1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
/*
* Copyright (c) 2002-2011 BalaBit IT Ltd, Budapest, Hungary
* Copyright (c) 1998-2011 Balázs Scheidler
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*
* As an additional exemption you are allowed to compile & link against the
* OpenSSL libraries as published by the OpenSSL project. See the file
* COPYING for details.
*
*/
#ifndef LOGSOURCE_H_INCLUDED
#define LOGSOURCE_H_INCLUDED
#include "logpipe.h"
#include "stats.h"
#include <iv_event.h>
typedef struct _LogSourceOptions
{
gint init_window_size;
const gchar *group_name;
gboolean keep_timestamp;
gboolean keep_hostname;
gboolean chain_hostnames;
gboolean normalize_hostnames;
gboolean use_dns;
gboolean use_fqdn;
gboolean use_dns_cache;
gchar *program_override;
gint program_override_len;
gchar *host_override;
gint host_override_len;
LogTagId source_group_tag;
GArray *tags;
} LogSourceOptions;
typedef struct _LogSource LogSource;
/**
* LogSource:
*
* This structure encapsulates an object which generates messages without
* defining how those messages are accepted by peers. The most prominent
* derived class is LogReader which is an extended RFC3164 capable syslog
* message processor used everywhere.
**/
struct _LogSource
{
LogPipe super;
LogSourceOptions *options;
guint16 stats_level;
guint16 stats_source;
gboolean threaded;
gchar *stats_id;
gchar *stats_instance;
GAtomicCounter window_size;
StatsCounterItem *last_message_seen;
StatsCounterItem *recvd_messages;
guint32 last_ack_count;
guint32 ack_count;
glong window_full_sleep_nsec;
struct timespec last_ack_rate_time;
void (*wakeup)(LogSource *s);
};
static inline gboolean
log_source_free_to_send(LogSource *self)
{
return g_atomic_counter_get(&self->window_size) > 0;
}
gboolean log_source_init(LogPipe *s);
gboolean log_source_deinit(LogPipe *s);
void log_source_set_options(LogSource *self, LogSourceOptions *options, gint stats_level, gint stats_source, const gchar *stats_id, const gchar *stats_instance, gboolean threaded);
void log_source_mangle_hostname(LogSource *self, LogMessage *msg);
void log_source_init_instance(LogSource *self);
void log_source_options_defaults(LogSourceOptions *options);
void log_source_options_init(LogSourceOptions *options, GlobalConfig *cfg, const gchar *group_name);
void log_source_options_destroy(LogSourceOptions *options);
void log_source_options_set_tags(LogSourceOptions *options, GList *tags);
void log_source_free(LogPipe *s);
void log_source_global_init(void);
#endif
|