Home
last modified time | relevance | path

Searched refs:persist_name (Results 26 – 50 of 54) sorted by relevance

123

/dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/
H A Dlogqueue-fifo.h30 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 Dlogqueue.c254 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 Ddriver.h161 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 Dpersist-state.c756 _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 Dlogqueue-fifo.c210 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 Dlogqueue.h49 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__.py34 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 Dkafka-dest-driver.c156 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 Dafsnmpdest.c457 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 Dafsql.c961 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 Ddbparser.c114 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 Dlogproto-server.h88 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 Dlogproto-client.h78 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 Dtest_logqueue.c194 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 Djournal-reader.c78 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 Dpython-fetcher.c61 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 Dpython-source.c67 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 Dpython-persist.h33 gchar *persist_name; member
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afmongodb/
H A Dafmongodb.c99 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 Dlogqueue-disk.c200 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 Dlogqueue-disk-reliable.c324 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 Dlogqueue-disk-reliable.h38 LogQueue *log_queue_disk_reliable_new(DiskQueueOptions *options, const gchar *persist_name);
H A Dlogqueue-disk-non-reliable.h39 LogQueue *log_queue_disk_non_reliable_new(DiskQueueOptions *options, const gchar *persist_name);
H A Dlogqueue-disk-non-reliable.c420 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 Dlogthrdestdrv.c777 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()

123