#include "main.h"

#include "buffer.h"

#include "conns.h"

#include "heap.h"

#include "log.h"

#include "stats.h"

struct conn_s *initialize_conn (int client_fd, const char *ipaddr,

const char *string_addr,

const char *sock_ipaddr)

{

struct conn_s *connptr;

struct buffer_s *cbuffer, *sbuffer;

assert (client_fd >= 0);

/*

cbuffer = new_buffer ();

sbuffer = new_buffer ();

if (!cbuffer || !sbuffer)

goto error_exit;

/*

connptr = (struct conn_s *) safemalloc (sizeof (struct conn_s));

if (!connptr)

goto error_exit;

connptr->client_fd = client_fd;

connptr->server_fd = -1;

connptr->cbuffer = cbuffer;

connptr->sbuffer = sbuffer;

connptr->request_line = NULL;

/* These store any error strings */

connptr->error_variables = NULL;

connptr->error_string = NULL;

connptr->error_number = -1;

connptr->connect_method = FALSE;

connptr->show_stats = FALSE;

connptr->protocol.major = connptr->protocol.minor = 0;

/* There is _no_ content length initially */

connptr->content_length.server = connptr->content_length.client = -1;

connptr->server_ip_addr = (sock_ipaddr ?

safestrdup (sock_ipaddr) : NULL);

connptr->client_ip_addr = safestrdup (ipaddr);

connptr->client_string_addr = safestrdup (string_addr);

connptr->upstream_proxy = NULL;

update_stats (STAT_OPEN);

#ifdef REVERSE_SUPPORT

connptr->reversepath = NULL;

return connptr;

error_exit:

/*

if (cbuffer)

delete_buffer (cbuffer);

if (sbuffer)

delete_buffer (sbuffer);

return NULL;

}

void destroy_conn (struct conn_s *connptr)

{

assert (connptr != NULL);

if (connptr->client_fd != -1)

if (close (connptr->client_fd) < 0)

log_message (LOG_INFO, "Client (%d) close message: %s",

connptr->client_fd, strerror (errno));

if (connptr->server_fd != -1)

if (close (connptr->server_fd) < 0)

log_message (LOG_INFO, "Server (%d) close message: %s",

connptr->server_fd, strerror (errno));

if (connptr->cbuffer)

delete_buffer (connptr->cbuffer);

if (connptr->sbuffer)

delete_buffer (connptr->sbuffer);

if (connptr->request_line)

safefree (connptr->request_line);

if (connptr->error_variables)

hashmap_delete (connptr->error_variables);

if (connptr->error_string)

safefree (connptr->error_string);

if (connptr->server_ip_addr)

safefree (connptr->server_ip_addr);

if (connptr->client_ip_addr)

safefree (connptr->client_ip_addr);

if (connptr->client_string_addr)

safefree (connptr->client_string_addr);

#ifdef REVERSE_SUPPORT

if (connptr->reversepath)

safefree (connptr->reversepath);

safefree (connptr);

update_stats (STAT_CLOSE);

}