Lines Matching full:call
105 * route an incoming cache manager call
108 bool afs_cm_incoming_call(struct afs_call *call) in afs_cm_incoming_call() argument
110 _enter("{%u, CB.OP %u}", call->service_id, call->operation_ID); in afs_cm_incoming_call()
112 switch (call->operation_ID) { in afs_cm_incoming_call()
114 call->type = &afs_SRXCBCallBack; in afs_cm_incoming_call()
117 call->type = &afs_SRXCBInitCallBackState; in afs_cm_incoming_call()
120 call->type = &afs_SRXCBInitCallBackState3; in afs_cm_incoming_call()
123 call->type = &afs_SRXCBProbe; in afs_cm_incoming_call()
126 call->type = &afs_SRXCBProbeUuid; in afs_cm_incoming_call()
129 call->type = &afs_SRXCBTellMeAboutYourself; in afs_cm_incoming_call()
132 if (call->service_id != YFS_CM_SERVICE) in afs_cm_incoming_call()
134 call->type = &afs_SRXYFSCB_CallBack; in afs_cm_incoming_call()
142 * Clean up a cache manager call.
144 static void afs_cm_destructor(struct afs_call *call) in afs_cm_destructor() argument
146 kfree(call->buffer); in afs_cm_destructor()
147 call->buffer = NULL; in afs_cm_destructor()
151 * Abort a service call from within an action function.
153 static void afs_abort_service_call(struct afs_call *call, u32 abort_code, int error, in afs_abort_service_call() argument
156 rxrpc_kernel_abort_call(call->net->socket, call->rxcall, in afs_abort_service_call()
158 afs_set_call_complete(call, error, 0); in afs_abort_service_call()
166 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_CallBack() local
174 if (call->server) { in SRXAFSCB_CallBack()
175 trace_afs_server(call->server->debug_id, in SRXAFSCB_CallBack()
176 refcount_read(&call->server->ref), in SRXAFSCB_CallBack()
177 atomic_read(&call->server->active), in SRXAFSCB_CallBack()
179 afs_break_callbacks(call->server, call->count, call->request); in SRXAFSCB_CallBack()
182 afs_send_empty_reply(call); in SRXAFSCB_CallBack()
183 afs_put_call(call); in SRXAFSCB_CallBack()
188 * deliver request data to a CB.CallBack call
190 static int afs_deliver_cb_callback(struct afs_call *call) in afs_deliver_cb_callback() argument
196 _enter("{%u}", call->unmarshall); in afs_deliver_cb_callback()
198 switch (call->unmarshall) { in afs_deliver_cb_callback()
200 afs_extract_to_tmp(call); in afs_deliver_cb_callback()
201 call->unmarshall++; in afs_deliver_cb_callback()
207 ret = afs_extract_data(call, true); in afs_deliver_cb_callback()
211 call->count = ntohl(call->tmp); in afs_deliver_cb_callback()
212 _debug("FID count: %u", call->count); in afs_deliver_cb_callback()
213 if (call->count > AFSCBMAX) in afs_deliver_cb_callback()
214 return afs_protocol_error(call, afs_eproto_cb_fid_count); in afs_deliver_cb_callback()
216 call->buffer = kmalloc(array3_size(call->count, 3, 4), in afs_deliver_cb_callback()
218 if (!call->buffer) in afs_deliver_cb_callback()
220 afs_extract_to_buf(call, call->count * 3 * 4); in afs_deliver_cb_callback()
221 call->unmarshall++; in afs_deliver_cb_callback()
226 ret = afs_extract_data(call, true); in afs_deliver_cb_callback()
231 call->request = kcalloc(call->count, in afs_deliver_cb_callback()
234 if (!call->request) in afs_deliver_cb_callback()
237 cb = call->request; in afs_deliver_cb_callback()
238 bp = call->buffer; in afs_deliver_cb_callback()
239 for (loop = call->count; loop > 0; loop--, cb++) { in afs_deliver_cb_callback()
245 afs_extract_to_tmp(call); in afs_deliver_cb_callback()
246 call->unmarshall++; in afs_deliver_cb_callback()
252 ret = afs_extract_data(call, true); in afs_deliver_cb_callback()
256 call->count2 = ntohl(call->tmp); in afs_deliver_cb_callback()
257 _debug("CB count: %u", call->count2); in afs_deliver_cb_callback()
258 if (call->count2 != call->count && call->count2 != 0) in afs_deliver_cb_callback()
259 return afs_protocol_error(call, afs_eproto_cb_count); in afs_deliver_cb_callback()
260 call->iter = &call->def_iter; in afs_deliver_cb_callback()
261 iov_iter_discard(&call->def_iter, ITER_DEST, call->count2 * 3 * 4); in afs_deliver_cb_callback()
262 call->unmarshall++; in afs_deliver_cb_callback()
267 iov_iter_count(call->iter), call->count2 * 3 * 4); in afs_deliver_cb_callback()
269 ret = afs_extract_data(call, false); in afs_deliver_cb_callback()
273 call->unmarshall++; in afs_deliver_cb_callback()
280 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_callback()
281 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_callback()
290 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_InitCallBackState() local
292 _enter("{%p}", call->server); in SRXAFSCB_InitCallBackState()
294 if (call->server) in SRXAFSCB_InitCallBackState()
295 afs_init_callback_state(call->server); in SRXAFSCB_InitCallBackState()
296 afs_send_empty_reply(call); in SRXAFSCB_InitCallBackState()
297 afs_put_call(call); in SRXAFSCB_InitCallBackState()
302 * deliver request data to a CB.InitCallBackState call
304 static int afs_deliver_cb_init_call_back_state(struct afs_call *call) in afs_deliver_cb_init_call_back_state() argument
308 afs_extract_discard(call, 0); in afs_deliver_cb_init_call_back_state()
309 return afs_extract_data(call, false); in afs_deliver_cb_init_call_back_state()
313 * deliver request data to a CB.InitCallBackState3 call
315 static int afs_deliver_cb_init_call_back_state3(struct afs_call *call) in afs_deliver_cb_init_call_back_state3() argument
322 _enter("{%u}", call->unmarshall); in afs_deliver_cb_init_call_back_state3()
324 switch (call->unmarshall) { in afs_deliver_cb_init_call_back_state3()
326 call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL); in afs_deliver_cb_init_call_back_state3()
327 if (!call->buffer) in afs_deliver_cb_init_call_back_state3()
329 afs_extract_to_buf(call, 11 * sizeof(__be32)); in afs_deliver_cb_init_call_back_state3()
330 call->unmarshall++; in afs_deliver_cb_init_call_back_state3()
335 ret = afs_extract_data(call, false); in afs_deliver_cb_init_call_back_state3()
343 call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL); in afs_deliver_cb_init_call_back_state3()
344 if (!call->request) in afs_deliver_cb_init_call_back_state3()
347 b = call->buffer; in afs_deliver_cb_init_call_back_state3()
348 r = call->request; in afs_deliver_cb_init_call_back_state3()
358 call->unmarshall++; in afs_deliver_cb_init_call_back_state3()
365 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_init_call_back_state3()
366 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_init_call_back_state3()
368 if (memcmp(call->request, &call->server->_uuid, sizeof(call->server->_uuid)) != 0) { in afs_deliver_cb_init_call_back_state3()
370 trace_afs_cm_no_server_u(call, call->request); in afs_deliver_cb_init_call_back_state3()
382 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_Probe() local
385 afs_send_empty_reply(call); in SRXAFSCB_Probe()
386 afs_put_call(call); in SRXAFSCB_Probe()
391 * deliver request data to a CB.Probe call
393 static int afs_deliver_cb_probe(struct afs_call *call) in afs_deliver_cb_probe() argument
399 afs_extract_discard(call, 0); in afs_deliver_cb_probe()
400 ret = afs_extract_data(call, false); in afs_deliver_cb_probe()
404 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_probe()
405 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_probe()
415 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_ProbeUuid() local
416 struct afs_uuid *r = call->request; in SRXAFSCB_ProbeUuid()
420 if (memcmp(r, &call->net->uuid, sizeof(call->net->uuid)) == 0) in SRXAFSCB_ProbeUuid()
421 afs_send_empty_reply(call); in SRXAFSCB_ProbeUuid()
423 afs_abort_service_call(call, 1, 1, afs_abort_probeuuid_negative); in SRXAFSCB_ProbeUuid()
425 afs_put_call(call); in SRXAFSCB_ProbeUuid()
430 * deliver request data to a CB.ProbeUuid call
432 static int afs_deliver_cb_probe_uuid(struct afs_call *call) in afs_deliver_cb_probe_uuid() argument
439 _enter("{%u}", call->unmarshall); in afs_deliver_cb_probe_uuid()
441 switch (call->unmarshall) { in afs_deliver_cb_probe_uuid()
443 call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL); in afs_deliver_cb_probe_uuid()
444 if (!call->buffer) in afs_deliver_cb_probe_uuid()
446 afs_extract_to_buf(call, 11 * sizeof(__be32)); in afs_deliver_cb_probe_uuid()
447 call->unmarshall++; in afs_deliver_cb_probe_uuid()
452 ret = afs_extract_data(call, false); in afs_deliver_cb_probe_uuid()
460 call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL); in afs_deliver_cb_probe_uuid()
461 if (!call->request) in afs_deliver_cb_probe_uuid()
464 b = call->buffer; in afs_deliver_cb_probe_uuid()
465 r = call->request; in afs_deliver_cb_probe_uuid()
475 call->unmarshall++; in afs_deliver_cb_probe_uuid()
482 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_probe_uuid()
483 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_probe_uuid()
492 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_TellMeAboutYourself() local
513 reply.ia.uuid[0] = call->net->uuid.time_low; in SRXAFSCB_TellMeAboutYourself()
514 reply.ia.uuid[1] = htonl(ntohs(call->net->uuid.time_mid)); in SRXAFSCB_TellMeAboutYourself()
515 reply.ia.uuid[2] = htonl(ntohs(call->net->uuid.time_hi_and_version)); in SRXAFSCB_TellMeAboutYourself()
516 reply.ia.uuid[3] = htonl((s8) call->net->uuid.clock_seq_hi_and_reserved); in SRXAFSCB_TellMeAboutYourself()
517 reply.ia.uuid[4] = htonl((s8) call->net->uuid.clock_seq_low); in SRXAFSCB_TellMeAboutYourself()
519 reply.ia.uuid[loop + 5] = htonl((s8) call->net->uuid.node[loop]); in SRXAFSCB_TellMeAboutYourself()
523 afs_send_simple_reply(call, &reply, sizeof(reply)); in SRXAFSCB_TellMeAboutYourself()
524 afs_put_call(call); in SRXAFSCB_TellMeAboutYourself()
529 * deliver request data to a CB.TellMeAboutYourself call
531 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call) in afs_deliver_cb_tell_me_about_yourself() argument
537 afs_extract_discard(call, 0); in afs_deliver_cb_tell_me_about_yourself()
538 ret = afs_extract_data(call, false); in afs_deliver_cb_tell_me_about_yourself()
542 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_tell_me_about_yourself()
543 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_tell_me_about_yourself()
548 * deliver request data to a YFS CB.CallBack call
550 static int afs_deliver_yfs_cb_callback(struct afs_call *call) in afs_deliver_yfs_cb_callback() argument
557 _enter("{%u}", call->unmarshall); in afs_deliver_yfs_cb_callback()
559 switch (call->unmarshall) { in afs_deliver_yfs_cb_callback()
561 afs_extract_to_tmp(call); in afs_deliver_yfs_cb_callback()
562 call->unmarshall++; in afs_deliver_yfs_cb_callback()
568 ret = afs_extract_data(call, true); in afs_deliver_yfs_cb_callback()
572 call->count = ntohl(call->tmp); in afs_deliver_yfs_cb_callback()
573 _debug("FID count: %u", call->count); in afs_deliver_yfs_cb_callback()
574 if (call->count > YFSCBMAX) in afs_deliver_yfs_cb_callback()
575 return afs_protocol_error(call, afs_eproto_cb_fid_count); in afs_deliver_yfs_cb_callback()
577 size = array_size(call->count, sizeof(struct yfs_xdr_YFSFid)); in afs_deliver_yfs_cb_callback()
578 call->buffer = kmalloc(size, GFP_KERNEL); in afs_deliver_yfs_cb_callback()
579 if (!call->buffer) in afs_deliver_yfs_cb_callback()
581 afs_extract_to_buf(call, size); in afs_deliver_yfs_cb_callback()
582 call->unmarshall++; in afs_deliver_yfs_cb_callback()
587 ret = afs_extract_data(call, false); in afs_deliver_yfs_cb_callback()
592 call->request = kcalloc(call->count, in afs_deliver_yfs_cb_callback()
595 if (!call->request) in afs_deliver_yfs_cb_callback()
598 cb = call->request; in afs_deliver_yfs_cb_callback()
599 bp = call->buffer; in afs_deliver_yfs_cb_callback()
600 for (loop = call->count; loop > 0; loop--, cb++) { in afs_deliver_yfs_cb_callback()
608 afs_extract_to_tmp(call); in afs_deliver_yfs_cb_callback()
609 call->unmarshall++; in afs_deliver_yfs_cb_callback()
616 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_yfs_cb_callback()
617 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_yfs_cb_callback()