RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2024-12-11 14:05:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

MEDIUM: threads/logs: Make logs thread-safe

Browse Source 
log buffers and static variables used in log functions are now thread-local. So
there is no need to lock anything to log messages. Moreover, per-thread
init/deinit functions are now used to initialize these buffers.
This commit is contained in:
Christopher Faulet 2017-06-02 16:20:16 +02:00 committed by Willy Tarreau
parent 9a65571781
commit f8188c69fa
2 changed files with 33 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
include/proto/log.h
View File

@ -28,6 +28,8 @@
#include <common/config.h>
#include <common/memory.h>
#include <common/hathreads.h>
#include <types/log.h>
#include <types/proxy.h>
#include <types/stream.h>
@ -42,10 +44,10 @@ extern char clf_http_log_format[];
extern char default_rfc5424_sd_log_format[];
extern char *logheader;
extern char *logheader_rfc5424;
extern char *logline;
extern char *logline_rfc5424;
extern THREAD_LOCAL char *logheader;
extern THREAD_LOCAL char *logheader_rfc5424;
extern THREAD_LOCAL char *logline;
extern THREAD_LOCAL char *logline_rfc5424;
/*

47
src/log.c
View File

@ -211,26 +211,26 @@ char default_rfc5424_sd_log_format[] = "- ";
* RFC3164 format. It begins with time-based part and is updated by
* update_log_hdr().
*/
char *logheader = NULL;
THREAD_LOCAL char *logheader = NULL;
/* This is a global syslog header for messages in RFC5424 format. It is
* updated by update_log_hdr_rfc5424().
*/
char *logheader_rfc5424 = NULL;
THREAD_LOCAL char *logheader_rfc5424 = NULL;
/* This is a global syslog message buffer, common to all outgoing
* messages. It contains only the data part.
*/
char *logline = NULL;
THREAD_LOCAL char *logline = NULL;
/* A global syslog message buffer, common to all RFC5424 syslog messages.
* Currently, it is used for generating the structured-data part.
*/
char *logline_rfc5424 = NULL;
THREAD_LOCAL char *logline_rfc5424 = NULL;
/* A global buffer used to store all startup alerts/warnings. It will then be
* retrieve on the CLI. */
static char *startup_logs = NULL;
static THREAD_LOCAL char *startup_logs = NULL;
struct logformat_var_args {
char *name;
@ -985,10 +985,10 @@ char *lf_port(char *dst, struct sockaddr *sockaddr, size_t size, struct logforma
*/
static char *update_log_hdr(const time_t time)
{
static long tvsec;
static char *dataptr = NULL; /* backup of last end of header, NULL first time */
static struct chunk host = { NULL, 0, 0 };
static int sep = 0;
static THREAD_LOCAL long tvsec;
static THREAD_LOCAL char *dataptr = NULL; /* backup of last end of header, NULL first time */
static THREAD_LOCAL struct chunk host = { NULL, 0, 0 };
static THREAD_LOCAL int sep = 0;
if (unlikely(time != tvsec || dataptr == NULL)) {
/* this string is rebuild only once a second */
@ -1030,8 +1030,8 @@ static char *update_log_hdr(const time_t time)
*/
static char *update_log_hdr_rfc5424(const time_t time)
{
static long tvsec;
static char *dataptr = NULL; /* backup of last end of header, NULL first time */
static THREAD_LOCAL long tvsec;
static THREAD_LOCAL char *dataptr = NULL; /* backup of last end of header, NULL first time */
const char *gmt_offset;
if (unlikely(time != tvsec || dataptr == NULL)) {
@ -1094,14 +1094,14 @@ void send_log(struct proxy *p, int level, const char *format, ...)
*/
void __send_log(struct proxy *p, int level, char *message, size_t size, char *sd, size_t sd_size)
{
static struct iovec iovec[NB_MSG_IOVEC_ELEMENTS] = { };
static struct msghdr msghdr = {
.msg_iov = iovec,
static THREAD_LOCAL struct iovec iovec[NB_MSG_IOVEC_ELEMENTS] = { };
static THREAD_LOCAL struct msghdr msghdr = {
//.msg_iov = iovec,
.msg_iovlen = NB_MSG_IOVEC_ELEMENTS
};
static int logfdunix = -1; /* syslog to AF_UNIX socket */
static int logfdinet = -1; /* syslog to AF_INET socket */
static char *dataptr = NULL;
static THREAD_LOCAL int logfdunix = -1; /* syslog to AF_UNIX socket */
static THREAD_LOCAL int logfdinet = -1; /* syslog to AF_INET socket */
static THREAD_LOCAL char *dataptr = NULL;
int fac_level;
struct list *logsrvs = NULL;
struct logsrv *tmp = NULL;
@ -1110,9 +1110,11 @@ void __send_log(struct proxy *p, int level, char *message, size_t size, char *sd
size_t hdr_size;
time_t time = date.tv_sec;
struct chunk *tag = &global.log_tag;
static int curr_pid;
static char pidstr[100];
static struct chunk pid;
static THREAD_LOCAL int curr_pid;
static THREAD_LOCAL char pidstr[100];
static THREAD_LOCAL struct chunk pid;
msghdr.msg_iov = iovec;
dataptr = message;
@ -1345,6 +1347,11 @@ void init_log()
/* Initialize log buffers used for syslog messages */
int init_log_buffers()
{
if (global.nbthread > 1 && tid == (unsigned int)(-1)) {
hap_register_per_thread_init(init_log_buffers);
hap_register_per_thread_deinit(deinit_log_buffers);
}
logheader = my_realloc2(logheader, global.max_syslog_len + 1);
logheader_rfc5424 = my_realloc2(logheader_rfc5424, global.max_syslog_len + 1);
logline = my_realloc2(logline, global.max_syslog_len + 1);