#include <gnutls/gnutls.h>
#include <netinet/in.h>
#include <arpa/inet.h>
+#include <signal.h>
#include "log.h"
#include "pop.h"
return NULL;
}
pop_conn = hc_conn_new (NULL, NULL);
- r = hc_conn_set_driver_pop (pop_conn, conn);
+ r = hc_conn_set_driver_pop (pop_conn, ssl_conn);
if (r != 0)
{
hc_conn_close (pop_conn);
}
}
+static void
+ssl_connected (HCConn *client_conn, HCEvent event, gpointer data)
+{
+ struct pop_address *address = data;
+ HCConn *server_conn;
+ if (event != HC_EVENT_CONNECT)
+ {
+ g_debug ("Did not get connect event when trying to handshake:"
+ " got %d", event);
+ hc_conn_close (client_conn);
+ return;
+ }
+ server_conn = server_conn_new (address->server, address->port,
+ address->ssl);
+ if (server_conn == NULL)
+ {
+ g_debug ("Failure to create connection to server.");
+ hc_conn_close (client_conn);
+ return;
+ }
+ hc_conn_set_callback (client_conn, push_other, server_conn);
+ hc_conn_set_callback (server_conn, push_other, client_conn);
+}
+
static void
new_client (int fd, struct sockaddr *addr, socklen_t saddr, gpointer data)
{
HCConn *client_conn;
- HCConn *server_conn;
struct pop_address *address = data;
if (fd < 0)
{
g_message ("Received connection from %s.",
inet_ntoa (((struct sockaddr_in *) addr)->sin_addr));
- server_conn = server_conn_new (address->server, address->port,
- address->ssl);
- if (server_conn == NULL)
- {
- return;
- }
client_conn = client_conn_new (fd);
if (client_conn == NULL)
{
- hc_conn_close (server_conn);
return;
}
- hc_conn_set_callback (client_conn, push_other, server_conn);
- hc_conn_set_callback (server_conn, push_other, client_conn);
+ if (address->ssl)
+ hc_conn_set_callback (client_conn, ssl_connected, address);
+ else
+ ssl_connected (client_conn, HC_EVENT_CONNECT, address);
}
gchar *policy;
struct pop_address pop_address;
+ signal (SIGPIPE, SIG_IGN);
+
gnutls_global_init ();
configfile = CONFFILE;