| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logmsg/ |
| H A D | logmsg.h | 61 typedef struct _LogPathOptions LogPathOptions; typedef
247 LogMessage *log_msg_clone_cow(LogMessage *msg, const LogPathOptions *path_options);
248 LogMessage *log_msg_make_writable(LogMessage **pmsg, const LogPathOptions *path_options);
369 LogMessageQueueNode *log_msg_alloc_queue_node(LogMessage *msg, const LogPathOptions *path_options);
370 LogMessageQueueNode *log_msg_alloc_dynamic_queue_node(LogMessage *msg, const LogPathOptions *path_o…
383 void log_msg_add_ack(LogMessage *msg, const LogPathOptions *path_options);
384 void log_msg_ack(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type);
385 void log_msg_drop(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type);
386 const LogPathOptions *log_msg_break_ack(LogMessage *msg, const LogPathOptions *path_options,
387 LogPathOptions *local_options);
[all …]
|
| H A D | logmsg.c | 231 log_msg_make_writable(LogMessage **pself, const LogPathOptions *path_options) in log_msg_make_writable()
448 log_msg_alloc_queue_node(LogMessage *msg, const LogPathOptions *path_options) in log_msg_alloc_queue_node()
479 log_msg_alloc_dynamic_queue_node(LogMessage *msg, const LogPathOptions *path_options) in log_msg_alloc_dynamic_queue_node()
1259 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in log_msg_clone_ack()
1272 log_msg_clone_cow(LogMessage *msg, const LogPathOptions *path_options) in log_msg_clone_cow()
1451 log_msg_drop(LogMessage *msg, const LogPathOptions *path_options, AckType ack_type) in log_msg_drop()
1568 log_msg_add_ack(LogMessage *self, const LogPathOptions *path_options) in log_msg_add_ack()
1596 log_msg_ack(LogMessage *self, const LogPathOptions *path_options, AckType ack_type) in log_msg_ack()
1631 const LogPathOptions *
1632 log_msg_break_ack(LogMessage *msg, const LogPathOptions *path_options, LogPathOptions *local_option… in log_msg_break_ack()
[all …]
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ |
| H A D | logqueue.h | 69 void (*push_tail)(LogQueue *self, LogMessage *msg, const LogPathOptions *path_options);
70 void (*push_head)(LogQueue *self, LogMessage *msg, const LogPathOptions *path_options);
71 LogMessage *(*pop_head)(LogQueue *self, LogPathOptions *path_options);
105 log_queue_push_tail(LogQueue *self, LogMessage *msg, const LogPathOptions *path_options) in log_queue_push_tail()
111 log_queue_push_head(LogQueue *self, LogMessage *msg, const LogPathOptions *path_options) in log_queue_push_head()
117 log_queue_pop_head(LogQueue *self, LogPathOptions *path_options) in log_queue_pop_head()
133 log_queue_pop_head_ignore_throttle(LogQueue *self, LogPathOptions *path_options) in log_queue_pop_head_ignore_throttle()
|
| H A D | logpipe.h | 220 void (*queue)(LogPipe *self, LogMessage *msg, const LogPathOptions *path_options);
265 extern gboolean (*pipe_single_step_hook)(LogPipe *pipe, LogMessage *msg, const LogPathOptions *path…
339 log_pipe_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options);
342 log_pipe_forward_msg(LogPipe *self, LogMessage *msg, const LogPathOptions *path_options) in log_pipe_forward_msg()
355 log_pipe_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options) in log_pipe_queue()
357 LogPathOptions local_path_options; in log_pipe_queue()
|
| H A D | logqueue-fifo.c | 175 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in log_queue_fifo_drop_messages_from_input_queue()
305 _message_has_to_be_dropped(LogQueueFifo *self, const LogPathOptions *path_options) in _message_has_to_be_dropped()
315 _drop_message(LogMessage *msg, const LogPathOptions *path_options) in _drop_message()
338 log_queue_fifo_push_tail(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in log_queue_fifo_push_tail()
430 log_queue_fifo_push_head(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in log_queue_fifo_push_head()
458 log_queue_fifo_pop_head(LogQueue *s, LogPathOptions *path_options) in log_queue_fifo_pop_head()
533 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in log_queue_fifo_ack_backlog()
621 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in log_queue_fifo_free_queue()
|
| H A D | logpipe.c | 29 gboolean (*pipe_single_step_hook)(LogPipe *pipe, LogMessage *msg, const LogPathOptions *path_option…
162 __log_pipe_forward_msg(LogPipe *self, LogMessage *msg, const LogPathOptions *path_options)
|
| H A D | driver.h | 149 void log_src_driver_queue_method(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options);
204 void log_dest_driver_queue_method(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options);
|
| H A D | logmpx.c | 73 log_multiplexer_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options) in log_multiplexer_queue()
77 LogPathOptions local_options = *path_options; in log_multiplexer_queue()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/diskq/ |
| H A D | logqueue-disk-non-reliable.c | 136 LogPathOptions path_options; in _move_messages_from_overflow()
180 LogPathOptions path_options; in _move_messages_from_disk_to_qout()
212 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _ack_backlog()
258 _pop_head_qout(LogQueueDiskNonReliable *self, LogPathOptions *path_options) in _pop_head_qout()
268 _pop_head_qoverflow(LogQueueDiskNonReliable *self, LogPathOptions *path_options) in _pop_head_qoverflow()
279 _push_tail_qbacklog(LogQueueDiskNonReliable *self, LogMessage *msg, LogPathOptions *path_options) in _push_tail_qbacklog()
287 _pop_head(LogQueue *s, LogPathOptions *path_options) in _pop_head()
328 _push_head(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in _push_head()
369 _push_tail_qout(LogQueueDiskNonReliable *self, LogMessage *msg, const LogPathOptions *path_options) in _push_tail_qout()
406 _push_tail(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in _push_tail()
[all …]
|
| H A D | logqueue-disk-reliable.c | 36 _push_to_memory_queue_tail(GQueue *queue, gint64 position, LogMessage *msg, const LogPathOptions *p… in _push_to_memory_queue_tail()
47 _pop_from_memory_queue_head(GQueue *queue, gint64 *position, LogMessage **msg, LogPathOptions *path… in _pop_from_memory_queue_head()
87 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _empty_queue()
110 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _ack_backlog()
244 _pop_head(LogQueue *s, LogPathOptions *path_options) in _pop_head()
314 _push_tail(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in _push_tail()
368 LogPathOptions local_options = *path_options; in _push_tail()
384 _push_head(LogQueue *s, LogMessage *msg, const LogPathOptions *path_options) in _push_head()
|
| H A D | logqueue-disk.h | 55 LogMessage *log_queue_disk_read_message(LogQueueDisk *self, LogPathOptions *path_options);
56 void log_queue_disk_drop_message(LogQueueDisk *self, LogMessage *msg, const LogPathOptions *path_op…
|
| H A D | logqueue-disk.c | 125 log_queue_disk_read_message(LogQueueDisk *self, LogPathOptions *path_options) in log_queue_disk_read_message()
154 log_queue_disk_drop_message(LogQueueDisk *self, LogMessage *msg, const LogPathOptions *path_options) in log_queue_disk_drop_message()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/xml/tests/ |
| H A D | test_xml_parser.c | 109 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
148 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
230 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
250 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
332 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
363 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
394 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
438 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/parser/ |
| H A D | parser-expr.h | 41 …gboolean (*process)(LogParser *s, LogMessage **pmsg, const LogPathOptions *path_options, const gch…
61 log_parser_process(LogParser *self, LogMessage **pmsg, const LogPathOptions *path_options, const gc… in log_parser_process()
69 gboolean log_parser_process_message(LogParser *self, LogMessage **pmsg, const LogPathOptions *path_…
|
| H A D | parser-expr.c | 40 log_parser_process_message(LogParser *self, LogMessage **pmsg, const LogPathOptions *path_options) in log_parser_process_message()
80 log_parser_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options) in log_parser_queue()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/libtest/ |
| H A D | queue_utils_lib.c | 60 feed_empty_messages(LogQueue *q, const LogPathOptions *path_options, gint n) in feed_empty_messages()
76 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in feed_some_messages()
88 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in send_some_messages()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/diskq/tests/ |
| H A D | test_reliable_backlog.c | 117 LogPathOptions local_options = LOG_PATH_OPTIONS_INIT; in _prepare_eof_test()
149 LogPathOptions read_options; in test_read_over_eof()
171 LogPathOptions local_options = LOG_PATH_OPTIONS_INIT; in test_rewind_over_eof()
224 LogPathOptions read_options = LOG_PATH_OPTIONS_INIT; in Test()
253 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _prepare_rewind_backlog_test()
264 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _prepare_rewind_backlog_test()
284 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _prepare_rewind_backlog_test()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/tests/ |
| H A D | test_logqueue.c | 58 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _threaded_feed()
99 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in _threaded_consume()
336 LogPathOptions flow_controlled_path = LOG_PATH_OPTIONS_INIT;
339 LogPathOptions non_flow_controlled_path = LOG_PATH_OPTIONS_INIT;
376 LogPathOptions flow_controlled_path = LOG_PATH_OPTIONS_INIT; in _flow_control_feed_thread()
379 LogPathOptions non_flow_controlled_path = LOG_PATH_OPTIONS_INIT; in _flow_control_feed_thread()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/filter/ |
| H A D | filter-expr.h | 62 gboolean filter_expr_eval_root(FilterExprNode *self, LogMessage **msg, const LogPathOptions *path_o…
65 const LogPathOptions *path_options);
|
| H A D | filter-expr.c | 64 const LogPathOptions *path_options) in filter_expr_eval_root_with_context()
75 filter_expr_eval_root(FilterExprNode *self, LogMessage **msg, const LogPathOptions *path_options) in filter_expr_eval_root()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/tagsparser/tests/ |
| H A D | test_tagsparser.c | 56 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
80 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ack-tracker/tests/ |
| H A D | test_batched_ack_tracker.c | 104 _test_logpipe_dst_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options) in _test_logpipe_dst_queue()
203 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
262 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
302 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
|
| H A D | test_instant_ack_tracker.c | 66 _test_logpipe_dst_queue(LogPipe *s, LogMessage *msg, const LogPathOptions *path_options) in _test_logpipe_dst_queue()
159 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
223 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/regexp-parser/tests/ |
| H A D | test_regexp_parser.c | 102 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in ParameterizedTest()
130 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT; in Test()
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/affile/tests/ |
| H A D | test_wildcard_file_reader.c | 56 LogPathOptions path_options = LOG_PATH_OPTIONS_INIT;
70 void file_reader_queue_method(LogPipe *s, LogMessage *msg, const LogPathOptions *po) in file_reader_queue_method()
|