mirror of
http://git.haproxy.org/git/haproxy.git/
synced 2024-12-14 15:34:35 +00:00
52c2ec3202
Since commit 3a4bedccc ("MEDIUM: vars: replace the global name index with
a hash") the names of HAProxy variables are no longer saved, ie their
64-bit hashes are saved instead.
This is very convenient for the HAProxy itself, but for the OpenTracing
module it is a problem because the names of the variables are important
when transferring the OpenTracing context. Namely, this context consists
of an unknown amount of data stored in a key-value format. The number
of these data (and the name of the variable used for this purpose) is
determined with the configuration of the OpenTracing filter, as well as
with the tracer used. The two previous sentences seem to be in conflict,
but that is only so at first glance. The function in the OpenTracing
filter used to read the context does not really know this, neither their
number nor its name. The only thing that function actually knows is the
prefix of the variable names used for context transfer, and by that it
could find all the necessary data. Of course, until the application of
the above-mentioned commit.
The problem is solved in a very simple way: in a common variable that
the filter always knows its name, the names of all variables that are the
product of the OpenTracing context are saved. The names of these context
variables can only be added to that common variable. When that variable
is no longer needed (when we no longer need context), it is deleted.
The format for saving data to this common variable is as follows:
+-----+---------------+-- .. --+-----+---------------+
| len | variable name | | len | variable name |
+-----+---------------+-- .. --+-----+---------------+
The amount of memory space used to store the length of the name is 1 byte,
with a sign (the minus sign is provided for inactive records, but this is
not currently used). This means that the maximum length of the variable
name to be saved is 127 characters, which is quite enough for use in the
filter. The buffer size for such data storage is global.tune.bufsize.
This patch must be backported in 2.5.
105 lines
4.7 KiB
C
105 lines
4.7 KiB
C
/***
|
|
* Copyright 2020 HAProxy Technologies
|
|
*
|
|
* This file is part of the HAProxy OpenTracing filter.
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation; either version 2
|
|
* of the License, or (at your option) any later version.
|
|
*
|
|
* This program 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 General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
*/
|
|
#ifndef _OPENTRACING_DEBUG_H_
|
|
#define _OPENTRACING_DEBUG_H_
|
|
|
|
#ifdef DEBUG_FULL
|
|
# define DEBUG_OT
|
|
#endif
|
|
|
|
#ifdef DEBUG_OT
|
|
# ifdef DEBUG_OT_SYSTIME
|
|
# define FLT_OT_DBG_FMT(f) "[% 2d] %ld.%06ld [" FLT_OT_SCOPE "]: " f, tid, now.tv_sec, now.tv_usec
|
|
# else
|
|
# define FLT_OT_DBG_FMT(f) "[% 2d] %11.6f [" FLT_OT_SCOPE "]: " f, tid, FLT_OT_TV_UDIFF(&(flt_ot_debug.start), &now) / 1e6
|
|
# endif
|
|
# define FLT_OT_DBG_INDENT " "
|
|
# define FLT_OT_DBG(l,f, ...) \
|
|
do { \
|
|
if (!(l) || (flt_ot_debug.level & (1 << (l)))) \
|
|
(void)fprintf(stderr, FLT_OT_DBG_FMT("%.*s" f "\n"), \
|
|
dbg_indent_level, FLT_OT_DBG_INDENT, ##__VA_ARGS__); \
|
|
} while (0)
|
|
# define FLT_OT_FUNC(f, ...) do { FLT_OT_DBG(1, "%s(" f ") {", __func__, ##__VA_ARGS__); dbg_indent_level += 3; } while (0)
|
|
# define FLT_OT_RETURN(a) do { dbg_indent_level -= 3; FLT_OT_DBG(1, "}"); return a; } while (0)
|
|
# define FLT_OT_RETURN_EX(a,t,f) do { dbg_indent_level -= 3; { t _r = (a); FLT_OT_DBG(1, "} = " f, _r); return _r; } } while (0)
|
|
# define FLT_OT_RETURN_INT(a) FLT_OT_RETURN_EX((a), int, "%d")
|
|
# define FLT_OT_RETURN_PTR(a) FLT_OT_RETURN_EX((a), void *, "%p")
|
|
# define FLT_OT_DBG_IFDEF(a,b) a
|
|
# define FLT_OT_DBG_ARGS(a, ...) a, ##__VA_ARGS__
|
|
# define FLT_OT_DBG_BUF(a,b) do { FLT_OT_DBG((a), "%p:{ %zu %p %zu %zu }", (b), (b)->size, (b)->area, (b)->data, (b)->head); } while (0)
|
|
|
|
struct flt_ot_debug {
|
|
#ifndef DEBUG_OT_SYSTIME
|
|
struct timeval start;
|
|
#endif
|
|
uint8_t level;
|
|
};
|
|
|
|
|
|
extern THREAD_LOCAL int dbg_indent_level;
|
|
extern struct flt_ot_debug flt_ot_debug;
|
|
|
|
#else
|
|
|
|
# define FLT_OT_DBG(...) while (0)
|
|
# define FLT_OT_FUNC(...) while (0)
|
|
# define FLT_OT_RETURN(a) return a
|
|
# define FLT_OT_RETURN_EX(a,t,f) return a
|
|
# define FLT_OT_RETURN_INT(a) return a
|
|
# define FLT_OT_RETURN_PTR(a) return a
|
|
# define FLT_OT_DBG_IFDEF(a,b) b
|
|
# define FLT_OT_DBG_ARGS(...)
|
|
# define FLT_OT_DBG_BUF(a,b) while (0)
|
|
#endif /* DEBUG_OT */
|
|
|
|
/*
|
|
* ON | NOLOGNORM |
|
|
* -----+-----------+-------------
|
|
* 0 | 0 | no log
|
|
* 0 | 1 | no log
|
|
* 1 | 0 | log all
|
|
* 1 | 1 | log errors
|
|
* -----+-----------+-------------
|
|
*/
|
|
#define FLT_OT_LOG(l,f, ...) \
|
|
do { \
|
|
if (!(conf->tracer->logging & FLT_OT_LOGGING_ON)) \
|
|
FLT_OT_DBG(3, "NOLOG[%d]: [" FLT_OT_SCOPE "]: [%s] " f, (l), conf->id, ##__VA_ARGS__); \
|
|
else if ((conf->tracer->logging & FLT_OT_LOGGING_NOLOGNORM) && ((l) > LOG_ERR)) \
|
|
FLT_OT_DBG(2, "NOLOG[%d]: [" FLT_OT_SCOPE "]: [%s] " f, (l), conf->id, ##__VA_ARGS__); \
|
|
else { \
|
|
send_log(&(conf->tracer->proxy_log), (l), "[" FLT_OT_SCOPE "]: [%s] " f "\n", conf->id, ##__VA_ARGS__); \
|
|
\
|
|
FLT_OT_DBG(1, "LOG[%d]: %s", (l), logline); \
|
|
} \
|
|
} while (0)
|
|
|
|
#endif /* _OPENTRACING_DEBUG_H_ */
|
|
|
|
/*
|
|
* Local variables:
|
|
* c-indent-level: 8
|
|
* c-basic-offset: 8
|
|
* End:
|
|
*
|
|
* vi: noexpandtab shiftwidth=8 tabstop=8
|
|
*/
|