Lines Matching defs:qentry
2211 * if qentry == NULL: new message, if temporarily undeliverable it will be enqueued
2212 * if qentry != NULL: a temporarily undeliverable message will not be enqueued,
2216 fprintlog(struct filed *f, struct buf_msg *passedbuffer, struct buf_queue *qentry)
2233 DPRINTF(D_CALL, "fprintlog(%p, %p, %p)\n", f, buffer, qentry);
2290 if (qentry
2322 if (!(buffer->flags & SIGN_MSG) && !qentry) {
2423 if (!qentry)
2424 qentry = message_queue_add(f, NEWREF(buffer));
2425 (void)tls_send(f, lineptr, len, qentry);
2440 } else if (!qentry) /* prevent recursion */
2488 if (e == 0 && qentry) { /* sent buffered msg */
2489 message_queue_remove(f, qentry);
2546 if (!qentry) /* prevent recursion */
2548 else if (qentry) /* sent buffered msg */
2549 message_queue_remove(f, qentry);
2562 if (qentry)
2563 message_queue_remove(f, qentry);
2585 if (qentry)
2586 message_queue_remove(f, qentry);
2601 if (!qentry) /* prevent recursion (see comment for F_FILE) */
2603 if (qentry) /* sent buffered msg */
2604 message_queue_remove(f, qentry);
2615 if (error && !qentry)
4392 struct buf_queue *qentry;
4408 while ((qentry = STAILQ_FIRST(&f->f_qhead))) {
4423 fprintlog(f, qentry->msg, qentry);
4519 struct buf_queue *qentry = NULL;
4534 qentry = find_qentry_to_delete(&f->f_qhead, strategy, 0);
4535 if (message_queue_remove(f, qentry))
4622 buf_queue_obj_size(struct buf_queue *qentry)
4626 if (!qentry)
4628 sum += sizeof(*qentry)
4629 + sizeof(*qentry->msg)
4630 + qentry->msg->msgsize
4631 + SAFEstrlen(qentry->msg->timestamp)+1
4632 + SAFEstrlen(qentry->msg->msgid)+1;
4633 if (qentry->msg->prog
4634 && qentry->msg->prog != include_pid)
4635 sum += strlen(qentry->msg->prog)+1;
4636 if (qentry->msg->pid
4637 && qentry->msg->pid != appname)
4638 sum += strlen(qentry->msg->pid)+1;
4639 if (qentry->msg->recvhost
4640 && qentry->msg->recvhost != LocalHostName
4641 && qentry->msg->recvhost != LocalFQDN
4642 && qentry->msg->recvhost != oldLocalFQDN)
4643 sum += strlen(qentry->msg->recvhost)+1;
4644 if (qentry->msg->host
4645 && qentry->msg->host != LocalHostName
4646 && qentry->msg->host != LocalFQDN
4647 && qentry->msg->host != oldLocalFQDN)
4648 sum += strlen(qentry->msg->host)+1;
4654 message_queue_remove(struct filed *f, struct buf_queue *qentry)
4656 if (!f || !qentry || !qentry->msg)
4660 STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
4662 f->f_qsize -= buf_queue_obj_size(qentry);
4665 qentry->msg, f, f->f_qelements);
4666 DELREF(qentry->msg);
4667 FREEPTR(qentry);
4672 * returns *qentry on success and NULL on error
4677 struct buf_queue *qentry;
4682 while (!(qentry = malloc(sizeof(*qentry)))
4685 if (!qentry) {
4690 qentry->msg = buffer;
4692 f->f_qsize += buf_queue_obj_size(qentry);
4693 STAILQ_INSERT_TAIL(&f->f_qhead, qentry, entries);
4697 return qentry;
4704 struct buf_queue *qentry;
4711 qentry = STAILQ_FIRST(&f->f_qhead);
4712 STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
4713 DELREF(qentry->msg);
4714 FREEPTR(qentry);