return ssl_conn;
}
+static HCConn *
+client_conn_new (int fd)
+{
+ HCConn *conn;
+ HCConn *pop_conn;
+ int r;
+ conn = hc_conn_new (NULL, NULL);
+ r = hc_conn_set_driver_channel (conn, fd);
+ if (r != 0)
+ {
+ hc_conn_close (conn);
+ close (fd);
+ return NULL;
+ }
+ pop_conn = hc_conn_new (NULL, NULL);
+ r = hc_conn_set_driver_pop (pop_conn, conn);
+ if (r != 0)
+ {
+ hc_conn_close (pop_conn);
+ hc_conn_close (conn);
+ return NULL;
+ }
+ return pop_conn;
+}
+
static void
push_other (HCConn *conn, HCEvent event, gpointer data)
{
static void
new_client (int fd, struct sockaddr *addr, socklen_t saddr, gpointer data)
{
- HCConn *conn;
- HCConn *pop_conn;
+ HCConn *client_conn;
HCConn *server_conn;
struct pop_address *address = data;
- int r;
if (fd < 0)
{
g_critical ("Server has received an error event.");
{
return;
}
-
- conn = hc_conn_new (NULL, NULL);
- r = hc_conn_set_driver_channel (conn, fd);
- if (r != 0)
+ client_conn = client_conn_new (fd);
+ if (client_conn == NULL)
{
hc_conn_close (server_conn);
- hc_conn_close (conn);
- close (fd);
return;
}
- pop_conn = hc_conn_new (NULL, NULL);
- r = hc_conn_set_driver_pop (pop_conn, conn);
- if (r != 0)
- {
- hc_conn_close (server_conn);
- hc_conn_close (pop_conn);
- hc_conn_close (conn);
- return;
- }
- hc_conn_set_callback (pop_conn, push_other, server_conn);
- hc_conn_set_callback (server_conn, push_other, pop_conn);
+
+ hc_conn_set_callback (client_conn, push_other, server_conn);
+ hc_conn_set_callback (server_conn, push_other, client_conn);
}