syslog-ng source
Classes | Macros | Typedefs | Enumerations | Functions | Variables
logmsg.h File Reference
#include "syslog-ng.h"
#include "gsockaddr.h"
#include "atomic.h"
#include "serialize.h"
#include "timeutils/unixtime.h"
#include "logmsg/nvtable.h"
#include "logmsg/tags.h"
#include "messages.h"
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/time.h>
#include <iv_list.h>
Include dependency graph for logmsg.h:

Go to the source code of this file.

Classes

struct  LogMessageQueueNode
 
struct  LogMessage
 

Macros

#define IS_ACK_ABORTED(x)   ((x) == AT_ABORTED ? 1 : 0)
 
#define IS_ABORTFLAG_ON(x)   ((x) == 1 ? TRUE : FALSE)
 
#define IS_ACK_SUSPENDED(x)   ((x) == AT_SUSPENDED ? 1 : 0)
 
#define IS_SUSPENDFLAG_ON(x)   ((x) == 1 ? TRUE : FALSE)
 
#define STRICT_ROUND_TO_NEXT_EIGHT(x)   ((x + 8) & ~7)
 
#define LOGMSG_MAX_MATCHES   256
 
#define evt_tag_msg_reference(msg)
 

Typedefs

typedef void(* LMAckFunc) (LogMessage *lm, AckType ack_type)
 
typedef NVType LogMessageValueType
 
typedef gboolean(* LogMessageTagsForeachFunc) (const LogMessage *self, LogTagId tag_id, const gchar *name, gpointer user_data)
 

Enumerations

enum  AckType { AT_UNDEFINED , AT_PROCESSED , AT_ABORTED , AT_SUSPENDED }
 
enum  LogMessageTimeStamp { LM_TS_STAMP = 0 , LM_TS_RECVD = 1 , LM_TS_PROCESSED = 2 , LM_TS_MAX }
 
enum  {
  LM_V_NONE , LM_V_HOST , LM_V_HOST_FROM , LM_V_MESSAGE ,
  LM_V_PROGRAM , LM_V_PID , LM_V_MSGID , LM_V_SOURCE ,
  LM_V_LEGACY_MSGHDR , LM_V_MAX , LM_V_RAWMSG , LM_V_TRANSPORT ,
  LM_V_MSGFORMAT , LM_V_FILE_NAME , LM_V_PEER_IP , LM_V_PEER_PORT ,
  LM_V_PREDEFINED_MAX
}
 
enum  {
  LM_T_MSG_UTF8_SANITIZED , LM_T_SYSLOG_MISSING_PRI , LM_T_SYSLOG_INVALID_PRI , LM_T_SYSLOG_MISSING_TIMESTAMP ,
  LM_T_SYSLOG_INVALID_HOSTNAME , LM_T_SYSLOG_UNEXPECTED_FRAMING , LM_T_SYSLOG_RFC3164_MISSING_HEADER , LM_T_SYSLOG_RFC5424_MISSING_HOSTNAME ,
  LM_T_SYSLOG_RFC5424_MISSING_APP_NAME , LM_T_SYSLOG_RFC5424_MISSING_PROCID , LM_T_SYSLOG_RFC5424_MISSING_MSGID , LM_T_SYSLOG_RFC5424_MISSING_SDATA ,
  LM_T_SYSLOG_RFC5424_INVALID_SDATA , LM_T_SYSLOG_RFC5424_MISSING_MESSAGE , LM_T_SYSLOG_MISSING_MESSAGE , LM_T_SYSLOG_RFC_3164_INVALID_PROGRAM ,
  LM_T_PREDEFINED_MAX
}
 
enum  { LM_VF_SDATA = 0x0001 , LM_VF_MATCH = 0x0002 , LM_VF_MACRO = 0x0004 }
 
