addons/ot/include/util.h

/***
 * 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_UTIL_H_
#define _OPENTRACING_UTIL_H_

#define HTTP_METH_STR_OPTIONS   "OPTIONS"
#define HTTP_METH_STR_GET       "GET"
#define HTTP_METH_STR_HEAD      "HEAD"
#define HTTP_METH_STR_POST      "POST"
#define HTTP_METH_STR_PUT       "PUT"
#define HTTP_METH_STR_DELETE    "DELETE"
#define HTTP_METH_STR_TRACE     "TRACE"
#define HTTP_METH_STR_CONNECT   "CONNECT"

/* Defined in include/haproxy/channel-t.h. */
#define FLT_OT_AN_DEFINES                     \
	FLT_OT_AN_DEF(AN_REQ_INSPECT_FE)      \
	FLT_OT_AN_DEF(AN_REQ_WAIT_HTTP)       \
	FLT_OT_AN_DEF(AN_REQ_HTTP_BODY)       \
	FLT_OT_AN_DEF(AN_REQ_HTTP_PROCESS_FE) \
	FLT_OT_AN_DEF(AN_REQ_SWITCHING_RULES) \
	FLT_OT_AN_DEF(AN_REQ_INSPECT_BE)      \
	FLT_OT_AN_DEF(AN_REQ_HTTP_PROCESS_BE) \
	FLT_OT_AN_DEF(AN_REQ_HTTP_TARPIT)     \
	FLT_OT_AN_DEF(AN_REQ_SRV_RULES)       \
	FLT_OT_AN_DEF(AN_REQ_HTTP_INNER)      \
	FLT_OT_AN_DEF(AN_REQ_PRST_RDP_COOKIE) \
	FLT_OT_AN_DEF(AN_REQ_STICKING_RULES)  \
	FLT_OT_AN_DEF(AN_REQ_HTTP_XFER_BODY)  \
	FLT_OT_AN_DEF(AN_REQ_WAIT_CLI)        \
	FLT_OT_AN_DEF(AN_RES_INSPECT)         \
	FLT_OT_AN_DEF(AN_RES_WAIT_HTTP)       \
	FLT_OT_AN_DEF(AN_RES_STORE_RULES)     \
	FLT_OT_AN_DEF(AN_RES_HTTP_PROCESS_BE) \
	FLT_OT_AN_DEF(AN_RES_HTTP_PROCESS_FE) \
	FLT_OT_AN_DEF(AN_RES_HTTP_XFER_BODY)  \
	FLT_OT_AN_DEF(AN_RES_WAIT_CLI)

#define FLT_OT_PROXIES_LIST_START()                                             \
	do {                                                                    \
		struct flt_conf *fconf;                                         \
		struct proxy    *px;                                            \
                                                                                \
		for (px = proxies_list; px != NULL; px = px->next)              \
			list_for_each_entry(fconf, &(px->filter_configs), list) \
				if (fconf->id == ot_flt_id) {                   \
					struct flt_ot_conf *conf = fconf->conf;
#define FLT_OT_PROXIES_LIST_END() \
				} \
	} while (0)

#ifdef DEBUG_OT
#  define FLT_OT_ARGS_DUMP()   do { if (flt_ot_debug.level & (1 << 2)) flt_ot_args_dump(args); } while (0)
#else
#  define FLT_OT_ARGS_DUMP()   while (0)
#endif


#ifndef DEBUG_OT
#  define flt_ot_filters_dump()   while (0)
#else
void        flt_ot_args_dump(char **args);
void        flt_ot_filters_dump(void);
const char *flt_ot_chn_label(const struct channel *chn);
const char *flt_ot_pr_mode(const struct stream *s);
const char *flt_ot_stream_pos(const struct stream *s);
const char *flt_ot_type(const struct filter *f);
const char *flt_ot_analyzer(uint an_bit);
const char *flt_ot_str_hex(const void *data, size_t size);
const char *flt_ot_str_ctrl(const void *data, size_t size);
const char *flt_ot_list_debug(const struct list *head);
#endif

ssize_t     flt_ot_chunk_add(struct buffer *chk, const void *src, size_t n, char **err);
int         flt_ot_args_count(char **args);
void        flt_ot_args_to_str(char **args, int idx, char **str);
double      flt_ot_strtod(const char *nptr, double limit_min, double limit_max, char **err);
int64_t     flt_ot_strtoll(const char *nptr, int64_t limit_min, int64_t limit_max, char **err);
int         flt_ot_sample_to_str(const struct sample_data *data, char *value, size_t size, char **err);
int         flt_ot_sample_to_value(const char *key, const struct sample_data *data, struct otc_value *value, char **err);
int         flt_ot_sample_add(struct stream *s, uint dir, struct flt_ot_conf_sample *sample, struct flt_ot_scope_data *data, int type, char **err);

#endif /* _OPENTRACING_UTIL_H_ */

/*
 * Local variables:
 *  c-indent-level: 8
 *  c-basic-offset: 8
 * End:
 *
 * vi: noexpandtab shiftwidth=8 tabstop=8
 */