103  * route an incoming cache manager call
106 bool afs_cm_incoming_call(struct afs_call *call)  in afs_cm_incoming_call()  argument
108 	_enter("{%u, CB.OP %u}", call->service_id, call->operation_ID);  in afs_cm_incoming_call()
110 	switch (call->operation_ID) {  in afs_cm_incoming_call()
112 		call->type = &afs_SRXCBCallBack;  in afs_cm_incoming_call()
115 		call->type = &afs_SRXCBInitCallBackState;  in afs_cm_incoming_call()
118 		call->type = &afs_SRXCBInitCallBackState3;  in afs_cm_incoming_call()
121 		call->type = &afs_SRXCBProbe;  in afs_cm_incoming_call()
124 		call->type = &afs_SRXCBProbeUuid;  in afs_cm_incoming_call()
127 		call->type = &afs_SRXCBTellMeAboutYourself;  in afs_cm_incoming_call()
130 		if (call->service_id != YFS_CM_SERVICE)  in afs_cm_incoming_call()
132 		call->type = &afs_SRXYFSCB_CallBack;  in afs_cm_incoming_call()
143 static int afs_find_cm_server_by_peer(struct afs_call *call)  in afs_find_cm_server_by_peer()  argument
148 	rxrpc_kernel_get_peer(call->net->socket, call->rxcall, &srx);  in afs_find_cm_server_by_peer()
150 	server = afs_find_server(call->net, &srx);  in afs_find_cm_server_by_peer()
152 		trace_afs_cm_no_server(call, &srx);  in afs_find_cm_server_by_peer()
156 	call->server = server;  in afs_find_cm_server_by_peer()
164 static int afs_find_cm_server_by_uuid(struct afs_call *call,  in afs_find_cm_server_by_uuid()  argument
170 	server = afs_find_server_by_uuid(call->net, call->request);  in afs_find_cm_server_by_uuid()
173 		trace_afs_cm_no_server_u(call, call->request);  in afs_find_cm_server_by_uuid()
177 	call->server = server;  in afs_find_cm_server_by_uuid()
182  * Clean up a cache manager call.
184 static void afs_cm_destructor(struct afs_call *call)  in afs_cm_destructor()  argument
186 	kfree(call->buffer);  in afs_cm_destructor()
187 	call->buffer = NULL;  in afs_cm_destructor()
191  * Abort a service call from within an action function.
193 static void afs_abort_service_call(struct afs_call *call, u32 abort_code, int error,  in afs_abort_service_call()  argument
196 	rxrpc_kernel_abort_call(call->net->socket, call->rxcall,  in afs_abort_service_call()
198 	afs_set_call_complete(call, error, 0);  in afs_abort_service_call()
206 	struct afs_call *call = container_of(work, struct afs_call, work);  in SRXAFSCB_CallBack()  local
214 	if (call->server) {  in SRXAFSCB_CallBack()
215 		trace_afs_server(call->server,  in SRXAFSCB_CallBack()
216 				 atomic_read(&call->server->ref),  in SRXAFSCB_CallBack()
217 				 atomic_read(&call->server->active),  in SRXAFSCB_CallBack()
219 		afs_break_callbacks(call->server, call->count, call->request);  in SRXAFSCB_CallBack()
222 	afs_send_empty_reply(call);  in SRXAFSCB_CallBack()
223 	afs_put_call(call);  in SRXAFSCB_CallBack()
228  * deliver request data to a CB.CallBack call
230 static int afs_deliver_cb_callback(struct afs_call *call)  in afs_deliver_cb_callback()  argument
236 	_enter("{%u}", call->unmarshall);  in afs_deliver_cb_callback()
238 	switch (call->unmarshall) {  in afs_deliver_cb_callback()
240 		afs_extract_to_tmp(call);  in afs_deliver_cb_callback()
241 		call->unmarshall++;  in afs_deliver_cb_callback()
247 		ret = afs_extract_data(call, true);  in afs_deliver_cb_callback()
251 		call->count = ntohl(call->tmp);  in afs_deliver_cb_callback()
252 		_debug("FID count: %u", call->count);  in afs_deliver_cb_callback()
253 		if (call->count > AFSCBMAX)  in afs_deliver_cb_callback()
254 			return afs_protocol_error(call, afs_eproto_cb_fid_count);  in afs_deliver_cb_callback()
256 		call->buffer = kmalloc(array3_size(call->count, 3, 4),  in afs_deliver_cb_callback()
258 		if (!call->buffer)  in afs_deliver_cb_callback()
260 		afs_extract_to_buf(call, call->count * 3 * 4);  in afs_deliver_cb_callback()
261 		call->unmarshall++;  in afs_deliver_cb_callback()
266 		ret = afs_extract_data(call, true);  in afs_deliver_cb_callback()
271 		call->request = kcalloc(call->count,  in afs_deliver_cb_callback()
274 		if (!call->request)  in afs_deliver_cb_callback()
277 		cb = call->request;  in afs_deliver_cb_callback()
278 		bp = call->buffer;  in afs_deliver_cb_callback()
279 		for (loop = call->count; loop > 0; loop--, cb++) {  in afs_deliver_cb_callback()
285 		afs_extract_to_tmp(call);  in afs_deliver_cb_callback()
286 		call->unmarshall++;  in afs_deliver_cb_callback()
292 		ret = afs_extract_data(call, true);  in afs_deliver_cb_callback()
296 		call->count2 = ntohl(call->tmp);  in afs_deliver_cb_callback()
297 		_debug("CB count: %u", call->count2);  in afs_deliver_cb_callback()
298 		if (call->count2 != call->count && call->count2 != 0)  in afs_deliver_cb_callback()
299 			return afs_protocol_error(call, afs_eproto_cb_count);  in afs_deliver_cb_callback()
300 		call->iter = &call->def_iter;  in afs_deliver_cb_callback()
301 		iov_iter_discard(&call->def_iter, READ, call->count2 * 3 * 4);  in afs_deliver_cb_callback()
302 		call->unmarshall++;  in afs_deliver_cb_callback()
307 		       iov_iter_count(call->iter), call->count2 * 3 * 4);  in afs_deliver_cb_callback()
309 		ret = afs_extract_data(call, false);  in afs_deliver_cb_callback()
313 		call->unmarshall++;  in afs_deliver_cb_callback()
320 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_cb_callback()
321 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_cb_callback()
325 	return afs_find_cm_server_by_peer(call);  in afs_deliver_cb_callback()
333 	struct afs_call *call = container_of(work, struct afs_call, work);  in SRXAFSCB_InitCallBackState()  local
335 	_enter("{%p}", call->server);  in SRXAFSCB_InitCallBackState()
337 	if (call->server)  in SRXAFSCB_InitCallBackState()
338 		afs_init_callback_state(call->server);  in SRXAFSCB_InitCallBackState()
339 	afs_send_empty_reply(call);  in SRXAFSCB_InitCallBackState()
340 	afs_put_call(call);  in SRXAFSCB_InitCallBackState()
345  * deliver request data to a CB.InitCallBackState call
347 static int afs_deliver_cb_init_call_back_state(struct afs_call *call)  in afs_deliver_cb_init_call_back_state()  argument
353 	afs_extract_discard(call, 0);  in afs_deliver_cb_init_call_back_state()
354 	ret = afs_extract_data(call, false);  in afs_deliver_cb_init_call_back_state()
360 	return afs_find_cm_server_by_peer(call);  in afs_deliver_cb_init_call_back_state()
364  * deliver request data to a CB.InitCallBackState3 call
366 static int afs_deliver_cb_init_call_back_state3(struct afs_call *call)  in afs_deliver_cb_init_call_back_state3()  argument
375 	_enter("{%u}", call->unmarshall);  in afs_deliver_cb_init_call_back_state3()
377 	switch (call->unmarshall) {  in afs_deliver_cb_init_call_back_state3()
379 		call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL);  in afs_deliver_cb_init_call_back_state3()
380 		if (!call->buffer)  in afs_deliver_cb_init_call_back_state3()
382 		afs_extract_to_buf(call, 11 * sizeof(__be32));  in afs_deliver_cb_init_call_back_state3()
383 		call->unmarshall++;  in afs_deliver_cb_init_call_back_state3()
388 		ret = afs_extract_data(call, false);  in afs_deliver_cb_init_call_back_state3()
396 		call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);  in afs_deliver_cb_init_call_back_state3()
397 		if (!call->request)  in afs_deliver_cb_init_call_back_state3()
400 		b = call->buffer;  in afs_deliver_cb_init_call_back_state3()
401 		r = call->request;  in afs_deliver_cb_init_call_back_state3()
411 		call->unmarshall++;  in afs_deliver_cb_init_call_back_state3()
418 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_cb_init_call_back_state3()
419 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_cb_init_call_back_state3()
423 	return afs_find_cm_server_by_uuid(call, call->request);  in afs_deliver_cb_init_call_back_state3()
431 	struct afs_call *call = container_of(work, struct afs_call, work);  in SRXAFSCB_Probe()  local
434 	afs_send_empty_reply(call);  in SRXAFSCB_Probe()
435 	afs_put_call(call);  in SRXAFSCB_Probe()
440  * deliver request data to a CB.Probe call
442 static int afs_deliver_cb_probe(struct afs_call *call)  in afs_deliver_cb_probe()  argument
448 	afs_extract_discard(call, 0);  in afs_deliver_cb_probe()
449 	ret = afs_extract_data(call, false);  in afs_deliver_cb_probe()
453 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_cb_probe()
454 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_cb_probe()
455 	return afs_find_cm_server_by_peer(call);  in afs_deliver_cb_probe()
464 	struct afs_call *call = container_of(work, struct afs_call, work);  in SRXAFSCB_ProbeUuid()  local
465 	struct afs_uuid *r = call->request;  in SRXAFSCB_ProbeUuid()
469 	if (memcmp(r, &call->net->uuid, sizeof(call->net->uuid)) == 0)  in SRXAFSCB_ProbeUuid()
470 		afs_send_empty_reply(call);  in SRXAFSCB_ProbeUuid()
472 		afs_abort_service_call(call, 1, 1, "K-1");  in SRXAFSCB_ProbeUuid()
474 	afs_put_call(call);  in SRXAFSCB_ProbeUuid()
479  * deliver request data to a CB.ProbeUuid call
481 static int afs_deliver_cb_probe_uuid(struct afs_call *call)  in afs_deliver_cb_probe_uuid()  argument
488 	_enter("{%u}", call->unmarshall);  in afs_deliver_cb_probe_uuid()
490 	switch (call->unmarshall) {  in afs_deliver_cb_probe_uuid()
492 		call->buffer = kmalloc_array(11, sizeof(__be32), GFP_KERNEL);  in afs_deliver_cb_probe_uuid()
493 		if (!call->buffer)  in afs_deliver_cb_probe_uuid()
495 		afs_extract_to_buf(call, 11 * sizeof(__be32));  in afs_deliver_cb_probe_uuid()
496 		call->unmarshall++;  in afs_deliver_cb_probe_uuid()
501 		ret = afs_extract_data(call, false);  in afs_deliver_cb_probe_uuid()
509 		call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);  in afs_deliver_cb_probe_uuid()
510 		if (!call->request)  in afs_deliver_cb_probe_uuid()
513 		b = call->buffer;  in afs_deliver_cb_probe_uuid()
514 		r = call->request;  in afs_deliver_cb_probe_uuid()
524 		call->unmarshall++;  in afs_deliver_cb_probe_uuid()
531 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_cb_probe_uuid()
532 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_cb_probe_uuid()
533 	return afs_find_cm_server_by_peer(call);  in afs_deliver_cb_probe_uuid()
541 	struct afs_call *call = container_of(work, struct afs_call, work);  in SRXAFSCB_TellMeAboutYourself()  local
562 	reply.ia.uuid[0] = call->net->uuid.time_low;  in SRXAFSCB_TellMeAboutYourself()
563 	reply.ia.uuid[1] = htonl(ntohs(call->net->uuid.time_mid));  in SRXAFSCB_TellMeAboutYourself()
564 	reply.ia.uuid[2] = htonl(ntohs(call->net->uuid.time_hi_and_version));  in SRXAFSCB_TellMeAboutYourself()
565 	reply.ia.uuid[3] = htonl((s8) call->net->uuid.clock_seq_hi_and_reserved);  in SRXAFSCB_TellMeAboutYourself()
566 	reply.ia.uuid[4] = htonl((s8) call->net->uuid.clock_seq_low);  in SRXAFSCB_TellMeAboutYourself()
568 		reply.ia.uuid[loop + 5] = htonl((s8) call->net->uuid.node[loop]);  in SRXAFSCB_TellMeAboutYourself()
572 	afs_send_simple_reply(call, &reply, sizeof(reply));  in SRXAFSCB_TellMeAboutYourself()
573 	afs_put_call(call);  in SRXAFSCB_TellMeAboutYourself()
578  * deliver request data to a CB.TellMeAboutYourself call
580 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call)  in afs_deliver_cb_tell_me_about_yourself()  argument
586 	afs_extract_discard(call, 0);  in afs_deliver_cb_tell_me_about_yourself()
587 	ret = afs_extract_data(call, false);  in afs_deliver_cb_tell_me_about_yourself()
591 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_cb_tell_me_about_yourself()
592 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_cb_tell_me_about_yourself()
593 	return afs_find_cm_server_by_peer(call);  in afs_deliver_cb_tell_me_about_yourself()
597  * deliver request data to a YFS CB.CallBack call
599 static int afs_deliver_yfs_cb_callback(struct afs_call *call)  in afs_deliver_yfs_cb_callback()  argument
606 	_enter("{%u}", call->unmarshall);  in afs_deliver_yfs_cb_callback()
608 	switch (call->unmarshall) {  in afs_deliver_yfs_cb_callback()
610 		afs_extract_to_tmp(call);  in afs_deliver_yfs_cb_callback()
611 		call->unmarshall++;  in afs_deliver_yfs_cb_callback()
617 		ret = afs_extract_data(call, true);  in afs_deliver_yfs_cb_callback()
621 		call->count = ntohl(call->tmp);  in afs_deliver_yfs_cb_callback()
622 		_debug("FID count: %u", call->count);  in afs_deliver_yfs_cb_callback()
623 		if (call->count > YFSCBMAX)  in afs_deliver_yfs_cb_callback()
624 			return afs_protocol_error(call, afs_eproto_cb_fid_count);  in afs_deliver_yfs_cb_callback()
626 		size = array_size(call->count, sizeof(struct yfs_xdr_YFSFid));  in afs_deliver_yfs_cb_callback()
627 		call->buffer = kmalloc(size, GFP_KERNEL);  in afs_deliver_yfs_cb_callback()
628 		if (!call->buffer)  in afs_deliver_yfs_cb_callback()
630 		afs_extract_to_buf(call, size);  in afs_deliver_yfs_cb_callback()
631 		call->unmarshall++;  in afs_deliver_yfs_cb_callback()
636 		ret = afs_extract_data(call, false);  in afs_deliver_yfs_cb_callback()
641 		call->request = kcalloc(call->count,  in afs_deliver_yfs_cb_callback()
644 		if (!call->request)  in afs_deliver_yfs_cb_callback()
647 		cb = call->request;  in afs_deliver_yfs_cb_callback()
648 		bp = call->buffer;  in afs_deliver_yfs_cb_callback()
649 		for (loop = call->count; loop > 0; loop--, cb++) {  in afs_deliver_yfs_cb_callback()
657 		afs_extract_to_tmp(call);  in afs_deliver_yfs_cb_callback()
658 		call->unmarshall++;  in afs_deliver_yfs_cb_callback()
665 	if (!afs_check_call_state(call, AFS_CALL_SV_REPLYING))  in afs_deliver_yfs_cb_callback()
666 		return afs_io_error(call, afs_io_error_cm_reply);  in afs_deliver_yfs_cb_callback()
671 	return afs_find_cm_server_by_peer(call);  in afs_deliver_yfs_cb_callback()