enum  {
  LF_OLD_UNPARSED = 0x0001 , LF_UTF8 = 0x0001 , LF_INTERNAL = 0x0002 , LF_LOCAL = 0x0004 ,
  LF_MARK = 0x0008 , LF_STATE_MASK = 0xFFF0 , LF_STATE_OWN_PAYLOAD = 0x0010 , LF_STATE_OWN_SADDR = 0x0020 ,
  LF_STATE_OWN_DADDR = 0x0040 , LF_STATE_OWN_TAGS = 0x0080 , LF_STATE_OWN_SDATA = 0x0100 , LF_STATE_OWN_MASK = 0x01F0 ,
  LF_STATE_CLONED_MASK = 0xFE00 , LF_STATE_TRACING = 0x0200 , LF_CHAINED_HOSTNAME = 0x00010000 , __UNUSED_LF_LEGACY_MSGHDR = 0x00020000
}
 
enum  _LogMessageValueType {
  LM_VT_STRING = 0 , LM_VT_JSON = 1 , LM_VT_BOOLEAN = 2 , __COMPAT_LM_VT_INT32 = 3 ,
  __COMPAT_LM_VT_INT64 = 4 , LM_VT_INTEGER = 4 , LM_VT_DOUBLE = 5 , LM_VT_DATETIME = 6 ,
  LM_VT_LIST = 7 , LM_VT_NULL = 8 , LM_VT_BYTES = 9 , LM_VT_PROTOBUF = 10 ,
  LM_VT_NONE = 255
}
 

Functions

const gchar * log_msg_value_type_to_str (LogMessageValueType self)
 
gboolean log_msg_value_type_from_str (const gchar *in_str, LogMessageValueType *out_type)
 
LogMessage * log_msg_ref (LogMessage *m)
 
void log_msg_unref (LogMessage *m)
 
void log_msg_write_protect (LogMessage *m)
 
LogMessage * log_msg_clone_cow (LogMessage *msg, const LogPathOptions *path_options)
 
LogMessage * log_msg_make_writable (LogMessage **pmsg, const LogPathOptions *path_options)
 
gboolean log_msg_write (LogMessage *self, SerializeArchive *sa)
 
gboolean log_msg_read (LogMessage *self, SerializeArchive *sa)
 
NVHandle log_msg_get_value_handle (const gchar *value_name)
 
gboolean log_msg_is_value_name_valid (const gchar *value)
 
const gchar * log_msg_get_handle_name (NVHandle handle, gssize *length)
 
const gchar * log_msg_get_macro_value (const LogMessage *self, gint id, gssize *value_len, LogMessageValueType *type)
 
const gchar * log_msg_get_match_with_type (const LogMessage *self, gint index_, gssize *value_len, LogMessageValueType *type)
 
const gchar * log_msg_get_match_if_set_with_type (const LogMessage *self, gint index_, gssize *value_len, LogMessageValueType *type)
 
void log_msg_set_value (LogMessage *self, NVHandle handle, const gchar *new_value, gssize length)
 
void log_msg_set_value_with_type (LogMessage *self, NVHandle handle, const gchar *value, gssize value_len, LogMessageValueType type)
 
void log_msg_set_value_indirect (LogMessage *self, NVHandle handle, NVHandle ref_handle, guint16 ofs, guint16 len)
 
void log_msg_set_value_indirect_with_type (LogMessage *self, NVHandle handle, NVHandle ref_handle, guint16 ofs, guint16 len, LogMessageValueType type)
 
void log_msg_unset_value (LogMessage *self, NVHandle handle)
 
void log_msg_unset_value_by_name (LogMessage *self, const gchar *name)
 
gboolean log_msg_values_foreach (const LogMessage *self, NVTableForeachFunc func, gpointer user_data)
 
NVHandle log_msg_get_match_handle (gint index_)
 
gint log_msg_get_match_index (NVHandle handle)
 
void log_msg_set_match (LogMessage *self, gint index, const gchar *value, gssize value_len)
 
void log_msg_set_match_with_type (LogMessage *self, gint index, const gchar *value, gssize value_len, LogMessageValueType type)
 
void log_msg_set_match_indirect (LogMessage *self, gint index, NVHandle ref_handle, guint16 ofs, guint16 len)
 
void log_msg_set_match_indirect_with_type (LogMessage *self, gint index, NVHandle ref_handle, guint16 ofs, guint16 len, LogMessageValueType type)
 
void log_msg_unset_match (LogMessage *self, gint index_)
 
const gchar * log_msg_get_match (const LogMessage *self, gint index_, gssize *value_len)
 
