97 EVRPC_HEADER(Message, msg, kill)
98 EVRPC_HEADER(NeverReply, msg, kill)
100 EVRPC_GENERATE(Message, msg, kill)
101 EVRPC_GENERATE(NeverReply, msg, kill)
146 	EVRPC_REGISTER(base, Message, msg, kill, MessageCb, NULL);  in rpc_setup()
147 	EVRPC_REGISTER(base, NeverReply, msg, kill, NeverReplyCb, NULL);  in rpc_setup()
260 	struct msg *msg;  in rpc_basic_message()  local
282 	msg = msg_new();  in rpc_basic_message()
283 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_basic_message()
284 	EVTAG_ASSIGN(msg, to_name, "tester");  in rpc_basic_message()
285 	msg_marshal(req->output_buffer, msg);  in rpc_basic_message()
286 	msg_free(msg);  in rpc_basic_message()
326     struct msg *msg, struct kill *kill, void *arg)  in GotKillCb()  argument
365     struct msg *msg, struct kill *kill, void *arg)  in GotKillCbTwo()  argument
451 	struct msg *msg = NULL;  in rpc_basic_client()  local
471 	msg = msg_new();  in rpc_basic_client()
472 	tt_assert(msg);  in rpc_basic_client()
473 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_basic_client()
474 	EVTAG_ASSIGN(msg, to_name, "tester");  in rpc_basic_client()
478 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill,  GotKillCb, NULL);  in rpc_basic_client()
489 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill,  GotKillCb, NULL);  in rpc_basic_client()
500 		    EVRPC_MAKE_CTX(Message, msg, kill,  in rpc_basic_client()
501 			pool, msg, kill, GotKillCb, NULL);  in rpc_basic_client()
512 	if (msg)  in rpc_basic_client()
513 		msg_free(msg);  in rpc_basic_client()
537 	struct msg *msg=NULL;  in rpc_basic_queued_client()  local
546 	msg = msg_new();  in rpc_basic_queued_client()
547 	tt_assert(msg);  in rpc_basic_queued_client()
548 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_basic_queued_client()
549 	EVTAG_ASSIGN(msg, to_name, "tester");  in rpc_basic_queued_client()
554 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill_one,  GotKillCbTwo, NULL);  in rpc_basic_queued_client()
555 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill_two,  GotKillCb, NULL);  in rpc_basic_queued_client()
566 	if (msg)  in rpc_basic_queued_client()
567 		msg_free(msg);  in rpc_basic_queued_client()
581     struct msg *msg, struct kill *kill, void *arg)  in GotErrorCb()  argument
637 	struct msg *msg = NULL;  in rpc_basic_client_with_pause()  local
651 	msg = msg_new();  in rpc_basic_client_with_pause()
652 	tt_assert(msg);  in rpc_basic_client_with_pause()
653 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_basic_client_with_pause()
654 	EVTAG_ASSIGN(msg, to_name, "tester");  in rpc_basic_client_with_pause()
658 	EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL);  in rpc_basic_client_with_pause()
671 	if (msg)  in rpc_basic_client_with_pause()
672 		msg_free(msg);  in rpc_basic_client_with_pause()
689 	struct msg *msg = NULL;  in rpc_client_timeout()  local
701 	msg = msg_new();  in rpc_client_timeout()
702 	tt_assert(msg);  in rpc_client_timeout()
703 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_client_timeout()
704 	EVTAG_ASSIGN(msg, to_name, "tester");  in rpc_client_timeout()
708 	EVRPC_MAKE_REQUEST(NeverReply, pool, msg, kill, GotErrorCb, NULL);  in rpc_client_timeout()
722 	if (msg)  in rpc_client_timeout()
723 		msg_free(msg);  in rpc_client_timeout()
736 	struct msg *msg = NULL, *msg2 = NULL;  in rpc_test()  local
744 	msg = msg_new();  in rpc_test()
746 	tt_assert(msg);  in rpc_test()
748 	EVTAG_ASSIGN(msg, from_name, "niels");  in rpc_test()
749 	EVTAG_ASSIGN(msg, to_name, "phoenix");  in rpc_test()
751 	if (EVTAG_GET(msg, attack, &attack) == -1) {  in rpc_test()
765 		run = EVTAG_ARRAY_ADD(msg, run);  in rpc_test()
786 	if (msg_complete(msg) == -1)  in rpc_test()
789 	evtag_marshal_msg(tmp, 0xdeaf, msg);  in rpc_test()
874 	if (msg)  in rpc_test()
875 		msg_free(msg);  in rpc_test()