A message buffer with dnstap messages queued up. More...
|lock of the buffer structure. More...|
|the maximum size of the buffer, in bytes |
|current size of the buffer, in bytes. More...|
|number of messages in the queue |
|struct dt_msg_entry *||first|
|list of messages. More...|
|struct dt_msg_entry *||last|
|struct dt_io_thread *||dtio|
|reference to the io thread to wakeup |
|struct comm_timer *||wakeup_timer|
|the wakeup timer for dtio, on worker event base |
A message buffer with dnstap messages queued up.
It is per-worker. It has locks to synchronize. If the buffer is full, a new message cannot be added and is discarded. A thread reads the messages and sends them.
lock of the buffer structure.
Hold this lock to add or remove entries to the buffer. Release it so that other threads can also put messages to log, or a message can be taken out to send away by the writer thread.
|struct dt_msg_entry* dt_msg_queue::first|