void log_msg_clear_matches (LogMessage *self)
 
void log_msg_truncate_matches (LogMessage *self, gint n)
 
void log_msg_rename_value (LogMessage *self, NVHandle from, NVHandle to)
 
void log_msg_append_format_sdata (const LogMessage *self, GString *result, guint32 seq_num)
 
void log_msg_format_sdata (const LogMessage *self, GString *result, guint32 seq_num)
 
void log_msg_clear_sdata (LogMessage *self)
 
void log_msg_set_tag_by_id_onoff (LogMessage *self, LogTagId id, gboolean on)
 
void log_msg_set_tag_by_id (LogMessage *self, LogTagId id)
 
void log_msg_set_tag_by_name (LogMessage *self, const gchar *name)
 
void log_msg_clear_tag_by_id (LogMessage *self, LogTagId id)
 
void log_msg_clear_tag_by_name (LogMessage *self, const gchar *name)
 
gboolean log_msg_is_tag_by_id (LogMessage *self, LogTagId id)
 
gboolean log_msg_is_tag_by_name (LogMessage *self, const gchar *name)
 
void log_msg_tags_foreach (const LogMessage *self, LogMessageTagsForeachFunc callback, gpointer user_data)
 
void log_msg_format_tags (const LogMessage *self, GString *result, gboolean include_localtags)
 
void log_msg_format_matches (const LogMessage *self, GString *result)
 
void log_msg_set_saddr (LogMessage *self, GSockAddr *saddr)
 
void log_msg_set_saddr_ref (LogMessage *self, GSockAddr *saddr)
 
void log_msg_set_daddr (LogMessage *self, GSockAddr *daddr)
 
void log_msg_set_daddr_ref (LogMessage *self, GSockAddr *daddr)
 
LogMessageQueueNode * log_msg_alloc_queue_node (LogMessage *msg, const LogPathOptions *path_options)
 
LogMessageQueueNode * log_msg_alloc_dynamic_queue_node (LogMessage *msg, const LogPathOptions *path_options)
 
void log_msg_free_queue_node (LogMessageQueueNode *node)
 
void log_msg_clear (LogMessage *self)
 
void log_msg_merge_context (LogMessage *self, LogMessage **context, gsize context_len)
 
LogMessage * log_msg_sized_new (gsize payload_size)
 
LogMessage * log_msg_new_mark (void)
 
LogMessage * log_msg_new_internal (gint prio, const gchar *msg)
 
LogMessage * log_msg_new_empty (void)
 
LogMessage * log_msg_new_local (void)
 
void log_msg_add_ack (LogMessage *msg, const LogPathOptions *path_options)
 
void log_msg_ack (LogMessage *msg, const LogPathOptions *path_options, AckType ack_type)
 
void log_msg_drop (LogMessage *msg, const LogPathOptions *path_options, AckType ack_type)
 
const LogPathOptions * log_msg_break_ack (LogMessage *msg, const LogPathOptions *path_options, LogPathOptions *local_path_options)
 
void log_msg_refcache_start_producer (LogMessage *self)
 
void log_msg_refcache_start_consumer (LogMessage *self, const LogPathOptions *path_options)
 
void log_msg_refcache_stop (void)
 
void log_msg_registry_init (void)
 
void log_msg_registry_deinit (void)
 
void log_msg_global_init (void)
 
void log_msg_global_deinit (void)
 
void log_msg_stats_global_init (void)
 
void log_msg_registry_foreach (GHFunc func, gpointer user_data)
 
gint log_msg_lookup_time_stamp_name (const gchar *name)
 
gssize log_msg_get_size (LogMessage *self)
 

Variables

NVRegistry * logmsg_registry
 
const char logmsg_sd_prefix []
 
const gint logmsg_sd_prefix_len
 
gint logmsg_node_max
 

Macro Definition Documentation

◆ evt_tag_msg_reference

