static uv_loop_t * loop = NULL;
static struct sockaddr_storage client_addr;
- static uv_tcp_t client_server;
-
- static void on_data(uv_stream_t * client, sirinet_pkg_t * pkg);
- static void on_new_connection(uv_stream_t * server, int status);
- static void on_auth_request(uv_stream_t * client, sirinet_pkg_t * pkg);
- static void on_query(uv_stream_t * client, sirinet_pkg_t * pkg);
- static void on_insert(uv_stream_t * client, sirinet_pkg_t * pkg);
- static void on_ping(uv_stream_t * client, sirinet_pkg_t * pkg);
+ static uv_tcp_t client_server_tcp;
+ static uv_pipe_t client_server_pipe;
+
+ static void on_tcp_new_connection(uv_stream_t * server, int status);
+ static void on_pipe_new_connection(uv_stream_t * server, int status);
+ static void on_data(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_stream_data(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_auth_request(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_query(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_insert(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_ping(sirinet_stream_t * client, sirinet_pkg_t * pkg);
++
static void on_reqfile(
- uv_stream_t * client,
+ sirinet_stream_t * client,
sirinet_pkg_t * pkg,
sirinet_clserver_getfile getfile);
- static void on_register_server(uv_stream_t * client, sirinet_pkg_t * pkg);
- static void on_req_admin(uv_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_register_server(sirinet_stream_t * client, sirinet_pkg_t * pkg);
+ static void on_req_admin(sirinet_stream_t * client, sirinet_pkg_t * pkg);
static void CLSERVER_send_server_error(
siridb_t * siridb,
- uv_stream_t * stream,
+ sirinet_stream_t * client,
sirinet_pkg_t * pkg);
static void CLSERVER_send_pool_error(
- uv_stream_t * stream,
+ sirinet_stream_t * client,
sirinet_pkg_t * pkg);
static void CLSERVER_on_register_server_response(
slist_t * promises,