Lines Matching defs:msgid
31 uint32_t msgid;
190 uint32_t msgid;
194 msgid = evpid_to_msgid(si->evpid);
197 if ((update = tree_get(&updates, msgid)) == NULL) {
201 tree_xset(&updates, msgid, update);
205 if ((message = tree_get(&update->messages, msgid)) == NULL) {
207 message->msgid = msgid;
209 tree_xset(&update->messages, msgid, message);
236 scheduler_ram_commit(uint32_t msgid)
243 update = tree_xpop(&updates, msgid);
263 scheduler_ram_rollback(uint32_t msgid)
271 if ((update = tree_pop(&updates, msgid)) == NULL)
291 uint32_t msgid;
295 msgid = evpid_to_msgid(si->evpid);
296 msg = tree_xget(&ramqueue.messages, msgid);
333 uint32_t msgid;
337 msgid = evpid_to_msgid(evpid);
338 msg = tree_xget(&ramqueue.messages, msgid);
360 uint32_t msgid;
364 msgid = evpid_to_msgid(evpid);
365 msg = tree_xget(&ramqueue.messages, msgid);
659 uint32_t msgid;
666 msgid = evpid_to_msgid(evpid);
667 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
677 msgid = evpid;
678 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
697 uint32_t msgid;
704 msgid = evpid_to_msgid(evpid);
705 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
714 msgid = evpid;
715 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
731 uint32_t msgid;
738 msgid = evpid_to_msgid(evpid);
739 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
748 msgid = evpid;
749 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
765 uint32_t msgid;
772 msgid = evpid_to_msgid(evpid);
773 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
782 msgid = evpid;
783 if ((msg = tree_get(&ramqueue.messages, msgid)) == NULL)
797 uint32_t msgid;
800 msgid = evpid_to_msgid(evpid);
802 msgid = evpid;
804 if (tree_get(&ramqueue.messages, msgid) == NULL)
1082 tree_xpop(&rq->messages, evp->message->msgid);
1164 log_debug("debug: | msg:%08" PRIx32, message->msgid);