qentry
struct qentry *q_next; /* next one */
struct qentry *item;
STAILQ_ENTRY(qentry) list;
static STAILQ_HEAD(, qentry) queue = STAILQ_HEAD_INITIALIZER(queue);
static struct qentry *dequeue(void);
struct qentry *item;
item = grep_malloc(sizeof(struct qentry));
static struct qentry *
struct qentry *item;
struct qentry *item;
struct string_queue *qentry, *old_qentry;
STAILQ_FOREACH(qentry, &sg->hashes, entries)
qentry = STAILQ_FIRST(&sg->hashes);
sg->spri, GlobalSign.gbc, qentry->key,
assert(qentry);
qentry->data);
qentry = STAILQ_NEXT(qentry, entries);
qentry = STAILQ_FIRST(&sg->hashes);
old_qentry = qentry;
qentry = STAILQ_NEXT(old_qentry, entries);
struct string_queue *qentry, *tmp_qentry;
STAILQ_FOREACH_SAFE(qentry, sqhead, entries, tmp_qentry) {
STAILQ_REMOVE(sqhead, qentry, string_queue, entries);
FREEPTR(qentry->data);
free(qentry);
struct string_queue *qentry;
if ((qentry = STAILQ_LAST(&sg->hashes, string_queue, entries))
&& !strcmp(qentry->data, hash)) {
MALLOC(qentry, sizeof(*qentry));
qentry->key = sign_assign_msg_num(sg);
qentry->data = hash;
STAILQ_INSERT_TAIL(&sg->hashes, qentry, entries);
"#%" PRIdFAST64 "\n", hash, sg, qentry->key);
struct buf_queue *qentry)
DPRINTF(D_CALL, "fprintlog(%p, %p, %p)\n", f, buffer, qentry);
if (qentry
if (!(buffer->flags & SIGN_MSG) && !qentry) {
if (!qentry)
qentry = message_queue_add(f, NEWREF(buffer));
(void)tls_send(f, lineptr, len, qentry);
} else if (!qentry) /* prevent recursion */
if (e == 0 && qentry) { /* sent buffered msg */
message_queue_remove(f, qentry);
if (!qentry) /* prevent recursion */
else if (qentry) /* sent buffered msg */
message_queue_remove(f, qentry);
if (qentry)
message_queue_remove(f, qentry);
if (qentry)
message_queue_remove(f, qentry);
if (!qentry) /* prevent recursion (see comment for F_FILE) */
if (qentry) /* sent buffered msg */
message_queue_remove(f, qentry);
if (error && !qentry)
struct buf_queue *qentry;
while ((qentry = STAILQ_FIRST(&f->f_qhead))) {
fprintlog(f, qentry->msg, qentry);
struct buf_queue *qentry = NULL;
qentry = find_qentry_to_delete(&f->f_qhead, strategy, 0);
if (message_queue_remove(f, qentry))
buf_queue_obj_size(struct buf_queue *qentry)
if (!qentry)
sum += sizeof(*qentry)
+ sizeof(*qentry->msg)
+ qentry->msg->msgsize
+ SAFEstrlen(qentry->msg->timestamp)+1
+ SAFEstrlen(qentry->msg->msgid)+1;
if (qentry->msg->prog
&& qentry->msg->prog != appname)
sum += strlen(qentry->msg->prog)+1;
if (qentry->msg->pid
&& qentry->msg->pid != include_pid)
sum += strlen(qentry->msg->pid)+1;
if (qentry->msg->recvhost
&& qentry->msg->recvhost != LocalHostName
&& qentry->msg->recvhost != LocalFQDN
&& qentry->msg->recvhost != oldLocalFQDN)
sum += strlen(qentry->msg->recvhost)+1;
if (qentry->msg->host
&& qentry->msg->host != LocalHostName
&& qentry->msg->host != LocalFQDN
&& qentry->msg->host != oldLocalFQDN)
sum += strlen(qentry->msg->host)+1;
message_queue_remove(struct filed *f, struct buf_queue *qentry)
if (!f || !qentry || !qentry->msg)
STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
f->f_qsize -= buf_queue_obj_size(qentry);
qentry->msg, f, f->f_qelements);
DELREF(qentry->msg);
FREEPTR(qentry);
struct buf_queue *qentry;
while (!(qentry = malloc(sizeof(*qentry)))
if (!qentry) {
qentry->msg = buffer;
f->f_qsize += buf_queue_obj_size(qentry);
STAILQ_INSERT_TAIL(&f->f_qhead, qentry, entries);
return qentry;
struct buf_queue *qentry;
qentry = STAILQ_FIRST(&f->f_qhead);
STAILQ_REMOVE(&f->f_qhead, qentry, buf_queue, entries);
DELREF(qentry->msg);
FREEPTR(qentry);
tls_send(struct filed *f, char *line, size_t len, struct buf_queue *qentry)
(void)NEWREF(qentry->msg);
smsg->qentry = qentry;
smsg->f, smsg->qentry->msg, smsg->line,
DELREF(msg->qentry->msg);
(void)message_queue_remove(msg->f, msg->qentry);
struct buf_queue *qentry;