Lines Matching defs:envelope

189 	struct rq_envelope	*envelope;
213 	/* create envelope in ramqueue message */
214 	envelope = xcalloc(1, sizeof *envelope);
215 	envelope->evpid = si->evpid;
216 	envelope->type = si->type;
217 	envelope->message = message;
218 	envelope->ctime = si->creation;
219 	envelope->expire = si->creation + si->ttl;
220 	envelope->sched = scheduler_backoff(si->creation,
222 	tree_xset(&message->envelopes, envelope->evpid, envelope);
225 	stat_increment("scheduler.ramqueue.envelope", 1);
227 	envelope->state = RQ_EVPSTATE_PENDING;
228 	TAILQ_INSERT_TAIL(&update->q_pending, envelope, entry);
230 	si->nexttry = envelope->sched;
306 	 * If the envelope was removed while inflight,  schedule it for
374 	/* If the envelope is suspended, just mark it as pending */
388 	/* If the holdq is full, just "tempfail" the envelope */
843 	struct rq_envelope	*envelope;
856 		    (void*)&envelope)))
857 			envelope->message = tomessage;
864 	while ((envelope = TAILQ_FIRST(&update->q_pending))) {
865 		TAILQ_REMOVE(&update->q_pending, envelope, entry);
866 		sorted_insert(rq, envelope);
990 	 * If envelope is inflight, mark it envelope for removal.
1089 	stat_decrement("scheduler.ramqueue.envelope", 1);
1156 	struct rq_envelope	*envelope;
1167 		    (void*)&envelope)))
1169 			    rq_envelope_to_text(envelope));