- pidfile
- presetenv
- resetenv
- - ring
- uid
- ulimit-n
- user
next line in the configuration file sees the new environment. See also
"setenv", "presetenv", and "unsetenv".
-ring <name> [desc <desc>] [format <format>] [size <size>] [maxlen <length>]
- Creates a named ring buffer which could be used on log line for instance.
-
- <desc> is an optionnal description string of the ring. It will appear on
- CLI. By default, <name> is reused to fill this field.
-
- <format> is the log format used when generating syslog messages. It may be
- one of the following :
-
- iso A message containing only the ISO date, followed by the text.
- The PID, process name and system name are omitted. This is
- designed to be used with a local log server.
-
- raw A message containing only the text. The level, PID, date, time,
- process name and system name are omitted. This is designed to be
- used in containers or during development, where the severity only
- depends on the file descriptor used (stdout/stderr). This is
- the default.
-
- rfc3164 The RFC3164 syslog message format. This is the default.
- (https://tools.ietf.org/html/rfc3164)
-
- rfc5424 The RFC5424 syslog message format.
- (https://tools.ietf.org/html/rfc5424)
-
- short A message containing only a level between angle brackets such as
- '<3>', followed by the text. The PID, date, time, process name
- and system name are omitted. This is designed to be used with a
- local log server. This format is compatible with what the systemd
- logger consumes.
-
- timed A message containing only a level between angle brackets such as
- '<3>', followed by ISO date and by the text. The PID, process
- name and system name are omitted. This is designed to be
- used with a local log server.
-
- <length> is the maximum length of an event message stored into the ring,
- including formatted header. If an event message is longer than
- <length>, it will be truncated to this length.
-
- <name> is the ring identifier, which follows the same naming convention as
- proxies and servers.
-
- <size> is the optionnal size in bytes. Default value is set to BUFSIZE.
-
stats bind-process [ all | odd | even | <process_num>[-[process_num>]] ] ...
Limits the stats socket to a certain set of processes numbers. By default the
stats socket is bound to all processes, causing a warning to be emitted when
#include <common/mini-clist.h>
#include <proto/log.h>
-#include <proto/sink.h>
#include <proto/proxy.h>
/* configuration sections */
return sent;
}
-
-int parse_sinkbuf(char **args, char **err);
-
#endif /* _PROTO_SINK_H */
/*
/* describes the configuration and current state of an event sink */
struct sink {
struct list sink_list; // position in the sink list
- char *name; // sink name
- char *desc; // sink description
+ const char *name; // sink name
+ const char *desc; // sink description
enum sink_fmt fmt; // format expected by the sink
enum sink_type type; // type of storage
uint32_t maxlen; // max message length (truncated above)
free(global.log_send_hostname);
global.log_send_hostname = strdup(name);
}
- else if (!strcmp(args[0], "ring")) {
- if (!parse_sinkbuf(args, &errmsg)) {
- ha_alert("parsing [%s:%d] : %s : %s\n", file, linenum, args[0], errmsg);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
- }
else if (!strcmp(args[0], "server-state-base")) { /* path base where HAProxy can find server state files */
if (global.server_state_base != NULL) {
ha_alert("parsing [%s:%d] : '%s' already specified. Continuing.\n", file, linenum, args[0]);
if (!sink)
goto end;
- sink->name = strdup(name);
- sink->desc = strdup(desc);
+ sink->name = name;
+ sink->desc = desc;
sink->fmt = fmt;
sink->type = SINK_TYPE_NEW;
sink->maxlen = BUFSIZE;
sink->ctx.ring = ring_new(size);
if (!sink->ctx.ring) {
LIST_DEL(&sink->sink_list);
- free(sink->name);
- free(sink->desc);
free(sink);
goto fail;
}
if (sink->type == SINK_TYPE_BUFFER)
ring_free(sink->ctx.ring);
LIST_DEL(&sink->sink_list);
- free(sink->name);
- free(sink->desc);
free(sink);
}
}
-/*
- * Parse "ring" keyword and create corresponding sink buffer.
- *
- * The function returns 1 in success case, otherwise, it returns 0 and err is
- * filled.
- */
-
-int parse_sinkbuf(char **args, char **err)
-{
- int myidx = 2;
- size_t size = BUFSIZE;
- size_t maxlen = size;
- int format = SINK_FMT_RAW;
- struct sink *sink = NULL;
- char *desc, *name = args[1];
- const char *inv;
-
- if (!*name) {
- memprintf(err, "missing sink name");
- goto error;
- }
-
- inv = invalid_char(name);
- if (inv) {
- memprintf(err, "invalid sink name '%s' (character '%c' is not permitted)", name, *inv);
- goto error;
- }
-
- desc = name;
-
- while (*args[myidx]) {
- if (!strcmp(args[myidx], "size")) {
- myidx++;
- size = atol(args[myidx]);
- if (!size) {
- memprintf(err, "invalid size '%s' for new sink buffer for ring '%s'", args[myidx], name);
- goto error;
- }
- }
- else if (!strcmp(args[myidx], "maxlen")) {
- myidx++;
- maxlen = atol(args[myidx]);
- if (!maxlen) {
- memprintf(err, "invalid size '%s' for new sink buffer for ring '%s'", args[myidx], name);
- goto error;
- }
- }
- else if (!strcmp(args[myidx], "maxlen")) {
- myidx++;
- maxlen = atol(args[myidx]);
- if (!maxlen) {
- memprintf(err, "invalid size '%s' for new sink buffer for ring '%s'", args[myidx], name);
- goto error;
- }
- }
- else if (!strcmp(args[myidx], "desc")) {
- myidx++;
- desc = args[myidx];
- }
- else if (!strcmp(args[myidx],"format")) {
- myidx++;
- if (!strcmp(args[myidx], "raw")) {
- format = SINK_FMT_RAW;
- }
- else if (!strcmp(args[myidx], "short")) {
- format = SINK_FMT_SHORT;
- }
- else if (!strcmp(args[myidx], "iso")) {
- format = SINK_FMT_ISO;
- }
- else if (!strcmp(args[myidx], "timed")) {
- format = SINK_FMT_TIMED;
- }
- else if (!strcmp(args[myidx], "rfc3164")) {
- format = SINK_FMT_RFC3164;
- }
- else if (!strcmp(args[myidx], "rfc5424")) {
- format = SINK_FMT_RFC5424;
- }
- else {
- memprintf(err, "unknown format '%s' for new sink buffer for ring '%s'", args[myidx], name);
- goto error;
- }
- }
- else {
- memprintf(err, "unknown parameter '%s' for new sink buffer for ring '%s'", args[myidx], name);
- goto error;
- }
- myidx++;
- }
-
- if (maxlen > size) {
- memprintf(err, "maxlen '%lu' exceeds size of the new sink buffer for ring '%s'", maxlen, name);
- goto error;
- }
-
- sink = sink_new_buf(name, desc, format, size);
- if (!sink || sink->type != SINK_TYPE_BUFFER) {
- memprintf(err, "failed to create a new sink buffer for ring '%s'", name);
- goto error;
- }
-
- sink->maxlen = maxlen;
-
- return 1;
-error:
- if (sink) {
- if (sink->type == SINK_TYPE_BUFFER)
- ring_free(sink->ctx.ring);
- LIST_DEL(&sink->sink_list);
- free(sink->name);
- free(sink->desc);
- free(sink);
- }
- return 0;
-
-}
-
INITCALL0(STG_REGISTER, sink_init);
REGISTER_POST_DEINIT(sink_deinit);
projects / thirdparty / haproxy.git / commitdiff
