connection.h
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

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