Lines Matching refs:evpid

50 	uint64_t		 reqid, evpid, holdq;  in queue_imsg()  local
173 m_get_evpid(&m, &evpid); in queue_imsg()
177 m_add_evpid(p_scheduler, evpid); in queue_imsg()
181 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
185 queue_envelope_delete(evpid); in queue_imsg()
190 m_get_evpid(&m, &evpid); in queue_imsg()
194 m_add_evpid(p_scheduler, evpid); in queue_imsg()
198 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
207 queue_envelope_delete(evpid); in queue_imsg()
213 evpid = req_bounce->evpid; in queue_imsg()
215 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
218 m_add_evpid(p_scheduler, evpid); in queue_imsg()
226 log_warnx("warn: could not update envelope %016"PRIx64, evpid); in queue_imsg()
231 m_get_evpid(&m, &evpid); in queue_imsg()
233 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
236 m_add_evpid(p_scheduler, evpid); in queue_imsg()
249 m_get_evpid(&m, &evpid); in queue_imsg()
251 bounce_add(evpid); in queue_imsg()
256 m_get_evpid(&m, &evpid); in queue_imsg()
258 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
261 m_add_evpid(p_scheduler, evpid); in queue_imsg()
279 m_get_evpid(&m, &evpid); in queue_imsg()
284 if (queue_envelope_load(evpid, &evp) == 0) in queue_imsg()
324 m_get_evpid(&m, &evpid); in queue_imsg()
328 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
344 queue_envelope_delete(evpid); in queue_imsg()
346 m_add_evpid(p_scheduler, evpid); in queue_imsg()
353 m_get_evpid(&m, &evpid); in queue_imsg()
357 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
360 m_add_evpid(p_scheduler, evpid); in queue_imsg()
370 log_warnx("warn: could not update envelope %016"PRIx64, evpid); in queue_imsg()
379 m_get_evpid(&m, &evpid); in queue_imsg()
383 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
386 m_add_evpid(p_scheduler, evpid); in queue_imsg()
396 queue_envelope_delete(evpid); in queue_imsg()
398 m_add_evpid(p_scheduler, evpid); in queue_imsg()
405 m_get_evpid(&m, &evpid); in queue_imsg()
407 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
410 m_add_evpid(p_scheduler, evpid); in queue_imsg()
476 m_get_evpid(&m, &evpid); in queue_imsg()
478 if (queue_envelope_load(evpid, &evp) == 0) { in queue_imsg()
480 "envelope %016" PRIx64, evpid); in queue_imsg()
495 m_add_msgid(p_scheduler, evpid_to_msgid(evpid)); in queue_imsg()