/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ |
H A D | logqueue-fifo.h | 30 LogQueue *log_queue_fifo_new(gint log_fifo_size, const gchar *persist_name); 31 LogQueue *log_queue_fifo_legacy_new(gint log_fifo_size, const gchar *persist_name);
|
H A D | logqueue.c | 254 log_queue_init_instance(LogQueue *self, const gchar *persist_name) in log_queue_init_instance() argument 259 self->persist_name = persist_name ? g_strdup(persist_name) : NULL; in log_queue_init_instance() 267 g_free(self->persist_name); in log_queue_free_method()
|
H A D | driver.h | 161 LogQueue *(*acquire_queue)(LogDestDriver *s, const gchar *persist_name); 175 log_dest_driver_acquire_queue(LogDestDriver *self, const gchar *persist_name) in log_dest_driver_acquire_queue() argument 179 q = self->acquire_queue(self, persist_name); in log_dest_driver_acquire_queue()
|
H A D | persist-state.c | 756 _map_header_of_entry(PersistState *self, const gchar *persist_name, PersistEntryHandle *handle) in _map_header_of_entry() argument 758 if (!_persist_state_lookup_key(self, persist_name, handle)) in _map_header_of_entry() 766 persist_state_alloc_entry(PersistState *self, const gchar *persist_name, gsize alloc_size) in persist_state_alloc_entry() argument 770 persist_state_remove_entry(self, persist_name); in persist_state_alloc_entry() 776 if (!_add_key(self, persist_name, handle)) in persist_state_alloc_entry() 805 persist_state_entry_exists(PersistState *self, const gchar *persist_name) in persist_state_entry_exists() argument 808 return _persist_state_lookup_key(self, persist_name, &handle); in persist_state_entry_exists() 888 persist_state_alloc_string(PersistState *self, const gchar *persist_name, const gchar *value, gssiz… in persist_state_alloc_string() argument 907 handle = persist_state_alloc_entry(self, persist_name, buf->len); in persist_state_alloc_string()
|
H A D | logqueue-fifo.c | 210 evt_tag_str("persist_name", self->super.persist_name)); in log_queue_fifo_drop_messages_from_input_queue() 401 evt_tag_str("persist_name", self->super.persist_name)); in log_queue_fifo_push_tail() 654 log_queue_fifo_new(gint log_fifo_size, const gchar *persist_name) in log_queue_fifo_new() argument 661 log_queue_init_instance(&self->super, persist_name); in log_queue_fifo_new() 692 log_queue_fifo_legacy_new(gint log_fifo_size, const gchar *persist_name) in log_queue_fifo_legacy_new() argument 694 LogQueueFifo *self = (LogQueueFifo *) log_queue_fifo_new(log_fifo_size, persist_name); in log_queue_fifo_legacy_new()
|
H A D | logqueue.h | 49 gchar *persist_name; member 223 void log_queue_init_instance(LogQueue *self, const gchar *persist_name);
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/python/pylib/syslogng/ |
H A D | __init__.py | 34 def __init__(self, persist_name, defaults=None): argument 35 super(Persist, self).__init__(persist_name)
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/kafka/ |
H A D | kafka-dest-driver.c | 156 static gchar persist_name[1024]; in _format_persist_name() local 158 if (d->persist_name) in _format_persist_name() 159 g_snprintf(persist_name, sizeof(persist_name), "kafka.%s", d->persist_name); in _format_persist_name() 161 g_snprintf(persist_name, sizeof(persist_name), "kafka(%s)", self->topic_name->template); in _format_persist_name() 162 return persist_name; in _format_persist_name()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afsnmp/ |
H A D | afsnmpdest.c | 457 static gchar persist_name[1024]; in snmpdest_dd_format_persist_name() local 459 g_snprintf(persist_name, sizeof(persist_name), "snmpdest(%s,%u)", self->host, self->port); in snmpdest_dd_format_persist_name() 460 return persist_name; in snmpdest_dd_format_persist_name() 468 static gchar persist_name[1024]; in snmpdest_dd_format_stats_instance() local 470 g_snprintf(persist_name, sizeof(persist_name), "snmpdest,%s,%u", self->host, self->port); in snmpdest_dd_format_stats_instance() 471 return persist_name; in snmpdest_dd_format_stats_instance()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afsql/ |
H A D | afsql.c | 961 static gchar persist_name[64]; in afsql_dd_format_stats_instance() local 963 g_snprintf(persist_name, sizeof(persist_name), in afsql_dd_format_stats_instance() 966 return persist_name; in afsql_dd_format_stats_instance() 973 static gchar persist_name[256]; in afsql_dd_format_persist_name() local 975 if (s->persist_name) in afsql_dd_format_persist_name() 976 g_snprintf(persist_name, sizeof(persist_name), "afsql_dd.%s", s->persist_name); in afsql_dd_format_persist_name() 978 g_snprintf(persist_name, sizeof(persist_name), "afsql_dd(%s,%s,%s,%s,%s)", self->type, in afsql_dd_format_persist_name() 981 return persist_name; in afsql_dd_format_persist_name()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/dbparser/ |
H A D | dbparser.c | 114 static gchar persist_name[512]; in log_db_parser_format_persist_name() local 116 g_snprintf(persist_name, sizeof(persist_name), "db-parser(%s)", self->db_file); in log_db_parser_format_persist_name() 117 return persist_name; in log_db_parser_format_persist_name()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logproto/ |
H A D | logproto-server.h | 88 gboolean (*restart_with_state)(LogProtoServer *s, PersistState *state, const gchar *persist_name); 136 …_proto_server_restart_with_state(LogProtoServer *s, PersistState *state, const gchar *persist_name) in log_proto_server_restart_with_state() argument 139 return s->restart_with_state(s, state, persist_name); in log_proto_server_restart_with_state()
|
H A D | logproto-client.h | 78 gboolean (*restart_with_state)(LogProtoClient *s, PersistState *state, const gchar *persist_name); 188 …_proto_client_restart_with_state(LogProtoClient *s, PersistState *state, const gchar *persist_name) in log_proto_client_restart_with_state() argument 191 return s->restart_with_state(s, state, persist_name); in log_proto_client_restart_with_state()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/tests/ |
H A D | test_logqueue.c | 194 stats_cluster_logpipe_key_set(&sc_key, SCS_DESTINATION, q->persist_name, NULL ); in Test() 293 stats_cluster_logpipe_key_set(&sc_key, SCS_DESTINATION, q->persist_name, NULL ); in Test() 315 stats_cluster_logpipe_key_set(&sc_key, SCS_DESTINATION, q->persist_name, NULL); in _register_stats_counters() 326 stats_cluster_logpipe_key_set(&sc_key, SCS_DESTINATION, q->persist_name, NULL); in _unregister_stats_counters()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/systemd-journal/ |
H A D | journal-reader.c | 78 gchar *persist_name; member 279 …self->persist_handle = persist_state_alloc_entry(self->persist_state, self->persist_name, sizeof(J… in _alloc_state() 300 …self->persist_handle = persist_state_lookup_entry(self->persist_state, self->persist_name, &state_… in _load_state() 639 self->persist_name = g_strdup_printf("systemd_journal(%s)", self->options->namespace); in _init_persist_name() 643 self->persist_name = g_strdup("systemd-journal"); in _init_persist_name() 705 g_free(self->persist_name); in _free() 754 self->persist_name = NULL; in journal_reader_new()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/python/ |
H A D | python-fetcher.c | 61 gchar *persist_name; member 270 g_free(py_instance->persist_name); in _py_free_bindings() 354 const gchar *persist_name = python_fetcher_format_persist_name((LogPipe *)self); in _py_set_persist_name() local 356 py_instance->persist_name = g_strdup(persist_name); in _py_set_persist_name() 668 { "persist_name", T_STRING, offsetof(PyLogFetcher, persist_name), READONLY },
|
H A D | python-source.c | 67 gchar *persist_name; member 189 g_free(py_instance->persist_name); in _py_free_bindings() 315 const gchar *persist_name = python_source_format_persist_name(&self->super.super.super.super); in _py_set_persist_name() local 317 py_instance->persist_name = g_strdup(persist_name); in _py_set_persist_name() 715 { "persist_name", T_STRING, offsetof(PyLogSource, persist_name), READONLY },
|
H A D | python-persist.h | 33 gchar *persist_name; member
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afmongodb/ |
H A D | afmongodb.c | 99 if (((LogPipe *)d)->persist_name) in _format_instance_id() 101 g_snprintf(args, sizeof(args), "%s", ((LogPipe *)d)->persist_name); in _format_instance_id() 140 return s->persist_name ? _format_instance_id(self, "afmongodb.%s") in _format_persist_name()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/diskq/ |
H A D | logqueue-disk.c | 200 const gchar *persist_name) in log_queue_disk_init_instance() argument 202 log_queue_init_instance(&self->super, persist_name); in log_queue_disk_init_instance()
|
H A D | logqueue-disk-reliable.c | 324 evt_tag_str("persist_name", s->persist_name)); in _push_tail() 341 evt_tag_str("persist_name", s->persist_name)); in _push_tail() 461 log_queue_disk_reliable_new(DiskQueueOptions *options, const gchar *persist_name) in log_queue_disk_reliable_new() argument 465 log_queue_disk_init_instance(&self->super, options, "SLRQ", persist_name); in log_queue_disk_reliable_new()
|
H A D | logqueue-disk-reliable.h | 38 LogQueue *log_queue_disk_reliable_new(DiskQueueOptions *options, const gchar *persist_name);
|
H A D | logqueue-disk-non-reliable.h | 39 LogQueue *log_queue_disk_non_reliable_new(DiskQueueOptions *options, const gchar *persist_name);
|
H A D | logqueue-disk-non-reliable.c | 420 evt_tag_str("persist_name", s->persist_name)); in _push_tail() 449 evt_tag_str("persist_name", s->persist_name)); in _push_tail() 555 log_queue_disk_non_reliable_new(DiskQueueOptions *options, const gchar *persist_name) in log_queue_disk_non_reliable_new() argument 559 log_queue_disk_init_instance(&self->super, options, "SLQF", persist_name); in log_queue_disk_non_reliable_new()
|
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logthrdest/ |
H A D | logthrdestdrv.c | 777 gchar *persist_name = _format_queue_persist_name(self); in _acquire_worker_queue() local 778 self->queue = log_dest_driver_acquire_queue(&self->owner->super, persist_name); in _acquire_worker_queue() 779 g_free(persist_name); in _acquire_worker_queue() 1097 static gchar persist_name[256]; in _format_seqnum_persist_name() local 1099 g_snprintf(persist_name, sizeof(persist_name), "%s.seqnum", in _format_seqnum_persist_name() 1102 return persist_name; in _format_seqnum_persist_name()
|