#define evt_tag_msg_reference (   msg)
Value:
evt_tag_printf("msg", "%p", (msg)), \
evt_tag_printf("rcptid", "%" G_GUINT64_FORMAT, (msg)->rcptid)
evt_tag_printf
EVTTAG * evt_tag_printf(const char *tag, const char *format,...) G_GNUC_PRINTF(2
msg
LogMessage * msg
Definition: test_rename.c:35

◆ IS_ABORTFLAG_ON

#define IS_ABORTFLAG_ON (   x)    ((x) == 1 ? TRUE : FALSE)

◆ IS_ACK_ABORTED

#define IS_ACK_ABORTED (   x)    ((x) == AT_ABORTED ? 1 : 0)

◆ IS_ACK_SUSPENDED

#define IS_ACK_SUSPENDED (   x)    ((x) == AT_SUSPENDED ? 1 : 0)

◆ IS_SUSPENDFLAG_ON

#define IS_SUSPENDFLAG_ON (   x)    ((x) == 1 ? TRUE : FALSE)

◆ LOGMSG_MAX_MATCHES

#define LOGMSG_MAX_MATCHES   256

◆ STRICT_ROUND_TO_NEXT_EIGHT

#define STRICT_ROUND_TO_NEXT_EIGHT (   x)    ((x + 8) & ~7)

Typedef Documentation

◆ LMAckFunc

typedef void(* LMAckFunc) (LogMessage *lm, AckType ack_type)

◆ LogMessageTagsForeachFunc

typedef gboolean(* LogMessageTagsForeachFunc) (const LogMessage *self, LogTagId tag_id, const gchar *name, gpointer user_data)

◆ LogMessageValueType

typedef NVType LogMessageValueType

Enumeration Type Documentation

◆ anonymous enum

anonymous enum
Enumerator
LM_V_NONE 
LM_V_HOST 
LM_V_HOST_FROM 
LM_V_MESSAGE 
LM_V_PROGRAM 
LM_V_PID 
LM_V_MSGID 
LM_V_SOURCE 
LM_V_LEGACY_MSGHDR 
LM_V_MAX 
LM_V_RAWMSG 
LM_V_TRANSPORT 
LM_V_MSGFORMAT 
LM_V_FILE_NAME 
LM_V_PEER_IP 
LM_V_PEER_PORT 
LM_V_PREDEFINED_MAX 

◆ anonymous enum

anonymous enum
Enumerator
LM_T_MSG_UTF8_SANITIZED 
LM_T_SYSLOG_MISSING_PRI 
LM_T_SYSLOG_INVALID_PRI 
LM_T_SYSLOG_MISSING_TIMESTAMP 
LM_T_SYSLOG_INVALID_HOSTNAME 
LM_T_SYSLOG_UNEXPECTED_FRAMING 
LM_T_SYSLOG_RFC3164_MISSING_HEADER 
LM_T_SYSLOG_RFC5424_MISSING_HOSTNAME 
LM_T_SYSLOG_RFC5424_MISSING_APP_NAME 
LM_T_SYSLOG_RFC5424_MISSING_PROCID 
LM_T_SYSLOG_RFC5424_MISSING_MSGID 
LM_T_SYSLOG_RFC5424_MISSING_SDATA 
LM_T_SYSLOG_RFC5424_INVALID_SDATA 
LM_T_SYSLOG_RFC5424_MISSING_MESSAGE 
LM_T_SYSLOG_MISSING_MESSAGE 
LM_T_SYSLOG_RFC_3164_INVALID_PROGRAM 
LM_T_PREDEFINED_MAX 

◆ anonymous enum

anonymous enum
Enumerator
LM_VF_SDATA 
LM_VF_MATCH 
LM_VF_MACRO 

◆ anonymous enum

anonymous enum
Enumerator
LF_OLD_UNPARSED 
LF_UTF8 
LF_INTERNAL 
LF_LOCAL 
LF_MARK 
LF_STATE_MASK 
LF_STATE_OWN_PAYLOAD 
LF_STATE_OWN_SADDR 
LF_STATE_OWN_DADDR 
LF_STATE_OWN_TAGS 
LF_STATE_OWN_SDATA 
LF_STATE_OWN_MASK 
LF_STATE_CLONED_MASK 
LF_STATE_TRACING 
LF_CHAINED_HOSTNAME 
__UNUSED_LF_LEGACY_MSGHDR 

◆ _LogMessageValueType

enum _LogMessageValueType
Enumerator
LM_VT_STRING 
LM_VT_JSON 
LM_VT_BOOLEAN 
__COMPAT_LM_VT_INT32 
__COMPAT_LM_VT_INT64 
LM_VT_INTEGER 
LM_VT_DOUBLE 
LM_VT_DATETIME 
LM_VT_LIST 
LM_VT_NULL 
LM_VT_BYTES 
LM_VT_PROTOBUF 
LM_VT_NONE 

◆ AckType

enum AckType
Enumerator
AT_UNDEFINED 
AT_PROCESSED 
AT_ABORTED 
AT_SUSPENDED 

◆ LogMessageTimeStamp

enum LogMessageTimeStamp
Enumerator
LM_TS_STAMP 
LM_TS_RECVD 
LM_TS_PROCESSED 
LM_TS_MAX 

Function Documentation

◆ log_msg_ack()

void log_msg_ack ( LogMessage *  self,
const LogPathOptions *  path_options,
AckType  ack_type 
)

log_msg_ack: @msg: LogMessage instance @path_options: path specific options @acked: TRUE: positive ack, FALSE: negative ACK

Indicate that the message was processed successfully and the sender can queue further messages.

◆ log_msg_add_ack()

void log_msg_add_ack ( LogMessage *  self,
const LogPathOptions *  path_options 
)

log_msg_add_ack: @m: LogMessage instance

This function increments the number of required acknowledges.

◆ log_msg_alloc_dynamic_queue_node()

LogMessageQueueNode* log_msg_alloc_dynamic_queue_node ( LogMessage *  msg,
const LogPathOptions *  path_options 
)

◆ log_msg_alloc_queue_node()

LogMessageQueueNode* log_msg_alloc_queue_node ( LogMessage *  msg,
const LogPathOptions *  path_options 
)

◆ log_msg_append_format_sdata()

void log_msg_append_format_sdata ( const LogMessage *  self,
GString *  result,
guint32  seq_num 
)

◆ log_msg_break_ack()

const LogPathOptions* log_msg_break_ack ( LogMessage *  msg,
const LogPathOptions *  path_options,
LogPathOptions *  local_path_options 
)

◆ log_msg_clear()

void log_msg_clear ( LogMessage *  self)

◆ log_msg_clear_matches()

void log_msg_clear_matches ( LogMessage *  self)

◆ log_msg_clear_sdata()

void log_msg_clear_sdata ( LogMessage *  self)

◆ log_msg_clear_tag_by_id()

void log_msg_clear_tag_by_id ( LogMessage *  self,
LogTagId  id 
)

◆ log_msg_clear_tag_by_name()

void log_msg_clear_tag_by_name ( LogMessage *  self,
const gchar *  name 
)

◆ log_msg_clone_cow()

LogMessage* log_msg_clone_cow ( LogMessage *  msg,
const LogPathOptions *  path_options 
)

◆ log_msg_drop()

void log_msg_drop ( LogMessage *  msg,
const LogPathOptions *  path_options,
AckType  ack_type 
)

log_msg_drop: @msg: LogMessage instance @path_options: path specific options

This function is called whenever a destination driver feels that it is unable to process this message. It acks and unrefs the message.

◆ log_msg_format_matches()

void log_msg_format_matches ( const LogMessage *  self,
GString *  result 
)

◆ log_msg_format_sdata()

void log_msg_format_sdata ( const LogMessage *  self,
GString *  result,
guint32  seq_num 
)

◆ log_msg_format_tags()

void log_msg_format_tags ( const LogMessage *  self,
GString *  result,
gboolean  include_localtags 
)

◆ log_msg_free_queue_node()

void log_msg_free_queue_node ( LogMessageQueueNode *  node)

◆ log_msg_get_handle_name()

const gchar* log_msg_get_handle_name ( NVHandle  handle,
gssize *  length 
)

◆ log_msg_get_macro_value()

const gchar* log_msg_get_macro_value ( const LogMessage *  self,
gint  id,
gssize *  value_len,
LogMessageValueType *  type 
)

◆ log_msg_get_match()

const gchar* log_msg_get_match ( const LogMessage *  self,
gint  index_,
gssize *  value_len 
)

◆ log_msg_get_match_handle()

NVHandle log_msg_get_match_handle ( gint  index_)

◆ log_msg_get_match_if_set_with_type()

const gchar* log_msg_get_match_if_set_with_type ( const LogMessage *  self,
gint  index_,
gssize *  value_len,
LogMessageValueType *  type 
)

◆ log_msg_get_match_index()

gint log_msg_get_match_index ( NVHandle  handle)

◆ log_msg_get_match_with_type()

const gchar* log_msg_get_match_with_type ( const LogMessage *  self,
gint  index_,
gssize *  value_len,
LogMessageValueType *  type 
)

◆ log_msg_get_size()

gssize log_msg_get_size ( LogMessage *  self)

◆ log_msg_get_value_handle()

NVHandle log_msg_get_value_handle ( const gchar *  value_name)

◆ log_msg_global_deinit()

void log_msg_global_deinit ( void  )

◆ log_msg_global_init()

void log_msg_global_init ( void  )

◆ log_msg_is_tag_by_id()

gboolean log_msg_is_tag_by_id ( LogMessage *  self,
LogTagId  id 
)

◆ log_msg_is_tag_by_name()

gboolean log_msg_is_tag_by_name ( LogMessage *  self,
const gchar *  name 
)

◆ log_msg_is_value_name_valid()

gboolean log_msg_is_value_name_valid ( const gchar *  value)

◆ log_msg_lookup_time_stamp_name()

gint log_msg_lookup_time_stamp_name ( const gchar *  name)

◆ log_msg_make_writable()

LogMessage* log_msg_make_writable ( LogMessage **  pmsg,
const LogPathOptions *  path_options 
)

◆ log_msg_merge_context()

void log_msg_merge_context ( LogMessage *  self,
LogMessage **  context,
gsize  context_len 
)

◆ log_msg_new_empty()

LogMessage* log_msg_new_empty ( void  )

◆ log_msg_new_internal()

LogMessage* log_msg_new_internal ( gint  prio,
const gchar *  msg 
)

log_msg_new_internal: @prio: message priority (LOG_*) @msg: message text @flags: parse flags (LP_*)

This function creates a new log message for messages originating internally to syslog-ng

◆ log_msg_new_local()

LogMessage* log_msg_new_local ( void  )

◆ log_msg_new_mark()

LogMessage* log_msg_new_mark ( void  )

log_msg_new_mark:

This function returns a new MARK message. MARK messages have the LF_MARK flag set.

◆ log_msg_read()

gboolean log_msg_read ( LogMessage *  self,
SerializeArchive *  sa 
)

◆ log_msg_ref()

LogMessage* log_msg_ref ( LogMessage *  self)

log_msg_ref: @self: LogMessage instance

Increment reference count of @self and return the new reference.

◆ log_msg_refcache_start_consumer()

void log_msg_refcache_start_consumer ( LogMessage *  self,
const LogPathOptions *  path_options 
)

◆ log_msg_refcache_start_producer()

void log_msg_refcache_start_producer ( LogMessage *  self)

◆ log_msg_refcache_stop()

void log_msg_refcache_stop ( void  )

◆ log_msg_registry_deinit()

void log_msg_registry_deinit ( void  )

◆ log_msg_registry_foreach()

void log_msg_registry_foreach ( GHFunc  func,
gpointer  user_data 
)

◆ log_msg_registry_init()

void log_msg_registry_init ( void  )

◆ log_msg_rename_value()

void log_msg_rename_value ( LogMessage *  self,
NVHandle  from,
NVHandle  to 
)

◆ log_msg_set_daddr()

void log_msg_set_daddr ( LogMessage *  self,
GSockAddr *  daddr 
)

◆ log_msg_set_daddr_ref()

void log_msg_set_daddr_ref ( LogMessage *  self,
GSockAddr *  daddr 
)

◆ log_msg_set_match()

void log_msg_set_match ( LogMessage *  self,
gint  index,
const gchar *  value,
gssize  value_len 
)

◆ log_msg_set_match_indirect()

void log_msg_set_match_indirect ( LogMessage *  self,
gint  index,
NVHandle  ref_handle,
guint16  ofs,
guint16  len 
)

◆ log_msg_set_match_indirect_with_type()

void log_msg_set_match_indirect_with_type ( LogMessage *  self,
gint  index,
NVHandle  ref_handle,
guint16  ofs,
guint16  len,
LogMessageValueType  type 
)

◆ log_msg_set_match_with_type()

void log_msg_set_match_with_type ( LogMessage *  self,
gint  index,
const gchar *  value,
gssize  value_len,
LogMessageValueType  type 
)

◆ log_msg_set_saddr()

void log_msg_set_saddr ( LogMessage *  self,
GSockAddr *  saddr 
)

◆ log_msg_set_saddr_ref()

void log_msg_set_saddr_ref ( LogMessage *  self,
GSockAddr *  saddr 
)

◆ log_msg_set_tag_by_id()

void log_msg_set_tag_by_id ( LogMessage *  self,
LogTagId  id 
)

◆ log_msg_set_tag_by_id_onoff()

void log_msg_set_tag_by_id_onoff ( LogMessage *  self,
LogTagId  id,
gboolean  on 
)

◆ log_msg_set_tag_by_name()

void log_msg_set_tag_by_name ( LogMessage *  self,
const gchar *  name 
)

◆ log_msg_set_value()

void log_msg_set_value ( LogMessage *  self,
NVHandle  handle,
const gchar *  new_value,
gssize  length 
)

◆ log_msg_set_value_indirect()

void log_msg_set_value_indirect ( LogMessage *  self,
NVHandle  handle,
NVHandle  ref_handle,
guint16  ofs,
guint16  len 
)

◆ log_msg_set_value_indirect_with_type()

void log_msg_set_value_indirect_with_type ( LogMessage *  self,
NVHandle  handle,
NVHandle  ref_handle,
guint16  ofs,
guint16  len,
LogMessageValueType  type 
)

◆ log_msg_set_value_with_type()

void log_msg_set_value_with_type ( LogMessage *  self,
NVHandle  handle,
const gchar *  value,
gssize  value_len,
LogMessageValueType  type 
)

◆ log_msg_sized_new()

LogMessage* log_msg_sized_new ( gsize  payload_size)

◆ log_msg_stats_global_init()

void log_msg_stats_global_init ( void  )

◆ log_msg_tags_foreach()

void log_msg_tags_foreach ( const LogMessage *  self,
LogMessageTagsForeachFunc  callback,
gpointer  user_data 
)

◆ log_msg_truncate_matches()

void log_msg_truncate_matches ( LogMessage *  self,
gint  n 
)

◆ log_msg_unref()

void log_msg_unref ( LogMessage *  self)

log_msg_unref: @self: LogMessage instance

Decrement reference count and free self if the reference count becomes 0.

◆ log_msg_unset_match()

void log_msg_unset_match ( LogMessage *  self,
gint  index_ 
)

◆ log_msg_unset_value()

void log_msg_unset_value ( LogMessage *  self,
NVHandle  handle 
)

◆ log_msg_unset_value_by_name()

void log_msg_unset_value_by_name ( LogMessage *  self,
const gchar *  name 
)

◆ log_msg_value_type_from_str()

gboolean log_msg_value_type_from_str ( const gchar *  in_str,
LogMessageValueType *  out_type 
)

◆ log_msg_value_type_to_str()

const gchar* log_msg_value_type_to_str ( LogMessageValueType  self)

◆ log_msg_values_foreach()

gboolean log_msg_values_foreach ( const LogMessage *  self,
NVTableForeachFunc  func,
gpointer  user_data 
)

◆ log_msg_write()

gboolean log_msg_write ( LogMessage *  self,
SerializeArchive *  sa 
)

◆ log_msg_write_protect()

void log_msg_write_protect ( LogMessage *  m)

Variable Documentation

◆ logmsg_node_max

gint logmsg_node_max
extern

◆ logmsg_registry

NVRegistry* logmsg_registry
extern

◆ logmsg_sd_prefix

const char logmsg_sd_prefix[]
extern

◆ logmsg_sd_prefix_len

const gint logmsg_sd_prefix_len
extern