connection.h
dce8e2e6fb90master

connection.h
View Options

			#ifndef ANT_NET_CONNECTION_H
			#define ANT_NET_CONNECTION_H

			#include <stdbool.h>
			#include <stddef.h>
			#include <stdint.h>
			#include <uv.h>

			typedef struct ant_listener_s ant_listener_t;
			typedef struct ant_conn_s ant_conn_t;

			typedef enum {
			ANT_CONN_KIND_TCP = 0,
			ANT_CONN_KIND_PIPE,
			} ant_conn_kind_t;

			struct ant_conn_s {
			ant_conn_kind_t kind;

			union {
			uv_tcp_t tcp;
			uv_pipe_t pipe;
			} handle;

			uv_timer_t timer;
			ant_listener_t *listener;

			void *user_data;
			char *buffer;

			size_t buffer_len;
			size_t buffer_cap;
			size_t buffer_offset;

			uint64_t timeout_ms;
			uint64_t bytes_read;
			uint64_t bytes_written;

			int close_handles;
			bool closing;
			bool read_paused;
			bool read_eof;
			bool has_local_addr;
			bool has_remote_addr;

			char local_addr[64];
			char remote_addr[64];
			char local_family[8];
			char remote_family[8];

			int local_port;
			int remote_port;
			struct ant_conn_s *next;
			};

			static inline uv_stream_t ant_conn_stream(ant_conn_t conn) {
			if (!conn) return NULL;
			switch (conn->kind) {
			case ANT_CONN_KIND_PIPE: return (uv_stream_t *)&conn->handle.pipe;
			case ANT_CONN_KIND_TCP:
			default: return (uv_stream_t *)&conn->handle.tcp;
			}
			}

			void ant_conn_start(ant_conn_t *conn);
			int ant_conn_accept(ant_conn_t conn, uv_stream_t server_stream);

			ant_conn_t ant_conn_create_tcp(ant_listener_t listener, uint64_t timeout_ms);
			ant_conn_t ant_conn_create_pipe(ant_listener_t listener, uint64_t timeout_ms);

			#endif