#ifndef MOLTEN_LOG_H

#define MOLTEN_LOG_H

#ifdef HAVE_CONFIG_H

#include "config.h"

#include <stdint.h>

#include <limits.h>

#include <string.h>

#include <libgen.h>

#include <stdio.h>

#include <sys/stat.h>

#include <unistd.h>

#include <sys/socket.h>

#include <sys/un.h>

#include <errno.h>

#include <fcntl.h>

#include <time.h>

#include <sys/types.h>

# if defined(__linux__)

#include <linux/limits.h>

#ifdef HAS_CURL

#include "curl/curl.h"

#include "curl/easy.h"

#ifdef HAS_KAFKA

#include "librdkafka/rdkafka.h"

#include "php.h"

#include "Zend/zend_llist.h"

#include "molten_log.h"

#include "molten_util.h"

#include "php7_wrapper.h"

#include "molten_slog.h"

#ifndef PATH_MAX

#define PATH_MAX 4096

#define ALLOC_LOG_SIZE 1024

#define DEFAULT_LOG_DIR "/var/wd/log/tracing/php/"

#define DEFAULT_PREFIX "tracing"

#define LOG_FORMAT "%Y%m%d"

#define SINK_NONE 0

#define SINK_LOG 1

#define SINK_STD 2

#define SINK_SYSLOG 8 /* only for unx domain udp syslog */

#ifdef HAS_CURL

#define SINK_HTTP 4

#ifdef HAS_KAFKA

#define SINK_KAFKA 16

#define SPANS_WRAP 1<<0

#define SPANS_BREAK 1<<1

typedef struct {

uint8_t type;

char *post_uri;

/*

} mo_http_sink_t;

typedef struct {

uint8_t sink_type; /* log sink type */

uint8_t output_type; /* sink output type */

uint16_t support_type; /* sink support type */

char *host_name; /* link to global host name */

/* sink log file */

char *path;

char real_path[128]; /* log real path */

int tm_yday; /* day in year, get by ctime */

int fd;

ino_t ino;

char *format;

/* sink syslog */

char *unix_socket; /* unix domain udp syslog */

int sfd; /* unix domain syslog fd */

struct sockaddr_un server; /* server addr */

/* sink http */

char *post_uri; /* post uri */

/* kafka */

char *brokers; /* brokers */

char *topic; /* topic */

char *buf;

uint64_t total_size;

uint64_t alloc_size;

zval *spans;

} mo_chain_log_t;

void mo_chain_log_init(mo_chain_log_t *log);

void mo_chain_log_ctor(mo_chain_log_t *log, char *host_name, char *log_path, long sink_type, long output_type, char *post_uri, char *syslog_unix_socket);

int mo_chain_log_set_file_path(char *new_path);

void mo_chain_log_add(mo_chain_log_t *log, char *buf, size_t size);

void mo_chain_log_flush(mo_chain_log_t *log);

void mo_chain_log_dtor(mo_chain_log_t *log);

void mo_chain_add_span(mo_chain_log_t *log, zval *span);

void mo_log_write(mo_chain_log_t *log, char *bytes, int size);

#ifdef HAS_CURL

void send_data_by_http(char *post_uri, char *post_data);