44 	struct qr_message	*msg;  in get_message()  local
46         msg = tree_get(&messages, msgid);  in get_message()
47         if (msg == NULL)  in get_message()
50 	return (msg);  in get_message()
56 	struct qr_message	*msg;  in queue_ram_message_create()  local
58 	msg = calloc(1, sizeof(*msg));  in queue_ram_message_create()
59 	if (msg == NULL) {  in queue_ram_message_create()
63 	tree_init(&msg->envelopes);  in queue_ram_message_create()
69 	tree_xset(&messages, *msgid, msg);  in queue_ram_message_create()
77 	struct qr_message	*msg;  in queue_ram_message_commit()  local
83 	if ((msg = tree_get(&messages, msgid)) == NULL) {  in queue_ram_message_commit()
99 	msg->len = sb.st_size;  in queue_ram_message_commit()
100 	msg->buf = malloc(msg->len);  in queue_ram_message_commit()
101 	if (msg->buf == NULL) {  in queue_ram_message_commit()
108 	n = fread(msg->buf, 1, msg->len, f);  in queue_ram_message_commit()
115 		stat_increment("queue.ram.message.size", msg->len);  in queue_ram_message_commit()
125 	struct qr_message	*msg;  in queue_ram_message_delete()  local
129 	if ((msg = tree_pop(&messages, msgid)) == NULL) {  in queue_ram_message_delete()
138 	stat_decrement("queue.ram.message.size", msg->len);  in queue_ram_message_delete()
139 	free(msg->buf);  in queue_ram_message_delete()
140 	free(msg);  in queue_ram_message_delete()
147 	struct qr_message	*msg;  in queue_ram_message_fd_r()  local
152 	if ((msg = tree_get(&messages, msgid)) == NULL) {  in queue_ram_message_fd_r()
176 	n = fwrite(msg->buf, 1, msg->len, f);  in queue_ram_message_fd_r()
177 	if (n != msg->len) {  in queue_ram_message_fd_r()
193 	struct qr_message	*msg;  in queue_ram_envelope_create()  local
195 	if ((msg = get_message(msgid)) == NULL)  in queue_ram_envelope_create()
200 	} while (tree_check(&msg->envelopes, *evpid));  in queue_ram_envelope_create()
214 	tree_xset(&msg->envelopes, *evpid, evp);  in queue_ram_envelope_create()
223 	struct qr_message	*msg;  in queue_ram_envelope_delete()  local
225 	if ((msg = get_message(evpid_to_msgid(evpid))) == NULL)  in queue_ram_envelope_delete()
228 	if ((evp = tree_pop(&msg->envelopes, evpid)) == NULL) {  in queue_ram_envelope_delete()
235 	if (tree_empty(&msg->envelopes)) {  in queue_ram_envelope_delete()
237 		stat_decrement("queue.ram.message.size", msg->len);  in queue_ram_envelope_delete()
238 		free(msg->buf);  in queue_ram_envelope_delete()
239 		free(msg);  in queue_ram_envelope_delete()
248 	struct qr_message	*msg;  in queue_ram_envelope_update()  local
251 	if ((msg = get_message(evpid_to_msgid(evpid))) == NULL)  in queue_ram_envelope_update()
254 	if ((evp = tree_get(&msg->envelopes, evpid)) == NULL) {  in queue_ram_envelope_update()
276 	struct qr_message	*msg;  in queue_ram_envelope_load()  local
278 	if ((msg = get_message(evpid_to_msgid(evpid))) == NULL)  in queue_ram_envelope_load()
281 	if ((evp = tree_get(&msg->envelopes, evpid)) == NULL) {  in queue_ram_envelope_load()