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 = kzalloc_objs(struct afs_callback_break, in afs_deliver_cb_callback()
232 call->count); in afs_deliver_cb_callback()
233 if (!call->request) in afs_deliver_cb_callback()
236 cb = call->request; in afs_deliver_cb_callback()
237 bp = call->buffer; in afs_deliver_cb_callback()
238 for (loop = call->count; loop > 0; loop--, cb++) { in afs_deliver_cb_callback()
244 afs_extract_to_tmp(call); in afs_deliver_cb_callback()
245 call->unmarshall++; in afs_deliver_cb_callback()
251 ret = afs_extract_data(call, true); in afs_deliver_cb_callback()
255 call->count2 = ntohl(call->tmp); in afs_deliver_cb_callback()
256 _debug("CB count: %u", call->count2); in afs_deliver_cb_callback()
257 if (call->count2 != call->count && call->count2 != 0) in afs_deliver_cb_callback()
258 return afs_protocol_error(call, afs_eproto_cb_count); in afs_deliver_cb_callback()
259 call->iter = &call->def_iter; in afs_deliver_cb_callback()
260 iov_iter_discard(&call->def_iter, ITER_DEST, call->count2 * 3 * 4); in afs_deliver_cb_callback()
261 call->unmarshall++; in afs_deliver_cb_callback()
266 iov_iter_count(call->iter), call->count2 * 3 * 4); in afs_deliver_cb_callback()
268 ret = afs_extract_data(call, false); in afs_deliver_cb_callback()
272 call->unmarshall++; in afs_deliver_cb_callback()
279 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_callback()
280 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_callback()
289 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_InitCallBackState() local
291 _enter("{%p}", call->server); in SRXAFSCB_InitCallBackState()
293 if (call->server) in SRXAFSCB_InitCallBackState()
294 afs_init_callback_state(call->server); in SRXAFSCB_InitCallBackState()
295 afs_send_empty_reply(call); in SRXAFSCB_InitCallBackState()
296 afs_put_call(call); in SRXAFSCB_InitCallBackState()
301 * deliver request data to a CB.InitCallBackState call
303 static int afs_deliver_cb_init_call_back_state(struct afs_call *call) in afs_deliver_cb_init_call_back_state() argument
307 afs_extract_discard(call, 0); in afs_deliver_cb_init_call_back_state()
308 return afs_extract_data(call, false); in afs_deliver_cb_init_call_back_state()
312 * deliver request data to a CB.InitCallBackState3 call
314 static int afs_deliver_cb_init_call_back_state3(struct afs_call *call) in afs_deliver_cb_init_call_back_state3() argument
321 _enter("{%u}", call->unmarshall); in afs_deliver_cb_init_call_back_state3()
323 switch (call->unmarshall) { in afs_deliver_cb_init_call_back_state3()
325 call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL); in afs_deliver_cb_init_call_back_state3()
326 if (!call->buffer) in afs_deliver_cb_init_call_back_state3()
328 afs_extract_to_buf(call, 11 * sizeof(__be32)); in afs_deliver_cb_init_call_back_state3()
329 call->unmarshall++; in afs_deliver_cb_init_call_back_state3()
334 ret = afs_extract_data(call, false); in afs_deliver_cb_init_call_back_state3()
342 call->request = kmalloc_obj(struct afs_uuid); in afs_deliver_cb_init_call_back_state3()
343 if (!call->request) in afs_deliver_cb_init_call_back_state3()
346 b = call->buffer; in afs_deliver_cb_init_call_back_state3()
347 r = call->request; in afs_deliver_cb_init_call_back_state3()
357 call->unmarshall++; in afs_deliver_cb_init_call_back_state3()
364 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_init_call_back_state3()
365 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_init_call_back_state3()
367 if (memcmp(call->request, &call->server->_uuid, sizeof(call->server->_uuid)) != 0) { in afs_deliver_cb_init_call_back_state3()
369 trace_afs_cm_no_server_u(call, call->request); in afs_deliver_cb_init_call_back_state3()
381 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_Probe() local
384 afs_send_empty_reply(call); in SRXAFSCB_Probe()
385 afs_put_call(call); in SRXAFSCB_Probe()
390 * deliver request data to a CB.Probe call
392 static int afs_deliver_cb_probe(struct afs_call *call) in afs_deliver_cb_probe() argument
398 afs_extract_discard(call, 0); in afs_deliver_cb_probe()
399 ret = afs_extract_data(call, false); in afs_deliver_cb_probe()
403 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_probe()
404 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_probe()
414 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_ProbeUuid() local
415 struct afs_uuid *r = call->request; in SRXAFSCB_ProbeUuid()
419 if (memcmp(r, &call->net->uuid, sizeof(call->net->uuid)) == 0) in SRXAFSCB_ProbeUuid()
420 afs_send_empty_reply(call); in SRXAFSCB_ProbeUuid()
422 afs_abort_service_call(call, 1, 1, afs_abort_probeuuid_negative); in SRXAFSCB_ProbeUuid()
424 afs_put_call(call); in SRXAFSCB_ProbeUuid()
429 * deliver request data to a CB.ProbeUuid call
431 static int afs_deliver_cb_probe_uuid(struct afs_call *call) in afs_deliver_cb_probe_uuid() argument
438 _enter("{%u}", call->unmarshall); in afs_deliver_cb_probe_uuid()
440 switch (call->unmarshall) { in afs_deliver_cb_probe_uuid()
442 call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL); in afs_deliver_cb_probe_uuid()
443 if (!call->buffer) in afs_deliver_cb_probe_uuid()
445 afs_extract_to_buf(call, 11 * sizeof(__be32)); in afs_deliver_cb_probe_uuid()
446 call->unmarshall++; in afs_deliver_cb_probe_uuid()
451 ret = afs_extract_data(call, false); in afs_deliver_cb_probe_uuid()
459 call->request = kmalloc_obj(struct afs_uuid); in afs_deliver_cb_probe_uuid()
460 if (!call->request) in afs_deliver_cb_probe_uuid()
463 b = call->buffer; in afs_deliver_cb_probe_uuid()
464 r = call->request; in afs_deliver_cb_probe_uuid()
474 call->unmarshall++; in afs_deliver_cb_probe_uuid()
481 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_probe_uuid()
482 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_probe_uuid()
491 struct afs_call *call = container_of(work, struct afs_call, work); in SRXAFSCB_TellMeAboutYourself() local
512 reply.ia.uuid[0] = call->net->uuid.time_low; in SRXAFSCB_TellMeAboutYourself()
513 reply.ia.uuid[1] = htonl(ntohs(call->net->uuid.time_mid)); in SRXAFSCB_TellMeAboutYourself()
514 reply.ia.uuid[2] = htonl(ntohs(call->net->uuid.time_hi_and_version)); in SRXAFSCB_TellMeAboutYourself()
515 reply.ia.uuid[3] = htonl((s8) call->net->uuid.clock_seq_hi_and_reserved); in SRXAFSCB_TellMeAboutYourself()
516 reply.ia.uuid[4] = htonl((s8) call->net->uuid.clock_seq_low); in SRXAFSCB_TellMeAboutYourself()
518 reply.ia.uuid[loop + 5] = htonl((s8) call->net->uuid.node[loop]); in SRXAFSCB_TellMeAboutYourself()
522 afs_send_simple_reply(call, &reply, sizeof(reply)); in SRXAFSCB_TellMeAboutYourself()
523 afs_put_call(call); in SRXAFSCB_TellMeAboutYourself()
528 * deliver request data to a CB.TellMeAboutYourself call
530 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call) in afs_deliver_cb_tell_me_about_yourself() argument
536 afs_extract_discard(call, 0); in afs_deliver_cb_tell_me_about_yourself()
537 ret = afs_extract_data(call, false); in afs_deliver_cb_tell_me_about_yourself()
541 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_cb_tell_me_about_yourself()
542 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_cb_tell_me_about_yourself()
547 * deliver request data to a YFS CB.CallBack call
549 static int afs_deliver_yfs_cb_callback(struct afs_call *call) in afs_deliver_yfs_cb_callback() argument
556 _enter("{%u}", call->unmarshall); in afs_deliver_yfs_cb_callback()
558 switch (call->unmarshall) { in afs_deliver_yfs_cb_callback()
560 afs_extract_to_tmp(call); in afs_deliver_yfs_cb_callback()
561 call->unmarshall++; in afs_deliver_yfs_cb_callback()
567 ret = afs_extract_data(call, true); in afs_deliver_yfs_cb_callback()
571 call->count = ntohl(call->tmp); in afs_deliver_yfs_cb_callback()
572 _debug("FID count: %u", call->count); in afs_deliver_yfs_cb_callback()
573 if (call->count > YFSCBMAX) in afs_deliver_yfs_cb_callback()
574 return afs_protocol_error(call, afs_eproto_cb_fid_count); in afs_deliver_yfs_cb_callback()
576 size = array_size(call->count, sizeof(struct yfs_xdr_YFSFid)); in afs_deliver_yfs_cb_callback()
577 call->buffer = kmalloc(size, GFP_KERNEL); in afs_deliver_yfs_cb_callback()
578 if (!call->buffer) in afs_deliver_yfs_cb_callback()
580 afs_extract_to_buf(call, size); in afs_deliver_yfs_cb_callback()
581 call->unmarshall++; in afs_deliver_yfs_cb_callback()
586 ret = afs_extract_data(call, false); in afs_deliver_yfs_cb_callback()
591 call->request = kzalloc_objs(struct afs_callback_break, in afs_deliver_yfs_cb_callback()
592 call->count); in afs_deliver_yfs_cb_callback()
593 if (!call->request) in afs_deliver_yfs_cb_callback()
596 cb = call->request; in afs_deliver_yfs_cb_callback()
597 bp = call->buffer; in afs_deliver_yfs_cb_callback()
598 for (loop = call->count; loop > 0; loop--, cb++) { in afs_deliver_yfs_cb_callback()
606 afs_extract_to_tmp(call); in afs_deliver_yfs_cb_callback()
607 call->unmarshall++; in afs_deliver_yfs_cb_callback()
614 if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING)) in afs_deliver_yfs_cb_callback()
615 return afs_io_error(call, afs_io_error_cm_reply); in afs_deliver_yfs_cb_callback()