lsquic_logger.c revision b8fa6195
17d09751dSDmitri Tikhonov/* Copyright (c) 2017 - 2020 LiteSpeed Technologies Inc. See LICENSE. */ 250aadb33SDmitri Tikhonov/* 350aadb33SDmitri Tikhonov * LSQUIC Logger implementation. 450aadb33SDmitri Tikhonov */ 550aadb33SDmitri Tikhonov 6560db45bSDmitri Tikhonov#include <assert.h> 750aadb33SDmitri Tikhonov#include <errno.h> 850aadb33SDmitri Tikhonov#include <inttypes.h> 950aadb33SDmitri Tikhonov#include <stdarg.h> 1050aadb33SDmitri Tikhonov#include <stdio.h> 1150aadb33SDmitri Tikhonov#include <stdlib.h> 1250aadb33SDmitri Tikhonov#include <string.h> 13461e84d8SAmol Deshpande#ifndef WIN32 1450aadb33SDmitri Tikhonov#include <sys/time.h> 15461e84d8SAmol Deshpande#endif 1650aadb33SDmitri Tikhonov#include <time.h> 1750aadb33SDmitri Tikhonov 1850aadb33SDmitri Tikhonov#define LSQUIC_LOGGER_MODULE LSQLM_LOGGER /* Quis custodiet ipsos custodes? */ 1950aadb33SDmitri Tikhonov#include "lsquic.h" 205392f7a3SLiteSpeed Tech#include "lsquic_logger.h" 2150aadb33SDmitri Tikhonov 225392f7a3SLiteSpeed Tech#define MAX_LINE_LEN 8192 2355f8042dSDmitri Tikhonov/* Expanded TRUNC_FMT should not exceed TRUNC_SZ bytes. At the same time, 2455f8042dSDmitri Tikhonov * TRUNC_SZ should be significantly smaller than MAX_LINE_LEN. 2555f8042dSDmitri Tikhonov */ 2655f8042dSDmitri Tikhonov#define TRUNC_FMT "<truncated, need %d bytes>" 2755f8042dSDmitri Tikhonov#define TRUNC_SZ 40 2855f8042dSDmitri Tikhonov#define FORMAT_PROBLEM(lb, len, max) ((lb < 0) || (lb + len >= max)) 295392f7a3SLiteSpeed Tech 305392f7a3SLiteSpeed Tech/* TODO: display GQUIC CIDs in Chrome-compatible format */ 313229dd11SDmitri Tikhonov 3250aadb33SDmitri Tikhonovstatic enum lsquic_logger_timestamp_style g_llts = LLTS_NONE; 3350aadb33SDmitri Tikhonov 3450aadb33SDmitri Tikhonovstatic int 355392f7a3SLiteSpeed Technull_log_buf (void *ctx, const char *buf, size_t len) 3650aadb33SDmitri Tikhonov{ 3750aadb33SDmitri Tikhonov return 0; 3850aadb33SDmitri Tikhonov} 3950aadb33SDmitri Tikhonov 4050aadb33SDmitri Tikhonovstatic int 415392f7a3SLiteSpeed Techfile_log_buf (void *ctx, const char *buf, size_t len) 4250aadb33SDmitri Tikhonov{ 435392f7a3SLiteSpeed Tech return (int)fwrite(buf, sizeof(char), len, (FILE *) ctx); 4450aadb33SDmitri Tikhonov} 4550aadb33SDmitri Tikhonov 4650aadb33SDmitri Tikhonovstatic const struct lsquic_logger_if file_logger_if = { 475392f7a3SLiteSpeed Tech .log_buf = file_log_buf, 4850aadb33SDmitri Tikhonov}; 4950aadb33SDmitri Tikhonov 5050aadb33SDmitri Tikhonovstatic const struct lsquic_logger_if null_logger_if = { 515392f7a3SLiteSpeed Tech .log_buf = null_log_buf, 5250aadb33SDmitri Tikhonov}; 5350aadb33SDmitri Tikhonov 5450aadb33SDmitri Tikhonovstatic void *logger_ctx = NULL; 5550aadb33SDmitri Tikhonovstatic const struct lsquic_logger_if *logger_if = &null_logger_if; 5650aadb33SDmitri Tikhonov 5750aadb33SDmitri Tikhonovenum lsq_log_level lsq_log_levels[N_LSQUIC_LOGGER_MODULES] = { 5850aadb33SDmitri Tikhonov [LSQLM_NOMODULE] = LSQ_LOG_WARN, 5950aadb33SDmitri Tikhonov [LSQLM_LOGGER] = LSQ_LOG_WARN, 6050aadb33SDmitri Tikhonov [LSQLM_EVENT] = LSQ_LOG_WARN, 6150aadb33SDmitri Tikhonov [LSQLM_ENGINE] = LSQ_LOG_WARN, 6250aadb33SDmitri Tikhonov [LSQLM_CONN] = LSQ_LOG_WARN, 6350aadb33SDmitri Tikhonov [LSQLM_RECHIST] = LSQ_LOG_WARN, 6450aadb33SDmitri Tikhonov [LSQLM_STREAM] = LSQ_LOG_WARN, 6550aadb33SDmitri Tikhonov [LSQLM_PARSE] = LSQ_LOG_WARN, 6650aadb33SDmitri Tikhonov [LSQLM_CFCW] = LSQ_LOG_WARN, 6750aadb33SDmitri Tikhonov [LSQLM_SFCW] = LSQ_LOG_WARN, 6850aadb33SDmitri Tikhonov [LSQLM_SENDCTL] = LSQ_LOG_WARN, 6950aadb33SDmitri Tikhonov [LSQLM_ALARMSET] = LSQ_LOG_WARN, 7050aadb33SDmitri Tikhonov [LSQLM_CRYPTO] = LSQ_LOG_WARN, 7150aadb33SDmitri Tikhonov [LSQLM_HANDSHAKE] = LSQ_LOG_WARN, 7250aadb33SDmitri Tikhonov [LSQLM_HSK_ADAPTER] = LSQ_LOG_WARN, 735392f7a3SLiteSpeed Tech [LSQLM_BBR] = LSQ_LOG_WARN, 7450aadb33SDmitri Tikhonov [LSQLM_CUBIC] = LSQ_LOG_WARN, 7550aadb33SDmitri Tikhonov [LSQLM_HEADERS] = LSQ_LOG_WARN, 7650aadb33SDmitri Tikhonov [LSQLM_FRAME_READER]= LSQ_LOG_WARN, 7750aadb33SDmitri Tikhonov [LSQLM_FRAME_WRITER]= LSQ_LOG_WARN, 785392f7a3SLiteSpeed Tech [LSQLM_MINI_CONN] = LSQ_LOG_WARN, 795392f7a3SLiteSpeed Tech [LSQLM_TOKGEN] = LSQ_LOG_WARN, 8050aadb33SDmitri Tikhonov [LSQLM_ENG_HIST] = LSQ_LOG_WARN, 8150aadb33SDmitri Tikhonov [LSQLM_SPI] = LSQ_LOG_WARN, 8250aadb33SDmitri Tikhonov [LSQLM_DI] = LSQ_LOG_WARN, 835392f7a3SLiteSpeed Tech [LSQLM_PRQ] = LSQ_LOG_WARN, 8450aadb33SDmitri Tikhonov [LSQLM_PACER] = LSQ_LOG_WARN, 853b55e6aeSDmitri Tikhonov [LSQLM_HTTP1X] = LSQ_LOG_WARN, 8655cd0b38SDmitri Tikhonov [LSQLM_QLOG] = LSQ_LOG_WARN, 875392f7a3SLiteSpeed Tech [LSQLM_TRAPA] = LSQ_LOG_WARN, 885392f7a3SLiteSpeed Tech [LSQLM_PURGA] = LSQ_LOG_WARN, 895392f7a3SLiteSpeed Tech [LSQLM_HCSI_READER] = LSQ_LOG_WARN, 905392f7a3SLiteSpeed Tech [LSQLM_HCSO_WRITER] = LSQ_LOG_WARN, 915392f7a3SLiteSpeed Tech [LSQLM_QENC_HDL] = LSQ_LOG_WARN, 925392f7a3SLiteSpeed Tech [LSQLM_QDEC_HDL] = LSQ_LOG_WARN, 935392f7a3SLiteSpeed Tech [LSQLM_QPACK_ENC] = LSQ_LOG_WARN, 945392f7a3SLiteSpeed Tech [LSQLM_QPACK_DEC] = LSQ_LOG_WARN, 955392f7a3SLiteSpeed Tech [LSQLM_PRIO] = LSQ_LOG_WARN, 965392f7a3SLiteSpeed Tech [LSQLM_BW_SAMPLER] = LSQ_LOG_WARN, 97b8fa6195SDmitri Tikhonov [LSQLM_PACKET_RESIZE] = LSQ_LOG_WARN, 9850aadb33SDmitri Tikhonov}; 9950aadb33SDmitri Tikhonov 10050aadb33SDmitri Tikhonovconst char *const lsqlm_to_str[N_LSQUIC_LOGGER_MODULES] = { 10150aadb33SDmitri Tikhonov [LSQLM_NOMODULE] = "", 10250aadb33SDmitri Tikhonov [LSQLM_LOGGER] = "logger", 10350aadb33SDmitri Tikhonov [LSQLM_EVENT] = "event", 10450aadb33SDmitri Tikhonov [LSQLM_ENGINE] = "engine", 10550aadb33SDmitri Tikhonov [LSQLM_CONN] = "conn", 10650aadb33SDmitri Tikhonov [LSQLM_RECHIST] = "rechist", 10750aadb33SDmitri Tikhonov [LSQLM_STREAM] = "stream", 10850aadb33SDmitri Tikhonov [LSQLM_PARSE] = "parse", 10950aadb33SDmitri Tikhonov [LSQLM_CFCW] = "cfcw", 11050aadb33SDmitri Tikhonov [LSQLM_SFCW] = "sfcw", 11150aadb33SDmitri Tikhonov [LSQLM_SENDCTL] = "sendctl", 11250aadb33SDmitri Tikhonov [LSQLM_ALARMSET] = "alarmset", 11350aadb33SDmitri Tikhonov [LSQLM_CRYPTO] = "crypto", 11450aadb33SDmitri Tikhonov [LSQLM_HANDSHAKE] = "handshake", 11550aadb33SDmitri Tikhonov [LSQLM_HSK_ADAPTER] = "hsk-adapter", 1165392f7a3SLiteSpeed Tech [LSQLM_BBR] = "bbr", 11750aadb33SDmitri Tikhonov [LSQLM_CUBIC] = "cubic", 11850aadb33SDmitri Tikhonov [LSQLM_HEADERS] = "headers", 11950aadb33SDmitri Tikhonov [LSQLM_FRAME_READER]= "frame-reader", 12050aadb33SDmitri Tikhonov [LSQLM_FRAME_WRITER]= "frame-writer", 1215392f7a3SLiteSpeed Tech [LSQLM_MINI_CONN] = "mini-conn", 1225392f7a3SLiteSpeed Tech [LSQLM_TOKGEN] = "tokgen", 12350aadb33SDmitri Tikhonov [LSQLM_ENG_HIST] = "eng-hist", 12450aadb33SDmitri Tikhonov [LSQLM_SPI] = "spi", 12550aadb33SDmitri Tikhonov [LSQLM_DI] = "di", 1265392f7a3SLiteSpeed Tech [LSQLM_PRQ] = "prq", 12750aadb33SDmitri Tikhonov [LSQLM_PACER] = "pacer", 1283b55e6aeSDmitri Tikhonov [LSQLM_HTTP1X] = "http1x", 12955cd0b38SDmitri Tikhonov [LSQLM_QLOG] = "qlog", 1305392f7a3SLiteSpeed Tech [LSQLM_TRAPA] = "trapa", 1315392f7a3SLiteSpeed Tech [LSQLM_PURGA] = "purga", 1325392f7a3SLiteSpeed Tech [LSQLM_HCSI_READER] = "hcsi-reader", 1335392f7a3SLiteSpeed Tech [LSQLM_HCSO_WRITER] = "hcso-writer", 1345392f7a3SLiteSpeed Tech [LSQLM_QENC_HDL] = "qenc-hdl", 1355392f7a3SLiteSpeed Tech [LSQLM_QDEC_HDL] = "qdec-hdl", 1365392f7a3SLiteSpeed Tech [LSQLM_QPACK_ENC] = "qpack-enc", 1375392f7a3SLiteSpeed Tech [LSQLM_QPACK_DEC] = "qpack-dec", 1385392f7a3SLiteSpeed Tech [LSQLM_PRIO] = "prio", 1395392f7a3SLiteSpeed Tech [LSQLM_BW_SAMPLER] = "bw-sampler", 140b8fa6195SDmitri Tikhonov [LSQLM_PACKET_RESIZE] = "packet-resize", 14150aadb33SDmitri Tikhonov}; 14250aadb33SDmitri Tikhonov 14350aadb33SDmitri Tikhonovconst char *const lsq_loglevel2str[N_LSQUIC_LOG_LEVELS] = { 14450aadb33SDmitri Tikhonov [LSQ_LOG_ALERT] = "ALERT", 14550aadb33SDmitri Tikhonov [LSQ_LOG_CRIT] = "CRIT", 14650aadb33SDmitri Tikhonov [LSQ_LOG_DEBUG] = "DEBUG", 14750aadb33SDmitri Tikhonov [LSQ_LOG_EMERG] = "EMERG", 14850aadb33SDmitri Tikhonov [LSQ_LOG_ERROR] = "ERROR", 14950aadb33SDmitri Tikhonov [LSQ_LOG_INFO] = "INFO", 15050aadb33SDmitri Tikhonov [LSQ_LOG_NOTICE] = "NOTICE", 15150aadb33SDmitri Tikhonov [LSQ_LOG_WARN] = "WARN", 15250aadb33SDmitri Tikhonov}; 15350aadb33SDmitri Tikhonov 15450aadb33SDmitri Tikhonov 155b93f59beSBob Perper#ifdef WIN32 156560db45bSDmitri Tikhonov#define DELTA_EPOCH_IN_TICKS 116444736000000000Ui64 157b93f59beSBob Perperstruct timezone 158b93f59beSBob Perper{ 159ab5c8df2SBob Perper time_t tz_minuteswest; /* minutes W of Greenwich */ 160ab5c8df2SBob Perper time_t tz_dsttime; /* type of dst correction */ 161b93f59beSBob Perper}; 162b93f59beSBob Perper 163b93f59beSBob Perperstatic int 164b93f59beSBob Perpergettimeofday (struct timeval *tv, struct timezone *tz) 165b93f59beSBob Perper{ 166b93f59beSBob Perper FILETIME ft; 167560db45bSDmitri Tikhonov uint64_t tmpres; 168b93f59beSBob Perper static int tzflag; 169b93f59beSBob Perper 170b93f59beSBob Perper if (NULL != tv) 171b93f59beSBob Perper { 172b93f59beSBob Perper GetSystemTimeAsFileTime(&ft); 173b93f59beSBob Perper 174560db45bSDmitri Tikhonov tmpres = ((uint64_t) ft.dwHighDateTime << 32) 175560db45bSDmitri Tikhonov | (ft.dwLowDateTime); 176b93f59beSBob Perper 177560db45bSDmitri Tikhonov tmpres -= DELTA_EPOCH_IN_TICKS; 178560db45bSDmitri Tikhonov tv->tv_sec = tmpres / 10000000; 179560db45bSDmitri Tikhonov tv->tv_usec = tmpres % 1000000; 180b93f59beSBob Perper } 181b93f59beSBob Perper 182b93f59beSBob Perper if (NULL != tz) 183b93f59beSBob Perper { 184b93f59beSBob Perper if (!tzflag) 185b93f59beSBob Perper { 186b93f59beSBob Perper _tzset(); 187b93f59beSBob Perper tzflag++; 188b93f59beSBob Perper } 189b93f59beSBob Perper tz->tz_minuteswest = _timezone / 60; 190b93f59beSBob Perper tz->tz_dsttime = _daylight; 191b93f59beSBob Perper } 192b93f59beSBob Perper 193b93f59beSBob Perper return 0; 194b93f59beSBob Perper} 195b93f59beSBob Perper#endif 196b93f59beSBob Perper 197b93f59beSBob Perper 1985392f7a3SLiteSpeed Techstatic size_t 1995392f7a3SLiteSpeed Techprint_timestamp (char *buf, size_t max) 20050aadb33SDmitri Tikhonov{ 20150aadb33SDmitri Tikhonov struct tm tm; 20250aadb33SDmitri Tikhonov struct timeval tv; 2035392f7a3SLiteSpeed Tech size_t len = 0; 2045392f7a3SLiteSpeed Tech 20550aadb33SDmitri Tikhonov gettimeofday(&tv, NULL); 206ab5c8df2SBob Perper#ifdef WIN32 207ab5c8df2SBob Perper { 2087b1586ddSDmitri Tikhonov time_t t = tv.tv_sec; 209560db45bSDmitri Tikhonov#ifndef NDEBUG 2107b1586ddSDmitri Tikhonov errno_t e = 211560db45bSDmitri Tikhonov#endif 2127b1586ddSDmitri Tikhonov localtime_s(&tm, &t); 213560db45bSDmitri Tikhonov assert(!e); 214ab5c8df2SBob Perper } 215ab5c8df2SBob Perper#else 21650aadb33SDmitri Tikhonov localtime_r(&tv.tv_sec, &tm); 217ab5c8df2SBob Perper#endif 218bfc7bfd8SDmitri Tikhonov if (g_llts == LLTS_YYYYMMDD_HHMMSSUS) 2195392f7a3SLiteSpeed Tech len = snprintf(buf, max, "%04d-%02d-%02d %02d:%02d:%02d.%06d ", 220bfc7bfd8SDmitri Tikhonov tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, 221bfc7bfd8SDmitri Tikhonov tm.tm_hour, tm.tm_min, tm.tm_sec, (int) (tv.tv_usec)); 222bfc7bfd8SDmitri Tikhonov else if (g_llts == LLTS_YYYYMMDD_HHMMSSMS) 2235392f7a3SLiteSpeed Tech len = snprintf(buf, max, "%04d-%02d-%02d %02d:%02d:%02d.%03d ", 22450aadb33SDmitri Tikhonov tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, 22550aadb33SDmitri Tikhonov tm.tm_hour, tm.tm_min, tm.tm_sec, (int) (tv.tv_usec / 1000)); 22650aadb33SDmitri Tikhonov else if (g_llts == LLTS_HHMMSSMS) 2275392f7a3SLiteSpeed Tech len = snprintf(buf, max, "%02d:%02d:%02d.%03d ", 2285392f7a3SLiteSpeed Tech tm.tm_hour, tm.tm_min, tm.tm_sec, (int) (tv.tv_usec / 1000)); 22950aadb33SDmitri Tikhonov else if (g_llts == LLTS_HHMMSSUS) 2305392f7a3SLiteSpeed Tech len = snprintf(buf, max, "%02d:%02d:%02d.%06d ", 2315392f7a3SLiteSpeed Tech tm.tm_hour, tm.tm_min, tm.tm_sec, (int) tv.tv_usec); 23250aadb33SDmitri Tikhonov else if (g_llts == LLTS_CHROMELIKE) 2335392f7a3SLiteSpeed Tech len = snprintf(buf, max, "%02d%02d/%02d%02d%02d.%06d ", 2345392f7a3SLiteSpeed Tech tm.tm_mon + 1, tm.tm_mday,tm.tm_hour, tm.tm_min, 2355392f7a3SLiteSpeed Tech tm.tm_sec, (int) tv.tv_usec); 2365392f7a3SLiteSpeed Tech return len; 23750aadb33SDmitri Tikhonov} 23850aadb33SDmitri Tikhonov 23950aadb33SDmitri Tikhonov 24050aadb33SDmitri Tikhonovvoid 24150aadb33SDmitri Tikhonovlsquic_logger_log3 (enum lsq_log_level log_level, 24250aadb33SDmitri Tikhonov enum lsquic_logger_module module, 2435392f7a3SLiteSpeed Tech const lsquic_cid_t *conn_id, lsquic_stream_id_t stream_id, 2445392f7a3SLiteSpeed Tech const char *fmt, ...) 24550aadb33SDmitri Tikhonov{ 24650aadb33SDmitri Tikhonov const int saved_errno = errno; 2475392f7a3SLiteSpeed Tech char cidbuf_[MAX_CID_LEN * 2 + 1]; 2485392f7a3SLiteSpeed Tech size_t len = 0; 24955f8042dSDmitri Tikhonov int lb; 2505392f7a3SLiteSpeed Tech size_t max = MAX_LINE_LEN; 2515392f7a3SLiteSpeed Tech char buf[MAX_LINE_LEN]; 25250aadb33SDmitri Tikhonov 25350aadb33SDmitri Tikhonov if (g_llts != LLTS_NONE) 2545392f7a3SLiteSpeed Tech { 2555392f7a3SLiteSpeed Tech lb = print_timestamp(buf, max); 2565392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 2575392f7a3SLiteSpeed Tech goto end; 2585392f7a3SLiteSpeed Tech len += lb; 2595392f7a3SLiteSpeed Tech } 2605392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "[%s] [QUIC:%"CID_FMT"-%"PRIu64"] %s: ", 2615392f7a3SLiteSpeed Tech lsq_loglevel2str[log_level], CID_BITS(conn_id), 2625392f7a3SLiteSpeed Tech stream_id, lsqlm_to_str[module]); 2635392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 2645392f7a3SLiteSpeed Tech goto end; 2655392f7a3SLiteSpeed Tech len += lb; 26650aadb33SDmitri Tikhonov va_list ap; 26750aadb33SDmitri Tikhonov va_start(ap, fmt); 2685392f7a3SLiteSpeed Tech lb = vsnprintf(buf + len, max - len, fmt, ap); 269a0e1aeeeSDmitri Tikhonov va_end(ap); 27055f8042dSDmitri Tikhonov if (lb > 0 && (size_t) lb >= max - len && max - len >= TRUNC_SZ) 27155f8042dSDmitri Tikhonov { 27255f8042dSDmitri Tikhonov len = max - TRUNC_SZ; 27355f8042dSDmitri Tikhonov lb = snprintf(buf + max - TRUNC_SZ, TRUNC_SZ, TRUNC_FMT, lb); 27455f8042dSDmitri Tikhonov } 2755392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 2765392f7a3SLiteSpeed Tech goto end; 2775392f7a3SLiteSpeed Tech len += lb; 2785392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "\n"); 2795392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 2805392f7a3SLiteSpeed Tech goto end; 2815392f7a3SLiteSpeed Tech len += lb; 2825392f7a3SLiteSpeed Tech logger_if->log_buf(logger_ctx, buf, len); 2835392f7a3SLiteSpeed Techend: 28450aadb33SDmitri Tikhonov errno = saved_errno; 28550aadb33SDmitri Tikhonov} 28650aadb33SDmitri Tikhonov 28750aadb33SDmitri Tikhonov 28850aadb33SDmitri Tikhonovvoid 28950aadb33SDmitri Tikhonovlsquic_logger_log2 (enum lsq_log_level log_level, 29050aadb33SDmitri Tikhonov enum lsquic_logger_module module, 2915392f7a3SLiteSpeed Tech const struct lsquic_cid *conn_id, const char *fmt, ...) 29250aadb33SDmitri Tikhonov{ 29350aadb33SDmitri Tikhonov const int saved_errno = errno; 2945392f7a3SLiteSpeed Tech char cidbuf_[MAX_CID_LEN * 2 + 1]; 2955392f7a3SLiteSpeed Tech size_t len = 0; 29655f8042dSDmitri Tikhonov int lb; 2975392f7a3SLiteSpeed Tech size_t max = MAX_LINE_LEN; 2985392f7a3SLiteSpeed Tech char buf[MAX_LINE_LEN]; 29950aadb33SDmitri Tikhonov 30050aadb33SDmitri Tikhonov if (g_llts != LLTS_NONE) 3015392f7a3SLiteSpeed Tech { 3025392f7a3SLiteSpeed Tech lb = print_timestamp(buf, max); 3035392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3045392f7a3SLiteSpeed Tech goto end; 3055392f7a3SLiteSpeed Tech len += lb; 3065392f7a3SLiteSpeed Tech } 30750aadb33SDmitri Tikhonov 3085392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "[%s] [QUIC:%"CID_FMT"] %s: ", 3095392f7a3SLiteSpeed Tech lsq_loglevel2str[log_level], CID_BITS(conn_id), lsqlm_to_str[module]); 3105392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3115392f7a3SLiteSpeed Tech goto end; 3125392f7a3SLiteSpeed Tech len += lb; 31350aadb33SDmitri Tikhonov va_list ap; 31450aadb33SDmitri Tikhonov va_start(ap, fmt); 3155392f7a3SLiteSpeed Tech lb = vsnprintf(buf + len, max - len, fmt, ap); 316a0e1aeeeSDmitri Tikhonov va_end(ap); 31755f8042dSDmitri Tikhonov if (lb > 0 && (size_t) lb >= max - len && max - len >= TRUNC_SZ) 31855f8042dSDmitri Tikhonov { 31955f8042dSDmitri Tikhonov len = max - TRUNC_SZ; 32055f8042dSDmitri Tikhonov lb = snprintf(buf + max - TRUNC_SZ, TRUNC_SZ, TRUNC_FMT, lb); 32155f8042dSDmitri Tikhonov } 3225392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3235392f7a3SLiteSpeed Tech goto end; 3245392f7a3SLiteSpeed Tech len += lb; 3255392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "\n"); 3265392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3275392f7a3SLiteSpeed Tech goto end; 3285392f7a3SLiteSpeed Tech len += lb; 3295392f7a3SLiteSpeed Tech logger_if->log_buf(logger_ctx, buf, len); 3305392f7a3SLiteSpeed Techend: 33150aadb33SDmitri Tikhonov errno = saved_errno; 33250aadb33SDmitri Tikhonov} 33350aadb33SDmitri Tikhonov 33450aadb33SDmitri Tikhonov 33550aadb33SDmitri Tikhonovvoid 33650aadb33SDmitri Tikhonovlsquic_logger_log1 (enum lsq_log_level log_level, 33750aadb33SDmitri Tikhonov enum lsquic_logger_module module, 33850aadb33SDmitri Tikhonov const char *fmt, ...) 33950aadb33SDmitri Tikhonov{ 34050aadb33SDmitri Tikhonov const int saved_errno = errno; 3415392f7a3SLiteSpeed Tech size_t len = 0; 34255f8042dSDmitri Tikhonov int lb; 3435392f7a3SLiteSpeed Tech size_t max = MAX_LINE_LEN; 3445392f7a3SLiteSpeed Tech char buf[MAX_LINE_LEN]; 34550aadb33SDmitri Tikhonov 34650aadb33SDmitri Tikhonov if (g_llts != LLTS_NONE) 3475392f7a3SLiteSpeed Tech { 3485392f7a3SLiteSpeed Tech lb = print_timestamp(buf, max); 3495392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3505392f7a3SLiteSpeed Tech goto end; 3515392f7a3SLiteSpeed Tech len += lb; 3525392f7a3SLiteSpeed Tech } 3535392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "[%s] %s: ", lsq_loglevel2str[log_level], 35450aadb33SDmitri Tikhonov lsqlm_to_str[module]); 3555392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3565392f7a3SLiteSpeed Tech goto end; 3575392f7a3SLiteSpeed Tech len += lb; 35850aadb33SDmitri Tikhonov va_list ap; 35950aadb33SDmitri Tikhonov va_start(ap, fmt); 3605392f7a3SLiteSpeed Tech lb = vsnprintf(buf + len, max - len, fmt, ap); 361a0e1aeeeSDmitri Tikhonov va_end(ap); 36255f8042dSDmitri Tikhonov if (lb > 0 && (size_t) lb >= max - len && max - len >= TRUNC_SZ) 36355f8042dSDmitri Tikhonov { 36455f8042dSDmitri Tikhonov len = max - TRUNC_SZ; 36555f8042dSDmitri Tikhonov lb = snprintf(buf + max - TRUNC_SZ, TRUNC_SZ, TRUNC_FMT, lb); 36655f8042dSDmitri Tikhonov } 3675392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3685392f7a3SLiteSpeed Tech goto end; 3695392f7a3SLiteSpeed Tech len += lb; 3705392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "\n"); 3715392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3725392f7a3SLiteSpeed Tech goto end; 3735392f7a3SLiteSpeed Tech len += lb; 3745392f7a3SLiteSpeed Tech logger_if->log_buf(logger_ctx, buf, len); 3755392f7a3SLiteSpeed Techend: 37650aadb33SDmitri Tikhonov errno = saved_errno; 37750aadb33SDmitri Tikhonov} 37850aadb33SDmitri Tikhonov 37950aadb33SDmitri Tikhonov 38050aadb33SDmitri Tikhonovvoid 38150aadb33SDmitri Tikhonovlsquic_logger_log0 (enum lsq_log_level log_level, const char *fmt, ...) 38250aadb33SDmitri Tikhonov{ 38350aadb33SDmitri Tikhonov const int saved_errno = errno; 3845392f7a3SLiteSpeed Tech size_t len = 0; 38555f8042dSDmitri Tikhonov int lb; 3865392f7a3SLiteSpeed Tech size_t max = MAX_LINE_LEN; 3875392f7a3SLiteSpeed Tech char buf[MAX_LINE_LEN]; 38850aadb33SDmitri Tikhonov 38950aadb33SDmitri Tikhonov if (g_llts != LLTS_NONE) 3905392f7a3SLiteSpeed Tech { 3915392f7a3SLiteSpeed Tech lb = print_timestamp(buf, max); 3925392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3935392f7a3SLiteSpeed Tech goto end; 3945392f7a3SLiteSpeed Tech len += lb; 3955392f7a3SLiteSpeed Tech } 39650aadb33SDmitri Tikhonov 3975392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "[%s] ", lsq_loglevel2str[log_level]); 3985392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 3995392f7a3SLiteSpeed Tech goto end; 4005392f7a3SLiteSpeed Tech len += lb; 40150aadb33SDmitri Tikhonov va_list ap; 40250aadb33SDmitri Tikhonov va_start(ap, fmt); 4035392f7a3SLiteSpeed Tech lb = vsnprintf(buf + len, max - len, fmt, ap); 40450aadb33SDmitri Tikhonov va_end(ap); 40555f8042dSDmitri Tikhonov if (lb > 0 && (size_t) lb >= max - len && max - len >= TRUNC_SZ) 40655f8042dSDmitri Tikhonov { 40755f8042dSDmitri Tikhonov len = max - TRUNC_SZ; 40855f8042dSDmitri Tikhonov lb = snprintf(buf + max - TRUNC_SZ, TRUNC_SZ, TRUNC_FMT, lb); 40955f8042dSDmitri Tikhonov } 4105392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 4115392f7a3SLiteSpeed Tech goto end; 4125392f7a3SLiteSpeed Tech len += lb; 4135392f7a3SLiteSpeed Tech lb = snprintf(buf + len, max - len, "\n"); 4145392f7a3SLiteSpeed Tech if (FORMAT_PROBLEM(lb, len, max)) 4155392f7a3SLiteSpeed Tech goto end; 4165392f7a3SLiteSpeed Tech len += lb; 4175392f7a3SLiteSpeed Tech logger_if->log_buf(logger_ctx, buf, len); 4185392f7a3SLiteSpeed Techend: 41950aadb33SDmitri Tikhonov errno = saved_errno; 42050aadb33SDmitri Tikhonov} 42150aadb33SDmitri Tikhonov 42250aadb33SDmitri Tikhonov 42350aadb33SDmitri Tikhonovvoid 42450aadb33SDmitri Tikhonovlsquic_logger_init (const struct lsquic_logger_if *lif, void *lctx, 42550aadb33SDmitri Tikhonov unsigned llts) 42650aadb33SDmitri Tikhonov{ 42750aadb33SDmitri Tikhonov logger_if = lif; 42850aadb33SDmitri Tikhonov logger_ctx = lctx; 42950aadb33SDmitri Tikhonov if (llts < N_LLTS) 43050aadb33SDmitri Tikhonov g_llts = llts; 43150aadb33SDmitri Tikhonov LSQ_DEBUG("%s called", __func__); 43250aadb33SDmitri Tikhonov} 43350aadb33SDmitri Tikhonov 43450aadb33SDmitri Tikhonov 43550aadb33SDmitri Tikhonovenum lsquic_logger_module 43650aadb33SDmitri Tikhonovlsquic_str_to_logger_module (const char *str) 43750aadb33SDmitri Tikhonov{ 43850aadb33SDmitri Tikhonov enum lsquic_logger_module i; 43950aadb33SDmitri Tikhonov for (i = 0; i < sizeof(lsqlm_to_str) / sizeof(lsqlm_to_str[0]); ++i) 44050aadb33SDmitri Tikhonov if (0 == strcasecmp(lsqlm_to_str[i], str)) 44150aadb33SDmitri Tikhonov return i; 44250aadb33SDmitri Tikhonov return -1; 44350aadb33SDmitri Tikhonov} 44450aadb33SDmitri Tikhonov 44550aadb33SDmitri Tikhonov 44650aadb33SDmitri Tikhonovenum lsq_log_level 44750aadb33SDmitri Tikhonovlsquic_str_to_log_level (const char *str) 44850aadb33SDmitri Tikhonov{ 44950aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "emerg")) 45050aadb33SDmitri Tikhonov return LSQ_LOG_EMERG; 45150aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "alert")) 45250aadb33SDmitri Tikhonov return LSQ_LOG_ALERT; 45350aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "crit")) 45450aadb33SDmitri Tikhonov return LSQ_LOG_CRIT; 45550aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "error")) 45650aadb33SDmitri Tikhonov return LSQ_LOG_ERROR; 45750aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "warn")) 45850aadb33SDmitri Tikhonov return LSQ_LOG_WARN; 45950aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "notice")) 46050aadb33SDmitri Tikhonov return LSQ_LOG_NOTICE; 46150aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "info")) 46250aadb33SDmitri Tikhonov return LSQ_LOG_INFO; 46350aadb33SDmitri Tikhonov if (0 == strcasecmp(str, "debug")) 46450aadb33SDmitri Tikhonov return LSQ_LOG_DEBUG; 46550aadb33SDmitri Tikhonov return -1; 46650aadb33SDmitri Tikhonov} 46750aadb33SDmitri Tikhonov 46850aadb33SDmitri Tikhonov 46950aadb33SDmitri Tikhonovvoid 47050aadb33SDmitri Tikhonovlsquic_log_to_fstream (FILE *file, unsigned llts) 47150aadb33SDmitri Tikhonov{ 47250aadb33SDmitri Tikhonov lsquic_logger_init(&file_logger_if, file, llts); 47350aadb33SDmitri Tikhonov} 47450aadb33SDmitri Tikhonov 47550aadb33SDmitri Tikhonov 47650aadb33SDmitri Tikhonovint 47750aadb33SDmitri Tikhonovlsquic_logger_lopt (const char *optarg_orig) 47850aadb33SDmitri Tikhonov{ 47950aadb33SDmitri Tikhonov char *const optarg = strdup(optarg_orig); 48050aadb33SDmitri Tikhonov char *mod_str; 48150aadb33SDmitri Tikhonov int i; 48250aadb33SDmitri Tikhonov for (i = 0; (mod_str = strtok(i ? NULL : optarg, ",")); ++i) { 48350aadb33SDmitri Tikhonov char *level_str = strchr(mod_str, '='); 48450aadb33SDmitri Tikhonov if (!level_str) { 48550aadb33SDmitri Tikhonov fprintf(stderr, "Invalid module specification `%s'\n", mod_str); 48650aadb33SDmitri Tikhonov break; 48750aadb33SDmitri Tikhonov } 48850aadb33SDmitri Tikhonov *level_str = '\0'; 48950aadb33SDmitri Tikhonov ++level_str; 49050aadb33SDmitri Tikhonov enum lsquic_logger_module mod = lsquic_str_to_logger_module(mod_str); 49150aadb33SDmitri Tikhonov if (-1 == (int) mod) { 49250aadb33SDmitri Tikhonov fprintf(stderr, "`%s' is not a valid module name\n", mod_str); 49350aadb33SDmitri Tikhonov break; 49450aadb33SDmitri Tikhonov } 49550aadb33SDmitri Tikhonov enum lsq_log_level level = lsquic_str_to_log_level(level_str); 49650aadb33SDmitri Tikhonov if (-1 == (int) level) { 49750aadb33SDmitri Tikhonov fprintf(stderr, "`%s' is not a valid level\n", level_str); 49850aadb33SDmitri Tikhonov break; 49950aadb33SDmitri Tikhonov } 50050aadb33SDmitri Tikhonov lsq_log_levels[mod] = level; 50150aadb33SDmitri Tikhonov LSQ_INFO("set %s to %s", mod_str, level_str); 50250aadb33SDmitri Tikhonov } 50350aadb33SDmitri Tikhonov free(optarg); 50450aadb33SDmitri Tikhonov return mod_str == NULL ? 0 : -1; 50550aadb33SDmitri Tikhonov} 50650aadb33SDmitri Tikhonov 50750aadb33SDmitri Tikhonov 50850aadb33SDmitri Tikhonovint 50950aadb33SDmitri Tikhonovlsquic_set_log_level (const char *level_str) 51050aadb33SDmitri Tikhonov{ 51150aadb33SDmitri Tikhonov enum lsq_log_level level; 51250aadb33SDmitri Tikhonov unsigned i; 51350aadb33SDmitri Tikhonov 51450aadb33SDmitri Tikhonov level = lsquic_str_to_log_level(level_str); 51550aadb33SDmitri Tikhonov if ((int) level >= 0) 51650aadb33SDmitri Tikhonov { 51750aadb33SDmitri Tikhonov for (i = 0; i < sizeof(lsq_log_levels) / sizeof(lsq_log_levels[0]); ++i) 51850aadb33SDmitri Tikhonov lsq_log_levels[i] = level; 51950aadb33SDmitri Tikhonov return 0; 52050aadb33SDmitri Tikhonov } 52150aadb33SDmitri Tikhonov else 52250aadb33SDmitri Tikhonov return -1; 52350aadb33SDmitri Tikhonov} 5245392f7a3SLiteSpeed Tech 5255392f7a3SLiteSpeed Tech 5265392f7a3SLiteSpeed Tech/* `out' must be at least MAX_CID_LEN * 2 + 1 characters long */ 5275392f7a3SLiteSpeed Techvoid 5285392f7a3SLiteSpeed Techlsquic_cid2str (const lsquic_cid_t *cid, char *out) 5295392f7a3SLiteSpeed Tech{ 5305392f7a3SLiteSpeed Tech static const char hex[] = "0123456789ABCDEF"; 5315392f7a3SLiteSpeed Tech int i; 5325392f7a3SLiteSpeed Tech 5335392f7a3SLiteSpeed Tech for (i = 0; i < (int) cid->len; ++i) 5345392f7a3SLiteSpeed Tech { 5355392f7a3SLiteSpeed Tech *out++ = hex[ cid->idbuf[i] >> 4 ]; 5365392f7a3SLiteSpeed Tech *out++ = hex[ cid->idbuf[i] & 0xF ]; 5375392f7a3SLiteSpeed Tech } 5385392f7a3SLiteSpeed Tech *out = '\0'; 5395392f7a3SLiteSpeed Tech} 540