Lines Matching refs:msg
98 EVRPC_HEADER(Message, msg, kill)
99 EVRPC_HEADER(NeverReply, msg, kill)
101 EVRPC_GENERATE(Message, msg, kill)
102 EVRPC_GENERATE(NeverReply, msg, kill)
147 EVRPC_REGISTER(base, Message, msg, kill, MessageCb, NULL);
148 EVRPC_REGISTER(base, NeverReply, msg, kill, NeverReplyCb, NULL);
261 struct msg *msg;
283 msg = msg_new();
284 EVTAG_ASSIGN(msg, from_name, "niels");
285 EVTAG_ASSIGN(msg, to_name, "tester");
286 msg_marshal(req->output_buffer, msg);
287 msg_free(msg);
327 struct msg *msg, struct kill *kill, void *arg)
366 struct msg *msg, struct kill *kill, void *arg)
452 struct msg *msg = NULL;
472 msg = msg_new();
473 tt_assert(msg);
474 EVTAG_ASSIGN(msg, from_name, "niels");
475 EVTAG_ASSIGN(msg, to_name, "tester");
479 EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL);
490 EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL);
501 EVRPC_MAKE_CTX(Message, msg, kill,
502 pool, msg, kill, GotKillCb, NULL);
513 if (msg)
514 msg_free(msg);
538 struct msg *msg=NULL;
547 msg = msg_new();
548 tt_assert(msg);
549 EVTAG_ASSIGN(msg, from_name, "niels");
550 EVTAG_ASSIGN(msg, to_name, "tester");
555 EVRPC_MAKE_REQUEST(Message, pool, msg, kill_one, GotKillCbTwo, NULL);
556 EVRPC_MAKE_REQUEST(Message, pool, msg, kill_two, GotKillCb, NULL);
567 if (msg)
568 msg_free(msg);
582 struct msg *msg, struct kill *kill, void *arg)
638 struct msg *msg = NULL;
652 msg = msg_new();
653 tt_assert(msg);
654 EVTAG_ASSIGN(msg, from_name, "niels");
655 EVTAG_ASSIGN(msg, to_name, "tester");
659 EVRPC_MAKE_REQUEST(Message, pool, msg, kill, GotKillCb, NULL);
672 if (msg)
673 msg_free(msg);
690 struct msg *msg = NULL;
702 msg = msg_new();
703 tt_assert(msg);
704 EVTAG_ASSIGN(msg, from_name, "niels");
705 EVTAG_ASSIGN(msg, to_name, "tester");
709 EVRPC_MAKE_REQUEST(NeverReply, pool, msg, kill, GotErrorCb, NULL);
723 if (msg)
724 msg_free(msg);
737 struct msg *msg = NULL, *msg2 = NULL;
745 msg = msg_new();
747 tt_assert(msg);
749 EVTAG_ASSIGN(msg, from_name, "niels");
750 EVTAG_ASSIGN(msg, to_name, "phoenix");
752 if (EVTAG_GET(msg, attack, &attack) == -1) {
766 run = EVTAG_ARRAY_ADD(msg, run);
787 if (msg_complete(msg) == -1)
790 evtag_marshal_msg(tmp, 0xdeaf, msg);
824 tt_abort_msg("Failed to get run msg.");
866 TT_DIE(("Cannot get %dth how_often msg.", i));
875 if (msg)
876 msg_free(msg);