From 21a5981905709974f2c60d9e3118945de4a0e23b Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 21 Jan 2010 17:26:27 +0100
Subject: [PATCH 01/21] Make sure start_listening_socket does everything, this
 will lead the way to multiple listen ports.

---
 src/core/hub.c           | 54 +++++++++++++++---------------------
 src/core/netevent.c      | 14 ++--------
 src/core/probe.c         |  3 +-
 src/network/connection.h |  3 --
 src/network/network.c    | 60 ++++++++++++++++++++++++++++++++--------
 src/network/network.h    |  2 ++
 6 files changed, 75 insertions(+), 61 deletions(-)

diff --git a/src/core/hub.c b/src/core/hub.c
index 96ffb91..ad72826 100644
--- a/src/core/hub.c
+++ b/src/core/hub.c
@@ -450,37 +450,28 @@ static void hub_event_dispatcher(void* callback_data, struct event_data* message
 	}
 }
 
-static int start_listening_socket(const char* bind_addr, uint16_t port, int backlog, char* address_out)
+static struct net_connection* start_listening_socket(const char* bind_addr, uint16_t port, int backlog, struct hub_info* hub)
 {
+	struct net_connection* server;
 	struct sockaddr_storage addr;
 	socklen_t sockaddr_size;
-	int af, sd, ret;
+	int sd, ret;
 
 	if (ip_convert_address(bind_addr, port, (struct sockaddr*) &addr, &sockaddr_size) == -1)
 	{
-		return -1;
+		return 0;
 	}
 
-	af = addr.ss_family;
-	if (af == AF_INET)
-	{
-		net_address_to_string(AF_INET, &((struct sockaddr_in*) &addr)->sin_addr, address_out, INET6_ADDRSTRLEN);
-	}
-	else if (af == AF_INET6)
-	{
-		net_address_to_string(AF_INET6, &((struct sockaddr_in6*) &addr)->sin6_addr, address_out, INET6_ADDRSTRLEN);
-	}
-
-	sd = net_socket_create(af, SOCK_STREAM, IPPROTO_TCP);
+	sd = net_socket_create(addr.ss_family, SOCK_STREAM, IPPROTO_TCP);
 	if (sd == -1)
 	{
-		return -1;
+		return 0;
 	}
 
 	if ((net_set_reuseaddress(sd, 1) == -1) || (net_set_nonblocking(sd, 1) == -1))
 	{
 		net_close(sd);
-		return -1;
+		return 0;
 	}
 
 	ret = net_bind(sd, (struct sockaddr*) &addr, sockaddr_size);
@@ -488,7 +479,7 @@ static int start_listening_socket(const char* bind_addr, uint16_t port, int back
 	{
 		LOG_ERROR("hub_start_service(): Unable to bind to TCP local address. errno=%d, str=%s", net_error(), net_error_string(net_error()));
 		net_close(sd);
-		return -1;
+		return 0;
 	}
 
 	ret = net_listen(sd, backlog);
@@ -496,16 +487,19 @@ static int start_listening_socket(const char* bind_addr, uint16_t port, int back
 	{
 		LOG_ERROR("hub_start_service(): Unable to listen to socket");
 		net_close(sd);
-		return -1;
+		return 0;
 	}
-	return sd;
+
+	server = net_con_create();
+	net_con_initialize(server, sd, net_on_accept, hub, NET_EVENT_READ);
+
+	return server;
 }
 
 struct hub_info* hub_start_service(struct hub_config* config)
 {
 	struct hub_info* hub = 0;
-	int server_tcp, ipv6_supported;
-	char address_buf[INET6_ADDRSTRLEN+1];
+	int ipv6_supported;
 
 	hub = hub_malloc_zero(sizeof(struct hub_info));
 	if (!hub)
@@ -521,14 +515,14 @@ struct hub_info* hub_start_service(struct hub_config* config)
 	else
 		LOG_DEBUG("IPv6 not supported.");
 
-	server_tcp = start_listening_socket(config->server_bind_addr, config->server_port, config->server_listen_backlog, address_buf);
-	if (server_tcp == -1)
+	hub->server = start_listening_socket(config->server_bind_addr, config->server_port, config->server_listen_backlog, hub);
+	if (!hub->server)
 	{
 		hub_free(hub);
 		LOG_FATAL("Unable to start hub service");
 		return 0;
 	}
-	LOG_INFO("Starting " PRODUCT "/" VERSION ", listening on %s:%d...", address_buf, config->server_port);
+	LOG_INFO("Starting " PRODUCT "/" VERSION ", listening on %s:%d...", net_get_local_address(hub->server->sd), config->server_port);
 
 #ifdef SSL_SUPPORT
 	if (config->tls_enable)
@@ -558,22 +552,21 @@ struct hub_info* hub_start_service(struct hub_config* config)
 	}
 #endif
 
-
 	hub->config = config;
 	hub->users = NULL;
 
 	if (uman_init(hub) == -1)
 	{
+		net_con_close(hub->server);
 		hub_free(hub);
-		net_close(server_tcp);
 		return 0;
 	}
 
 	if (event_queue_initialize(&hub->queue, hub_event_dispatcher, (void*) hub) == -1)
 	{
+		net_con_close(hub->server);
 		uman_shutdown(hub);
 		hub_free(hub);
-		net_close(server_tcp);
 		return 0;
 	}
 
@@ -581,11 +574,11 @@ struct hub_info* hub_start_service(struct hub_config* config)
 	hub->sendbuf = hub_malloc(MAX_SEND_BUF);
 	if (!hub->recvbuf || !hub->sendbuf)
 	{
+		net_con_close(hub->server);
 		hub_free(hub->recvbuf);
 		hub_free(hub->sendbuf);
 		uman_shutdown(hub);
 		hub_free(hub);
-		net_close(server_tcp);
 		return 0;
 	}
 
@@ -593,21 +586,18 @@ struct hub_info* hub_start_service(struct hub_config* config)
 	hub->logout_info  = (struct linked_list*) list_create();
 	if (!hub->chat_history)
 	{
+		net_con_close(hub->server);
 		list_destroy(hub->chat_history);
 		list_destroy(hub->logout_info);
 		hub_free(hub->recvbuf);
 		hub_free(hub->sendbuf);
 		uman_shutdown(hub);
 		hub_free(hub);
-		net_close(server_tcp);
 		return 0;
 	}
 
 	hub->status = hub_status_running;
 
-	hub->server = net_con_create();
-	net_con_initialize(hub->server, server_tcp, net_on_accept, hub, NET_EVENT_READ);
-	
 	g_hub = hub;
 	return hub;
 }
diff --git a/src/core/netevent.c b/src/core/netevent.c
index f0a2636..0c9fe4d 100644
--- a/src/core/netevent.c
+++ b/src/core/netevent.c
@@ -165,23 +165,13 @@ void net_event(struct net_connection* con, int event, void *arg)
 	LOG_TRACE("net_event() : fd=%d, ev=%d, arg=%p", fd, (int) event, arg);
 #endif
 
-	if (event == NET_EVENT_SOCKERROR)
-	{
-		hub_disconnect_user(g_hub, user, quit_socket_error);
-		return;
-	}
-	else if (event == NET_EVENT_CLOSED)
-	{
-		hub_disconnect_user(g_hub, user, quit_disconnected);
-		return;
-	}
-	else if (event == NET_EVENT_TIMEOUT)
+	if (event == NET_EVENT_TIMEOUT)
 	{
 		if (user_is_connecting(user))
 		{
 			hub_disconnect_user(g_hub, user, quit_timeout);
-			return;
 		}
+		return;
 	}
 
 	if (event & NET_EVENT_READ)
diff --git a/src/core/probe.c b/src/core/probe.c
index 547f1e5..8a480de 100644
--- a/src/core/probe.c
+++ b/src/core/probe.c
@@ -26,8 +26,7 @@ static char probe_recvbuf[PROBE_RECV_SIZE];
 static void probe_net_event(struct net_connection* con, int events, void *arg)
 {
 	struct hub_probe* probe = (struct hub_probe*) net_con_get_ptr(con);
-
-	if (events == NET_EVENT_SOCKERROR || events == NET_EVENT_CLOSED || events == NET_EVENT_TIMEOUT)
+	if (events == NET_EVENT_TIMEOUT)
 	{
 		probe_destroy(probe);
 		return;
diff --git a/src/network/connection.h b/src/network/connection.h
index 06fcc70..ea15d35 100644
--- a/src/network/connection.h
+++ b/src/network/connection.h
@@ -27,8 +27,6 @@
 #define NET_EVENT_TIMEOUT         0x0001
 #define NET_EVENT_READ            0x0002
 #define NET_EVENT_WRITE           0x0004
-#define NET_EVENT_SOCKERROR       0x1000 /* Socket error, closed */
-#define NET_EVENT_CLOSED          0x2000 /* Socket closed */
 
 struct net_connection;
 
@@ -53,7 +51,6 @@ extern void net_con_callback(struct net_connection* con, int events);
  * Close the connection.
  * This will ensure a connection is closed properly and will generate a NET_EVENT_DESTROYED event which indicates
  * that the con can safely be deleted (or set to NULL).
- * @returns 1 if the memory pointed to by con can be freed immediately, or 0 if it needs to go through the NET_EVENT_DESTROYED event.
  */
 extern void net_con_close(struct net_connection* con);
 
diff --git a/src/network/network.c b/src/network/network.c
index a4dba1b..431c8a5 100644
--- a/src/network/network.c
+++ b/src/network/network.c
@@ -381,11 +381,11 @@ int net_accept(int fd, struct ip_addr_encap* ipaddr)
 			{
 				char address[INET6_ADDRSTRLEN+1] = { 0, };
 				net_address_to_string(AF_INET6, (void*) &addr6->sin6_addr, address, INET6_ADDRSTRLEN+1);
-				if (!strncmp(address, "::ffff:", 7))
+				if (strchr(address, '.'))
 				{
 					/* Hack to convert IPv6 mapped IPv4 addresses to true IPv4 addresses */
-					net_string_to_address(AF_INET, address + 7, (void*) &ipaddr->internal_ip_data.in);
 					ipaddr->af = AF_INET;
+					net_string_to_address(AF_INET, address, (void*) &ipaddr->internal_ip_data.in);
 				}
 				else
 				{
@@ -526,7 +526,12 @@ const char* net_address_to_string(int af, const void* src, char* dst, socklen_t
 
 	return NULL;
 #else
-	return inet_ntop(af, src, dst, cnt);
+	const char* address = inet_ntop(af, src, dst, cnt);
+	if (af == AF_INET6 && strncmp(address, "::ffff:", 7) == 0) /* IPv6 mapped IPv4 address. */
+	{
+		return &address[7];
+	}
+	return address;
 #endif
 }
 
@@ -573,9 +578,6 @@ int net_string_to_address(int af, const char* src, void* dst)
 #endif
 }
 
-
-
-
 const char* net_get_peer_address(int fd)
 {
 	static char address[INET6_ADDRSTRLEN+1];
@@ -598,17 +600,12 @@ const char* net_get_peer_address(int fd)
 		if (af == AF_INET6)
 		{
 			net_address_to_string(af, (void*) &name6->sin6_addr, address, INET6_ADDRSTRLEN);
-			if (strncmp(address, "::ffff:", 7) == 0) /* IPv6 mapped IPv4 address. */
-			{
-				return &address[7];
-			}
-			return address;
 		}
 		else
 		{
 			net_address_to_string(af, (void*) &name4->sin_addr, address, INET6_ADDRSTRLEN);
-			return address;
 		}
+		return address;
 	}
 	else
 	{
@@ -619,6 +616,45 @@ const char* net_get_peer_address(int fd)
 	return "0.0.0.0";
 }
 
+const char* net_get_local_address(int fd)
+{
+	static char address[INET6_ADDRSTRLEN+1];
+	struct sockaddr_storage storage;
+	struct sockaddr_in6* name6;
+	struct sockaddr_in*  name4;
+	struct sockaddr*     name;
+
+	memset(address, 0, INET6_ADDRSTRLEN);
+	socklen_t namelen = sizeof(struct sockaddr_storage);
+	memset(&storage, 0, namelen);
+
+	name6 = (struct sockaddr_in6*) &storage;
+	name4 = (struct sockaddr_in*)  &storage;
+	name  = (struct sockaddr*)     &storage;
+
+	if (getsockname(fd, (struct sockaddr*) name, &namelen) != -1)
+	{
+		int af = name4->sin_family;
+		if (af == AF_INET6)
+		{
+			net_address_to_string(af, (void*) &name6->sin6_addr, address, INET6_ADDRSTRLEN);
+		}
+		else
+		{
+			net_address_to_string(af, (void*) &name4->sin_addr, address, INET6_ADDRSTRLEN);
+		}
+		return address;
+	}
+	else
+	{
+		net_error_out(fd, "net_get_local_address");
+		net_stats_add_error();
+	}
+
+	return "0.0.0.0";
+}
+
+
 
 ssize_t net_recv(int fd, void* buf, size_t len, int flags)
 {
diff --git a/src/network/network.h b/src/network/network.h
index c4ee234..c1a1066 100644
--- a/src/network/network.h
+++ b/src/network/network.h
@@ -224,6 +224,8 @@ extern int net_is_ipv6_supported();
  */
 extern const char* net_get_peer_address(int fd);
 
+extern const char* net_get_local_address(int fd);
+
 /**
  * See man(3) inet_ntop.
  */

From b04a20c66e2f9e05521dbd04504a6cac52174334 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 21 Jan 2010 22:20:26 +0100
Subject: [PATCH 02/21] fixed off by one bug in due to message escape.

---
 src/core/commands.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/core/commands.c b/src/core/commands.c
index 3038bd6..2218d3d 100644
--- a/src/core/commands.c
+++ b/src/core/commands.c
@@ -399,8 +399,8 @@ static int command_whoip(struct hub_info* hub, struct hub_user* user, struct hub
 
 static int command_broadcast(struct hub_info* hub, struct hub_user* user, struct hub_command* cmd)
 {
-	struct adc_message* command = adc_msg_construct(ADC_CMD_IMSG, strlen((cmd->message + 11)) + 6);
-	adc_msg_add_argument(command, (cmd->message + 11));
+	struct adc_message* command = adc_msg_construct(ADC_CMD_IMSG, strlen((cmd->message + 12)) + 6);
+	adc_msg_add_argument(command, (cmd->message + 12));
 	route_to_all(hub, command);
 	adc_msg_free(command);
 	return 0;

From 78ad9b85725c2d2e5462441c0affd7eb6db3b4aa Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 21 Jan 2010 22:56:07 +0100
Subject: [PATCH 03/21] Fixed bad logic inside the timer scheduling.

---
 src/network/epoll.c  |  7 +------
 src/network/select.c |  7 +------
 src/network/timer.c  |  2 +-
 src/util/timeout.c   | 41 ++++++++++++++++++++++++++---------------
 4 files changed, 29 insertions(+), 28 deletions(-)

diff --git a/src/network/epoll.c b/src/network/epoll.c
index dd1277a..bb9055e 100644
--- a/src/network/epoll.c
+++ b/src/network/epoll.c
@@ -226,12 +226,7 @@ void net_con_close(struct net_connection* con_)
 		g_backend->num--;
 	}
 
-	if (timeout_evt_is_scheduled(con->timeout))
-	{
-		timeout_queue_remove(&g_backend->timeout_queue, con->timeout);
-		hub_free(con->timeout);
-		con->timeout = 0;
-	}
+	net_con_clear_timeout(con_);
 
 	if (epoll_ctl(g_backend->epfd, EPOLL_CTL_DEL, con->sd, &con->ev) == -1)
 	{
diff --git a/src/network/select.c b/src/network/select.c
index d70acc0..6b35f64 100644
--- a/src/network/select.c
+++ b/src/network/select.c
@@ -195,12 +195,7 @@ void net_con_close(struct net_connection* con)
 		g_backend->num--;
 	}
 
-	if (timeout_evt_is_scheduled(con->timeout))
-	{
-		timeout_queue_remove(&g_backend->timeout_queue, con->timeout);
-		hub_free(con->timeout);
-		con->timeout = 0;
-	}
+	net_con_clear_timeout(con);
 
 	net_con_print("DEL", (struct net_connection_select*) con);
 	net_cleanup_delayed_free(g_backend->cleaner, con);
diff --git a/src/network/timer.c b/src/network/timer.c
index 9400cb7..48911d5 100644
--- a/src/network/timer.c
+++ b/src/network/timer.c
@@ -41,7 +41,7 @@ void net_con_set_timeout(struct net_connection* con, int seconds)
 
 void net_con_clear_timeout(struct net_connection* con)
 {
-	if (timeout_evt_is_scheduled(con->timeout))
+	if (con->timeout && timeout_evt_is_scheduled(con->timeout))
 	{
 		timeout_queue_remove(net_backend_get_timeout_queue(), con->timeout);
 		hub_free(con->timeout);
diff --git a/src/util/timeout.c b/src/util/timeout.c
index 6b75eb6..c728f31 100644
--- a/src/util/timeout.c
+++ b/src/util/timeout.c
@@ -36,7 +36,6 @@ void timeout_evt_reset(struct timeout_evt* t)
 
 int timeout_evt_is_scheduled(struct timeout_evt* t)
 {
-	if (!t) return 0;
 	return !!t->prev;
 }
 
@@ -82,16 +81,18 @@ void timeout_queue_insert(struct timeout_queue* t, struct timeout_evt* evt, size
 	
 	first = t->events[pos];
 	
-	if (!first)
+	if (first)
+	{
+		first->prev->next = evt;
+		evt->prev = first->prev;
+		first->prev = evt;
+	}
+	else
 	{
 		t->events[pos] = evt;
 		evt->prev = evt;
 	}
-	else
-	{
-		evt->prev = first->prev;
-		first->prev = evt;
-	}
+	evt->next = 0;
 }
 
 void timeout_queue_remove(struct timeout_queue* t, struct timeout_evt* evt)
@@ -99,23 +100,33 @@ void timeout_queue_remove(struct timeout_queue* t, struct timeout_evt* evt)
 	size_t pos = (evt->timestamp % t->max);
 	struct timeout_evt* first = t->events[pos];
 
-	if (!first || !evt)
+	if (!first || !evt->prev)
 		return;
 
 	if (first == evt)
 	{
-		if (first->next)
-			first->next->prev = first->prev;
-		t->events[pos] = first->next;
+		if (first->prev != first)
+		{
+			t->events[pos] = first->next;
+			t->events[pos]->prev = evt->prev;
+		}
+		else
+		{
+			t->events[pos] = 0;
+		}
+	}
+	else if (evt == first->prev)
+	{
+		first->prev = evt->prev;
+		evt->prev->next = 0;
 	}
 	else
 	{
 		evt->prev->next = evt->next;
-		if (evt->next)
-				evt->next->prev = evt->prev;
-		else
-				first->prev = evt->prev;
+		evt->next->prev = evt->prev;
 	}
+	evt->next = 0;
+	evt->prev = 0;
 }
 
 void timeout_queue_reschedule(struct timeout_queue* t, struct timeout_evt* evt, size_t seconds)

From b29da11f3b0aa1f8a1ec046e231b49a5aceba61e Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 21 Jan 2010 23:45:13 +0100
Subject: [PATCH 04/21] Make sure we call the timeout code.

---
 src/network/epoll.c  | 7 +++++++
 src/network/select.c | 6 ++++++
 src/util/timeout.c   | 4 +---
 3 files changed, 14 insertions(+), 3 deletions(-)

diff --git a/src/network/epoll.c b/src/network/epoll.c
index bb9055e..0232a4d 100644
--- a/src/network/epoll.c
+++ b/src/network/epoll.c
@@ -114,6 +114,9 @@ int net_backend_process()
 		return 0;
 	}
 
+	g_backend->now = time(0);
+	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
+
 	for (n = 0; n < res; n++)
 	{
 		struct net_connection_epoll* con = (struct net_connection_epoll*) g_backend->events[n].data.ptr;
@@ -232,6 +235,10 @@ void net_con_close(struct net_connection* con_)
 	{
 		LOG_WARN("epoll_ctl() delete failed.");
 	}
+
+	net_close(con->sd);
+	con->sd = -1;
+
 	net_con_print("DEL", con);
 	net_cleanup_delayed_free(g_backend->cleaner, con_);
 }
diff --git a/src/network/select.c b/src/network/select.c
index 6b35f64..069cdad 100644
--- a/src/network/select.c
+++ b/src/network/select.c
@@ -117,6 +117,9 @@ int net_backend_process()
 		return 0;
 	}
 
+	g_backend->now = time(0);
+	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
+
 	for (n = 0, found = 0; found < res && n < (maxfd+1); n++)
 	{
 		struct net_connection_select* con = g_backend->conns[n];
@@ -197,6 +200,9 @@ void net_con_close(struct net_connection* con)
 
 	net_con_clear_timeout(con);
 
+	net_close(con->sd);
+	con->sd = -1;
+
 	net_con_print("DEL", (struct net_connection_select*) con);
 	net_cleanup_delayed_free(g_backend->cleaner, con);
 }
diff --git a/src/util/timeout.c b/src/util/timeout.c
index c728f31..e5c3760 100644
--- a/src/util/timeout.c
+++ b/src/util/timeout.c
@@ -63,7 +63,6 @@ size_t timeout_queue_process(struct timeout_queue* t, time_t now)
 		while ((evt = t->events[pos % t->max]))
 		{
 			timeout_queue_remove(t, evt);
-			timeout_evt_reset(evt);
 			evt->callback(evt);
 			events++;
 		}
@@ -125,8 +124,7 @@ void timeout_queue_remove(struct timeout_queue* t, struct timeout_evt* evt)
 		evt->prev->next = evt->next;
 		evt->next->prev = evt->prev;
 	}
-	evt->next = 0;
-	evt->prev = 0;
+	timeout_evt_reset(evt);
 }
 
 void timeout_queue_reschedule(struct timeout_queue* t, struct timeout_evt* evt, size_t seconds)

From 8b7f09c7f43424598dad0d4b8ee0928b9d031f91 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Thu, 21 Jan 2010 23:54:38 +0100
Subject: [PATCH 05/21] Fixed two cases of bad connection close.

---
 src/core/netevent.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/core/netevent.c b/src/core/netevent.c
index 0c9fe4d..8b90b24 100644
--- a/src/core/netevent.c
+++ b/src/core/netevent.c
@@ -228,7 +228,7 @@ void net_on_accept(struct net_connection* con, int event, void *arg)
 		if (acl_is_ip_banned(hub->acl, addr))
 		{
 			LOG_INFO("Denied      [%s] (IP banned)", addr);
-			net_close(fd);
+			net_con_close(con);
 			continue;
 		}
 
@@ -236,7 +236,7 @@ void net_on_accept(struct net_connection* con, int event, void *arg)
 		if (!probe)
 		{
 			LOG_ERROR("Unable to create probe after socket accepted. Out of memory?");
-			net_close(fd);
+			net_con_close(con);
 			break;
 		}
 	}

From 26a2a384b677b43c9b5a145bdf2823f88b5e117d Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 16:01:54 +0100
Subject: [PATCH 06/21] Bump to version 0.3.0

---
 version.h | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/version.h b/version.h
index 4212306..aee2a52 100644
--- a/version.h
+++ b/version.h
@@ -9,7 +9,7 @@
 #endif
 
 #ifndef VERSION
-#define VERSION "0.3.0-rc4" REVISION
+#define VERSION "0.3.0" REVISION
 #endif
 
 #ifndef COPYRIGHT

From 5e253e844279a30664a794f83ad863bcadfd6483 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 16:04:36 +0100
Subject: [PATCH 07/21] Fix compile error.

---
 src/tools/adcclient.c | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/src/tools/adcclient.c b/src/tools/adcclient.c
index e6c4a0b..93bb666 100644
--- a/src/tools/adcclient.c
+++ b/src/tools/adcclient.c
@@ -75,19 +75,13 @@ static void event_callback(struct net_connection* con, int events, void *arg)
 {
 	struct ADC_client* client = (struct ADC_client*) net_con_get_ptr(con);
 
-	if (events == NET_EVENT_SOCKERROR || events == NET_EVENT_CLOSED)
-	{
-		printf("NET_EVENT_SOCKERROR || NET_EVENT_CLOSED\n");
-		client->callback(client, ADC_CLIENT_DISCONNECTED, 0);
-		return;
-	}
-
 	if (events == NET_EVENT_TIMEOUT)
 	{
 		if (client->state == ps_conn)
 		{
 			client->callback(client, ADC_CLIENT_DISCONNECTED, 0);
 		}
+		return;
 	}
 
 	if (events & NET_EVENT_READ)

From 1bb3bd90c1aa8006f53f3a37ca4fb6eb7bf070c7 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 16:05:48 +0100
Subject: [PATCH 08/21] Use non-default port to ensure autotests work even
 though a hub is running on the default port.

---
 autotest/test_hub.tcc | 1 +
 1 file changed, 1 insertion(+)

diff --git a/autotest/test_hub.tcc b/autotest/test_hub.tcc
index f3e0d7f..46271e5 100644
--- a/autotest/test_hub.tcc
+++ b/autotest/test_hub.tcc
@@ -23,6 +23,7 @@ EXO_TEST(hub_net_startup, {
 
 EXO_TEST(hub_config_initialize, {
 	config_defaults(&g_config);
+	g_config.server_port = 15111;
 	return 1;
 });
 

From 4711d26c11ba26dcf1b70ad5009884ea4c593195 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 16:09:19 +0100
Subject: [PATCH 09/21] Fix broken net_address_to_string().

---
 src/network/network.c | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/network/network.c b/src/network/network.c
index 431c8a5..b8b2e1f 100644
--- a/src/network/network.c
+++ b/src/network/network.c
@@ -526,12 +526,15 @@ const char* net_address_to_string(int af, const void* src, char* dst, socklen_t
 
 	return NULL;
 #else
-	const char* address = inet_ntop(af, src, dst, cnt);
-	if (af == AF_INET6 && strncmp(address, "::ffff:", 7) == 0) /* IPv6 mapped IPv4 address. */
+	if (inet_ntop(af, src, dst, cnt))
 	{
-		return &address[7];
+		if (af == AF_INET6 && strncmp(dst, "::ffff:", 7) == 0) /* IPv6 mapped IPv4 address. */
+		{
+			memmove(dst, dst + 7, cnt - 7);
+		}
+		return dst;
 	}
-	return address;
+	return NULL;
 #endif
 }
 

From 68a26e11605ea8846ac6ec4a9ea34522db774434 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 16:57:30 +0100
Subject: [PATCH 10/21] Added proper POSIX signal handler.

---
 src/core/main.c | 32 +++++++++++++++-----------------
 1 file changed, 15 insertions(+), 17 deletions(-)

diff --git a/src/core/main.c b/src/core/main.c
index f47262d..5a8b3dd 100644
--- a/src/core/main.c
+++ b/src/core/main.c
@@ -33,13 +33,13 @@ static const char* arg_pid = 0;
 static int arg_log_syslog = 0;
 
 
-#if !defined(WIN32) && defined(USE_LIBEVENT)
-void hub_handle_signal(int fd, short events, void* arg)
+#if !defined(WIN32)
+extern struct hub_info* g_hub;
+void hub_handle_signal(int sig)
 {
-	struct hub_info* hub = (struct hub_info*) arg;
-	int signal = fd;
+	struct hub_info* hub = g_hub;
 
-	switch (signal)
+	switch (sig)
 	{
 		case SIGINT:
 			LOG_INFO("Interrupted. Shutting down...");
@@ -65,7 +65,6 @@ void hub_handle_signal(int fd, short events, void* arg)
 	}
 }
 
-static struct event signal_events[10];
 static int signals[] =
 {
 	SIGINT,  /* Interrupt the application */
@@ -77,11 +76,16 @@ static int signals[] =
 
 void setup_signal_handlers(struct hub_info* hub)
 {
+	sigset_t sig_set;
+	sigemptyset(&sig_set);
+	struct sigaction act;
+	act.sa_mask = sig_set;
+	act.sa_flags = SA_ONSTACK  | SA_RESTART;
+	act.sa_handler = hub_handle_signal;
 	int i = 0;
 	for (i = 0; signals[i]; i++)
 	{
-		signal_set(&signal_events[i], signals[i], hub_handle_signal, hub);
-		if (signal_add(&signal_events[i], NULL))
+		if (sigaction(signals[i], &act, 0) != 0)
 		{
 			LOG_ERROR("Error setting signal handler %d", signals[i]);
 		}
@@ -90,14 +94,8 @@ void setup_signal_handlers(struct hub_info* hub)
 
 void shutdown_signal_handlers(struct hub_info* hub)
 {
-	int i = 0;
-	for (i = 0; signals[i]; i++)
-	{
-		signal_del(&signal_events[i]);
-	}
 }
-
-#endif /* !WIN32 && USE_LIBEVENT*/
+#endif /* !WIN32 */
 
 
 int main_loop()
@@ -133,7 +131,7 @@ int main_loop()
 			hub = hub_start_service(&configuration);
 			if (!hub)
 				return -1;
-#if !defined(WIN32) && defined(USE_LIBEVENT)
+#if !defined(WIN32)
 			setup_signal_handlers(hub);
 #endif
 		}
@@ -148,7 +146,7 @@ int main_loop()
 
 	} while (hub->status == hub_status_restart);
 
-#if !defined(WIN32) && defined(USE_LIBEVENT)
+#if !defined(WIN32)
 	shutdown_signal_handlers(hub);
 #endif
 	

From 5f353ebe280b41e73c479c12524e3532cf59e055 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 18:22:39 +0100
Subject: [PATCH 11/21] Added script to create SSL certificate.

---
 tools/create_certificate.sh | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100755 tools/create_certificate.sh

diff --git a/tools/create_certificate.sh b/tools/create_certificate.sh
new file mode 100755
index 0000000..7d13410
--- /dev/null
+++ b/tools/create_certificate.sh
@@ -0,0 +1,16 @@
+#!/bin/sh
+
+OPENSSL=/usr/bin/openssl
+NAME=certificate
+
+if [ ! -x ${OPENSSL} ]; then
+	echo "Cannot locate the openssl utility: ${OPENSSL}"
+	exit 1
+fi
+
+${OPENSSL} genrsa -out ${NAME}.key 1024 &&
+${OPENSSL} req -new -x509 -nodes -sha1 -days 365 -key ${NAME}.key > ${NAME}.crt &&
+cat ${NAME}.key ${NAME}.crt > ${NAME}.pem && rm -f ${NAME}.key ${NAME}.crt
+
+echo "Created certificate ${NAME}.pem"
+

From 230ca28b46f5fe4926d6f00140e0bbeaa8598176 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 18:52:38 +0100
Subject: [PATCH 12/21] Some unfinished SSL work.

---
 src/network/connection.c | 43 ++++++++++++++++++++++++++++++++++++++--
 1 file changed, 41 insertions(+), 2 deletions(-)

diff --git a/src/network/connection.c b/src/network/connection.c
index 744f248..27c2363 100644
--- a/src/network/connection.c
+++ b/src/network/connection.c
@@ -234,10 +234,49 @@ void* net_con_get_ptr(struct net_connection* con)
 
 void net_con_callback(struct net_connection* con, int events)
 {
-	if (!(con->flags & NET_CLEANUP))
+	if ((con->flags & NET_CLEANUP))
+		return;
+
+	if (events == NET_EVENT_TIMEOUT)
 	{
-		LOG_TRACE("net_con_callback(%p, %s%s%s)", con, (events & NET_EVENT_READ ? "R" : ""), (events & NET_EVENT_WRITE ? "W" : ""), events == NET_EVENT_TIMEOUT ? "TIMEOUT" : "");
+		LOG_TRACE("net_con_callback(%p, TIMEOUT", con);
 		con->callback(con, events, con->ptr);
+		return;
 	}
+
+#ifdef SSL_SUPPORT
+	if (!con->ssl)
+	{
+#endif
+		con->callback(con, events, con->ptr);
+#ifdef SSL_SUPPORT
+	}
+	else
+	{
+#ifdef NETWORK_DUMP_DEBUG
+		LOG_PROTO("net_con_event: events=%d, con=%p", ev, con);
+#endif
+		if (events == NET_EVENT_READ && con->flags & NET_WANT_SSL_READ)
+		{
+			con->callback(con, NET_EVENT_WRITE, con->ptr);
+		}
+		else if (events == NET_EVENT_WRITE && con->flags & NET_WANT_SSL_WRITE)
+		{
+			con->callback(con, events & NET_EVENT_READ, con->ptr);
+		}
+		if (con->flags & NET_WANT_SSL_ACCEPT)
+		{
+			net_con_ssl_accept(con);
+		}
+		else if (con->flags & NET_WANT_SSL_CONNECT)
+		{
+			net_con_ssl_connect(con);
+		}
+		else
+		{
+			con->callback(con, events, con->ptr);
+		}
+	}
+#endif
 }
 

From 4aa65733d0107b1269496c0fc6d8195afaac3cae Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 23:18:59 +0100
Subject: [PATCH 13/21] Poll as long as possible until next timeout the
 earliest.

---
 src/network/epoll.c  | 28 ++++------------------------
 src/network/select.c |  8 +++++++-
 src/util/timeout.c   | 15 ++++++++++++++-
 src/util/timeout.h   |  2 ++
 4 files changed, 27 insertions(+), 26 deletions(-)

diff --git a/src/network/epoll.c b/src/network/epoll.c
index 0232a4d..00ac494 100644
--- a/src/network/epoll.c
+++ b/src/network/epoll.c
@@ -95,6 +95,7 @@ int net_backend_initialize()
 void net_backend_shutdown()
 {
 	close(g_backend->epfd);
+	timeout_queue_shutdown(&g_backend->timeout_queue);
 	net_cleanup_shutdown(g_backend->cleaner);
 	hub_free(g_backend->conns);
 	hub_free(g_backend);
@@ -106,8 +107,9 @@ void net_backend_shutdown()
 int net_backend_process()
 {
 	int n;
-	LOG_TRACE("epoll_wait: fd=%d, events=%x, max=%zu", g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER));
-	int res = epoll_wait(g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER), 1000);
+	size_t secs = timeout_queue_get_next_timeout(&g_backend->timeout_queue, g_backend->now);
+	LOG_TRACE("epoll_wait: fd=%d, events=%x, max=%zu, seconds=%d", g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER), (int) secs);
+	int res = epoll_wait(g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER), secs * 1000);
 	if (res == -1)
 	{
 		LOG_WARN("epoll_wait returned -1");
@@ -188,28 +190,6 @@ void net_con_update(struct net_connection* con_, int events)
 	if (events & NET_EVENT_READ)  con->ev.events |= EPOLLIN;
 	if (events & NET_EVENT_WRITE) con->ev.events |= EPOLLOUT;
 
-#ifdef SSL_SUPPORT
-	if (events & NET_WANT_SSL_WRITE)
-		con->flags |= NET_WANT_SSL_WRITE;
-	else
-		con->flags &= ~NET_WANT_SSL_WRITE;
-
-	if (events & NET_WANT_SSL_READ)
-		con->flags |= NET_WANT_SSL_READ;
-	else
-		con->flags &= ~NET_WANT_SSL_READ;
-
-	if (events & NET_WANT_SSL_ACCEPT)
-		con->flags |= NET_WANT_SSL_ACCEPT;
-	else
-		con->flags &= ~NET_WANT_SSL_ACCEPT;
-
-	if (events & NET_WANT_SSL_CONNECT)
-		con->flags |= NET_WANT_SSL_CONNECT;
-	else
-		con->flags &= ~NET_WANT_SSL_CONNECT;
-#endif /* SSL_SUPPORT */
-
 	if (epoll_ctl(g_backend->epfd, EPOLL_CTL_MOD, con->sd, &con->ev) == -1)
 	{
 		LOG_TRACE("epoll_ctl() modify failed.");
diff --git a/src/network/select.c b/src/network/select.c
index 069cdad..872ad24 100644
--- a/src/network/select.c
+++ b/src/network/select.c
@@ -84,6 +84,7 @@ int net_backend_initialize()
  */
 void net_backend_shutdown()
 {
+	timeout_queue_shutdown(&g_backend->timeout_queue);
 	net_cleanup_shutdown(g_backend->cleaner);
 	hub_free(g_backend->conns);
 	hub_free(g_backend);
@@ -95,9 +96,14 @@ void net_backend_shutdown()
 int net_backend_process()
 {
 	int n, found, maxfd;
-	struct timeval tval = { 1, 0 };
+	struct timeval tval;
 	FD_ZERO(&g_backend->rfds);
 	FD_ZERO(&g_backend->wfds);
+
+	size_t secs = timeout_queue_get_next_timeout(&g_backend->timeout_queue, g_backend->now);
+	tval.tv_secs = secs;
+	tval.tv_usecs = 0;
+
 	for (n = 0, found = 0; found < g_backend->num && n < g_backend->max; n++)
 	{
 		struct net_connection_select* con = g_backend->conns[n];
diff --git a/src/util/timeout.c b/src/util/timeout.c
index e5c3760..b89eb6c 100644
--- a/src/util/timeout.c
+++ b/src/util/timeout.c
@@ -58,7 +58,7 @@ size_t timeout_queue_process(struct timeout_queue* t, time_t now)
 	size_t pos;
 	size_t events = 0;
 	struct timeout_evt* evt = 0;
-	for (pos = t->last; pos < now; pos++)
+	for (pos = t->last; pos <= now; pos++)
 	{
 		while ((evt = t->events[pos % t->max]))
 		{
@@ -71,6 +71,19 @@ size_t timeout_queue_process(struct timeout_queue* t, time_t now)
 	return events;
 }
 
+size_t timeout_queue_get_next_timeout(struct timeout_queue* t, time_t now)
+{
+	size_t seconds = 0;
+	while (t->events[(now + seconds) % t->max] == NULL && seconds < t->max)
+	{
+		seconds++;
+	}
+	if (seconds == 0)
+		return 1;
+	return seconds;
+}
+
+
 void timeout_queue_insert(struct timeout_queue* t, struct timeout_evt* evt, size_t seconds)
 {
 	struct timeout_evt* first;
diff --git a/src/util/timeout.h b/src/util/timeout.h
index 06eb926..b40abd9 100644
--- a/src/util/timeout.h
+++ b/src/util/timeout.h
@@ -53,4 +53,6 @@ void timeout_queue_insert(struct timeout_queue*, struct timeout_evt*, size_t sec
 void timeout_queue_remove(struct timeout_queue*, struct timeout_evt*);
 void timeout_queue_reschedule(struct timeout_queue*, struct timeout_evt*, size_t seconds);
 
+size_t timeout_queue_get_next_timeout(struct timeout_queue*, time_t now);
+
 #endif /* HAVE_UHUB_TIMEOUT_HANDLER_H */

From 84bd2591d6b057e1e7bf9f2e263db0a35d2c290d Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Fri, 22 Jan 2010 23:40:41 +0100
Subject: [PATCH 14/21] SSL fixes, seems to work with stunnel4 as a client but
 not linuxdcpp using SSL directly.

---
 src/core/netevent.c      |   4 +-
 src/network/common.h     |   2 +-
 src/network/connection.c | 147 ++++++++++++++++++++++++---------------
 3 files changed, 95 insertions(+), 58 deletions(-)

diff --git a/src/core/netevent.c b/src/core/netevent.c
index 8b90b24..0afe7cf 100644
--- a/src/core/netevent.c
+++ b/src/core/netevent.c
@@ -27,7 +27,7 @@ extern struct hub_info* g_hub;
 #ifdef DEBUG_SENDQ
 void debug_sendq_send(struct hub_user* user, int sent, int total)
 {
-	LOG_DUMP("SEND: sd=%d, %d/%d bytes\n", user->net.connection.sd, sent, total);
+	LOG_DUMP("SEND: sd=%d, %d/%d bytes\n", user->connection->sd, sent, total);
 	if (sent == -1)
 	{
 		int err = net_error();
@@ -162,7 +162,7 @@ void net_event(struct net_connection* con, int event, void *arg)
 	int flag_close = 0;
 
 #ifdef DEBUG_SENDQ
-	LOG_TRACE("net_event() : fd=%d, ev=%d, arg=%p", fd, (int) event, arg);
+	LOG_TRACE("net_event() : fd=%d, ev=%d, arg=%p", con->sd, (int) event, arg);
 #endif
 
 	if (event == NET_EVENT_TIMEOUT)
diff --git a/src/network/common.h b/src/network/common.h
index 5fe7fa8..014ddfb 100644
--- a/src/network/common.h
+++ b/src/network/common.h
@@ -28,7 +28,6 @@
 
 #define NET_CLEANUP               0x8000
 
-
 #define NET_CON_STRUCT_BASIC \
 	int                  sd;        /** socket descriptor */ \
 	uint32_t             flags;     /** Connection flags */ \
@@ -38,6 +37,7 @@
 
 #define NET_CON_STRUCT_SSL \
 	SSL*                 ssl;       /** SSL handle */ \
+	uint32_t             ssl_state; /** SSL state */ \
 	size_t               write_len; /** Length of last SSL_write(), only used if flags is NET_WANT_SSL_READ. */ \
 
 #ifdef SSL_SUPPORT
diff --git a/src/network/connection.c b/src/network/connection.c
index 27c2363..59c3795 100644
--- a/src/network/connection.c
+++ b/src/network/connection.c
@@ -21,6 +21,17 @@
 #include "network/common.h"
 
 #ifdef SSL_SUPPORT
+
+enum uhub_tls_state
+{
+	tls_st_none,
+	tls_st_error,
+	tls_st_accepting,
+	tls_st_connecting,
+	tls_st_connected,
+	tls_st_disconnecting,
+};
+
 static int handle_openssl_error(struct net_connection* con, int ret)
 {
 	uhub_assert(con);
@@ -30,30 +41,19 @@ static int handle_openssl_error(struct net_connection* con, int ret)
 	{
 		case SSL_ERROR_ZERO_RETURN:
 			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_ZERO_RETURN", ret, error);
+			con->ssl_state = tls_st_error;
 			return -1;
 
 		case SSL_ERROR_WANT_READ:
 			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_WANT_READ", ret, error);
-			net_con_update(con, NET_EVENT_READ | NET_WANT_SSL_READ);
+			con->flags |= NET_WANT_SSL_READ;
+			net_con_update(con, NET_EVENT_READ);
 			return 0;
 
 		case SSL_ERROR_WANT_WRITE:
 			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_WANT_WRITE", ret, error);
-			net_con_update(con, NET_EVENT_READ | NET_EVENT_WRITE | NET_WANT_SSL_WRITE);
-			return 0;
-
-		case SSL_ERROR_WANT_CONNECT:
-			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_WANT_CONNECT", ret, error);
-			net_con_update(con, NET_EVENT_READ | NET_EVENT_WRITE | NET_WANT_SSL_CONNECT);
-			return 0;
-
-		case SSL_ERROR_WANT_ACCEPT:
-			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_WANT_ACCEPT", ret, error);
-			net_con_update(con, NET_EVENT_READ | NET_EVENT_WRITE | NET_WANT_SSL_ACCEPT);
-			return 0;
-
-		case SSL_ERROR_WANT_X509_LOOKUP:
-			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_WANT_X509_LOOKUP", ret, error);
+			con->flags |= NET_WANT_SSL_WRITE;
+			net_con_update(con, NET_EVENT_READ | NET_EVENT_WRITE);
 			return 0;
 
 		case SSL_ERROR_SYSCALL:
@@ -67,6 +67,7 @@ static int handle_openssl_error(struct net_connection* con, int ret)
 		case SSL_ERROR_SSL:
 			LOG_PROTO("SSL_get_error: ret=%d, error=%d: SSL_ERROR_SSL", ret, error);
 			/* internal openssl error */
+			con->ssl_state = tls_st_error;
 			return -1;
 	}
 
@@ -76,7 +77,7 @@ static int handle_openssl_error(struct net_connection* con, int ret)
 ssize_t net_con_ssl_accept(struct net_connection* con)
 {
 	uhub_assert(con);
-
+	con->ssl_state = tls_st_accepting;
 	ssize_t ret = SSL_accept(con->ssl);
 #ifdef NETWORK_DUMP_DEBUG
 	LOG_PROTO("SSL_accept() ret=%d", ret);
@@ -84,6 +85,7 @@ ssize_t net_con_ssl_accept(struct net_connection* con)
 	if (ret > 0)
 	{
 		net_con_update(con, NET_EVENT_READ);
+		con->ssl_state = tls_st_connected;
 	}
 	else
 	{
@@ -96,12 +98,14 @@ ssize_t net_con_ssl_connect(struct net_connection* con)
 {
 	uhub_assert(con);
 
+	con->ssl_state = tls_st_connecting;
 	ssize_t ret = SSL_connect(con->ssl);
 #ifdef NETWORK_DUMP_DEBUG
 	LOG_PROTO("SSL_connect() ret=%d", ret);
 #endif
 	if (ret > 0)
 	{
+		con->ssl_state = tls_st_connected;
 		net_con_update(con, NET_EVENT_READ);
 	}
 	else
@@ -136,28 +140,42 @@ ssize_t net_con_ssl_handshake(struct net_connection* con, enum net_con_ssl_mode
 
 ssize_t net_con_send(struct net_connection* con, const void* buf, size_t len)
 {
-	int ret = net_send(con->sd, buf, len, UHUB_SEND_SIGNAL);
-	if (ret == -1)
+	int ret;
+#ifdef SSL_SUPPORT
+	if (!con->ssl)
 	{
-		if (net_error() == EWOULDBLOCK || net_error() == EINTR)
-			return 0;
-		return -1;
+#endif
+		ret = net_send(con->sd, buf, len, UHUB_SEND_SIGNAL);
+		if (ret == -1)
+		{
+			if (net_error() == EWOULDBLOCK || net_error() == EINTR)
+				return 0;
+			return -1;
+		}
+#ifdef SSL_SUPPORT
 	}
+	else
+	{
+		con->write_len = len;
+		ret = SSL_write(con->ssl, buf, len);
+		LOG_PROTO("SSL_write(con=%p, buf=%p, len=" PRINTF_SIZE_T ") => %d", con, buf, len, ret);
+		if (ret <= 0)
+		{
+			return -handle_openssl_error(con, ret);
+		}
+	}
+#endif
 	return ret;
 }
 
 ssize_t net_con_recv(struct net_connection* con, void* buf, size_t len)
 {
-	uhub_assert(con);
-
+	int ret;
 #ifdef SSL_SUPPORT
 	if (!net_con_is_ssl(con))
 	{
 #endif
-		int ret = net_recv(con->sd, buf, len, 0);
-#ifdef NETWORK_DUMP_DEBUG
-		LOG_PROTO("net_recv: ret=%d", ret);
-#endif
+		ret = net_recv(con->sd, buf, len, 0);
 		if (ret == -1)
 		{
 			if (net_error() == EWOULDBLOCK || net_error() == EINTR)
@@ -168,16 +186,15 @@ ssize_t net_con_recv(struct net_connection* con, void* buf, size_t len)
 		{
 			return -1;
 		}
-
-		return ret;
 #ifdef SSL_SUPPORT
 	}
 	else
 	{
-		int ret = SSL_read(con->ssl, buf, len);
-#ifdef NETWORK_DUMP_DEBUG
-		LOG_PROTO("net_recv: ret=%d", ret);
-#endif
+		if (con->ssl_state == tls_st_error)
+			return -1;
+
+		ret = SSL_read(con->ssl, buf, len);
+		LOG_PROTO("SSL_read(con=%p, buf=%p, len=" PRINTF_SIZE_T ") => %d", con, buf, len, ret);
 		if (ret > 0)
 		{
 			net_con_update(con, NET_EVENT_READ);
@@ -186,9 +203,9 @@ ssize_t net_con_recv(struct net_connection* con, void* buf, size_t len)
 		{
 			return -handle_openssl_error(con, ret);
 		}
-		return ret;
 	}
 #endif
+	return ret;
 }
 
 ssize_t net_con_peek(struct net_connection* con, void* buf, size_t len)
@@ -234,7 +251,7 @@ void* net_con_get_ptr(struct net_connection* con)
 
 void net_con_callback(struct net_connection* con, int events)
 {
-	if ((con->flags & NET_CLEANUP))
+	if (con->flags & NET_CLEANUP)
 		return;
 
 	if (events == NET_EVENT_TIMEOUT)
@@ -254,27 +271,47 @@ void net_con_callback(struct net_connection* con, int events)
 	else
 	{
 #ifdef NETWORK_DUMP_DEBUG
-		LOG_PROTO("net_con_event: events=%d, con=%p", ev, con);
+		LOG_PROTO("net_con_event: events=%d, con=%p, state=%d", events, con, con->ssl_state);
 #endif
-		if (events == NET_EVENT_READ && con->flags & NET_WANT_SSL_READ)
+		switch (con->ssl_state)
 		{
-			con->callback(con, NET_EVENT_WRITE, con->ptr);
-		}
-		else if (events == NET_EVENT_WRITE && con->flags & NET_WANT_SSL_WRITE)
-		{
-			con->callback(con, events & NET_EVENT_READ, con->ptr);
-		}
-		if (con->flags & NET_WANT_SSL_ACCEPT)
-		{
-			net_con_ssl_accept(con);
-		}
-		else if (con->flags & NET_WANT_SSL_CONNECT)
-		{
-			net_con_ssl_connect(con);
-		}
-		else
-		{
-			con->callback(con, events, con->ptr);
+			case tls_st_none:
+				con->callback(con, events, con->ptr);
+				break;
+
+			case tls_st_accepting:
+				if (net_con_ssl_accept(con) < 0)
+				{
+					con->callback(con, NET_EVENT_READ, con->ptr);
+				}
+				break;
+
+			case tls_st_connecting:
+				if (net_con_ssl_connect(con) < 0)
+				{
+					con->callback(con, NET_EVENT_READ, con->ptr);
+				}
+				break;
+
+			case tls_st_connected:
+				LOG_PROTO("tls_st_connected, events=%s%s, ssl_flags=%s%s", (events & NET_EVENT_READ ? "R" : ""), (events & NET_EVENT_WRITE ? "W" : ""), con->flags & NET_WANT_SSL_READ ? "R" : "", con->flags & NET_WANT_SSL_WRITE ? "W" : "");
+				if (events & NET_EVENT_WRITE && con->flags & NET_WANT_SSL_READ)
+				{
+					con->callback(con, events & NET_EVENT_READ, con->ptr);
+					return;
+				}
+
+				if (events & NET_EVENT_READ && con->flags & NET_WANT_SSL_WRITE)
+				{
+					con->callback(con, events & NET_EVENT_READ, con->ptr);
+					return;
+				}
+
+				con->callback(con, events, con->ptr);
+				break;
+
+			case tls_st_disconnecting:
+				return;
 		}
 	}
 #endif

From b2e7a2848fa25f0266f88aaba0ac472c9c641b92 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sat, 23 Jan 2010 00:03:45 +0100
Subject: [PATCH 15/21] Optimize epoll to never modify the epoll mask unless it
 actually changed.

---
 src/network/epoll.c | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/network/epoll.c b/src/network/epoll.c
index 00ac494..0726b77 100644
--- a/src/network/epoll.c
+++ b/src/network/epoll.c
@@ -186,10 +186,14 @@ void net_con_reinitialize(struct net_connection* con, net_connection_cb callback
 void net_con_update(struct net_connection* con_, int events)
 {
 	struct net_connection_epoll* con = (struct net_connection_epoll*) con_;
-	con->ev.events = 0;
-	if (events & NET_EVENT_READ)  con->ev.events |= EPOLLIN;
-	if (events & NET_EVENT_WRITE) con->ev.events |= EPOLLOUT;
+	int newev = 0;
+	if (events & NET_EVENT_READ)  newev |= EPOLLIN;
+	if (events & NET_EVENT_WRITE) newev |= EPOLLOUT;
 
+	if (newev == con->ev.events)
+		return;
+
+	con->ev.events = newev;
 	if (epoll_ctl(g_backend->epfd, EPOLL_CTL_MOD, con->sd, &con->ev) == -1)
 	{
 		LOG_TRACE("epoll_ctl() modify failed.");

From c670d13369dfa57a648f9cf43b3d814cbfc78499 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sat, 23 Jan 2010 00:20:48 +0100
Subject: [PATCH 16/21] Make sure we shutdown SSL connections when an error
 occurs.

---
 GNUmakefile              | 2 +-
 src/network/connection.c | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/GNUmakefile b/GNUmakefile
index fcea83e..a6618db 100644
--- a/GNUmakefile
+++ b/GNUmakefile
@@ -8,7 +8,7 @@ LD            := $(CC)
 MV            := mv
 RANLIB        := ranlib
 CFLAGS        += -pipe -Wall
-USE_SSL       ?= NO
+USE_SSL       ?= YES
 USE_BIGENDIAN ?= AUTO
 BITS          ?= AUTO
 SILENT        ?= YES
diff --git a/src/network/connection.c b/src/network/connection.c
index 59c3795..f53f0b2 100644
--- a/src/network/connection.c
+++ b/src/network/connection.c
@@ -279,6 +279,10 @@ void net_con_callback(struct net_connection* con, int events)
 				con->callback(con, events, con->ptr);
 				break;
 
+			case tls_st_error:
+				con->callback(con, NET_EVENT_READ, con->ptr);
+				break;
+
 			case tls_st_accepting:
 				if (net_con_ssl_accept(con) < 0)
 				{

From 304ecda16ae402758d8d1568cc9d6a79cc043747 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sat, 23 Jan 2010 00:43:38 +0100
Subject: [PATCH 17/21] Enable the statistics timer again, so that !stats
 provide up to date network statistics.

---
 src/core/usermanager.c | 20 ++++++++++++++++----
 src/core/usermanager.h |  1 +
 src/network/epoll.c    |  7 ++++---
 src/network/select.c   |  6 +++---
 4 files changed, 24 insertions(+), 10 deletions(-)

diff --git a/src/core/usermanager.c b/src/core/usermanager.c
index 3c0eb36..4daf4ab 100644
--- a/src/core/usermanager.c
+++ b/src/core/usermanager.c
@@ -19,8 +19,6 @@
 
 #include "uhub.h"
 
-#define USERMANAGER_TIMER
-
 /*
  * This callback function is used to clear user objects from the userlist.
  * Should only be used in uman_shutdown().
@@ -40,7 +38,6 @@ static void clear_user_list_callback(void* ptr)
 	}
 }
 
-
 void uman_update_stats(struct hub_info* hub)
 {
 	const int factor = TIMEOUT_STATS;
@@ -58,7 +55,6 @@ void uman_update_stats(struct hub_info* hub)
 	net_stats_reset();
 }
 
-
 void uman_print_stats(struct hub_info* hub)
 {
 	LOG_INFO("Statistics  users=" PRINTF_SIZE_T " (peak_users=" PRINTF_SIZE_T "), net_tx=%d KB/s, net_rx=%d KB/s (peak_tx=%d KB/s, peak_rx=%d KB/s)",
@@ -70,6 +66,13 @@ void uman_print_stats(struct hub_info* hub)
 		(int) hub->stats.net_rx_peak / 1024);
 }
 
+static void timer_statistics(struct timeout_evt* t)
+{
+	struct hub_info* hub = (struct hub_info*) t->ptr;
+	uman_update_stats(hub);
+	timeout_queue_reschedule(net_backend_get_timeout_queue(), hub->users->timeout, TIMEOUT_STATS);
+}
+
 int uman_init(struct hub_info* hub)
 {
 	struct hub_user_manager* users = NULL;
@@ -90,6 +93,10 @@ int uman_init(struct hub_info* hub)
 		return -1;
 	}
 
+	users->timeout = hub_malloc_zero(sizeof(struct timeout_evt));
+	timeout_evt_initialize(users->timeout, timer_statistics, hub);
+	timeout_queue_insert(net_backend_get_timeout_queue(), users->timeout, TIMEOUT_STATS);
+
 	hub->users = users;
 	return 0;
 }
@@ -100,6 +107,9 @@ int uman_shutdown(struct hub_info* hub)
 	if (!hub || !hub->users)
 		return -1;
 
+	timeout_queue_remove(net_backend_get_timeout_queue(), hub->users->timeout);
+	hub_free(hub->users->timeout);
+
 	if (hub->users->list)
 	{
 		list_clear(hub->users->list, &clear_user_list_callback);
@@ -108,6 +118,8 @@ int uman_shutdown(struct hub_info* hub)
 	sid_pool_destroy(hub->users->sids);
 	hub_free(hub->users);
 	hub->users = 0;
+
+
 	return 0;
 }
 
diff --git a/src/core/usermanager.h b/src/core/usermanager.h
index af59460..7cc5190 100644
--- a/src/core/usermanager.h
+++ b/src/core/usermanager.h
@@ -28,6 +28,7 @@ struct hub_user_manager
 	uint64_t shared_size;           /**<< "The total number of shared bytes among fully connected users." */
 	uint64_t shared_files;          /**<< "The total number of shared files among fully connected users." */
 	struct linked_list* list;       /**<< "Contains all logged in users" */
+	struct timeout_evt* timeout;    /**<< "Timeout handler for statistics" */
 };
 
 /**
diff --git a/src/network/epoll.c b/src/network/epoll.c
index 0726b77..cfaf5e1 100644
--- a/src/network/epoll.c
+++ b/src/network/epoll.c
@@ -110,15 +110,16 @@ int net_backend_process()
 	size_t secs = timeout_queue_get_next_timeout(&g_backend->timeout_queue, g_backend->now);
 	LOG_TRACE("epoll_wait: fd=%d, events=%x, max=%zu, seconds=%d", g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER), (int) secs);
 	int res = epoll_wait(g_backend->epfd, g_backend->events, MIN(g_backend->num, EPOLL_EVBUFFER), secs * 1000);
+
+	g_backend->now = time(0);
+	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
+
 	if (res == -1)
 	{
 		LOG_WARN("epoll_wait returned -1");
 		return 0;
 	}
 
-	g_backend->now = time(0);
-	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
-
 	for (n = 0; n < res; n++)
 	{
 		struct net_connection_epoll* con = (struct net_connection_epoll*) g_backend->events[n].data.ptr;
diff --git a/src/network/select.c b/src/network/select.c
index 872ad24..9f217b9 100644
--- a/src/network/select.c
+++ b/src/network/select.c
@@ -117,15 +117,15 @@ int net_backend_process()
 	}
 
 	int res = select(maxfd+1, &g_backend->rfds, &g_backend->wfds, 0, &tval);
+	g_backend->now = time(0);
+	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
+
 	if (res == -1)
 	{
 		LOG_WARN("select returned -1");
 		return 0;
 	}
 
-	g_backend->now = time(0);
-	timeout_queue_process(&g_backend->timeout_queue, g_backend->now);
-
 	for (n = 0, found = 0; found < res && n < (maxfd+1); n++)
 	{
 		struct net_connection_select* con = g_backend->conns[n];

From 92c448b855dbef710a58680896eb561e4296366f Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sat, 23 Jan 2010 01:09:00 +0100
Subject: [PATCH 18/21] Dont use SSL by default.

---
 GNUmakefile | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/GNUmakefile b/GNUmakefile
index a6618db..fcea83e 100644
--- a/GNUmakefile
+++ b/GNUmakefile
@@ -8,7 +8,7 @@ LD            := $(CC)
 MV            := mv
 RANLIB        := ranlib
 CFLAGS        += -pipe -Wall
-USE_SSL       ?= YES
+USE_SSL       ?= NO
 USE_BIGENDIAN ?= AUTO
 BITS          ?= AUTO
 SILENT        ?= YES

From bfc7c184a7a12ed11823b366bfa5572ed8fc5c32 Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sat, 23 Jan 2010 14:59:51 +0100
Subject: [PATCH 19/21] Fix release build compile warnings.

---
 src/network/network.c | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/network/network.c b/src/network/network.c
index b8b2e1f..39cf784 100644
--- a/src/network/network.c
+++ b/src/network/network.c
@@ -376,7 +376,7 @@ int net_accept(int fd, struct ip_addr_encap* ipaddr)
 		if (ipaddr)
 		{
 			memset(ipaddr, 0, sizeof(struct ip_addr_encap));
-			ipaddr->af = addr4->sin_family;
+			ipaddr->af = addr.ss_family;;
 			if (ipaddr->af == AF_INET6)
 			{
 				char address[INET6_ADDRSTRLEN+1] = { 0, };
@@ -599,7 +599,7 @@ const char* net_get_peer_address(int fd)
 	
 	if (getpeername(fd, (struct sockaddr*) name, &namelen) != -1)
 	{
-		int af = name4->sin_family;
+		int af = storage.ss_family;
 		if (af == AF_INET6)
 		{
 			net_address_to_string(af, (void*) &name6->sin6_addr, address, INET6_ADDRSTRLEN);
@@ -637,7 +637,7 @@ const char* net_get_local_address(int fd)
 
 	if (getsockname(fd, (struct sockaddr*) name, &namelen) != -1)
 	{
-		int af = name4->sin_family;
+		int af = storage.ss_family;
 		if (af == AF_INET6)
 		{
 			net_address_to_string(af, (void*) &name6->sin6_addr, address, INET6_ADDRSTRLEN);

From 59f67f9e1780975a133a3086b086d8ead9a4f6da Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Sun, 24 Jan 2010 23:38:25 +0100
Subject: [PATCH 20/21] Updated ChangeLog and README.

---
 ChangeLog | 12 ++++++++++++
 README    |  2 +-
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/ChangeLog b/ChangeLog
index 6ceb293..3e9a0f0 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,15 @@
+0.3.0:
+- More user commands: ban, broadcast, mute, rules, history, myip, whoip, log
+- Experimental SSL support
+- Large rewrite of the network stack in order to support SSL.
+- Added rule file for defining hub rules.
+- Many crash fixes and other important bug fixes.
+- Optimizations: O(1) timeout scheduler
+- New sid allocation code.
+- Added configurable server_listen_backlog (default 50).
+- Added init.d scripts for RedHat/CentOS
+
+
 0.2.8:
 - Fix bug #13: getsockname() failure, use sockaddr from accept() instead.
 - Fix bug #10: Improve logging, ensure logs are machine readable.
diff --git a/README b/README
index 4fe04e1..3e5583d 100644
--- a/README
+++ b/README
@@ -1,5 +1,5 @@
 Welcome and thanks for downloading uHub, a high performance ADC p2p hub.
 
 For the official documentation, bugs and other information, please visit:
-http://www.extatic.org/uhub/
+http://www.uhub.org/
 

From e3cf41cb9766bd6897e2a90b5b2b0a144b5ba0ae Mon Sep 17 00:00:00 2001
From: Jan Vidar Krey <janvidar@extatic.org>
Date: Mon, 25 Jan 2010 14:23:22 +0100
Subject: [PATCH 21/21] BSD/OSX compile fix.

---
 src/network/select.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/network/select.c b/src/network/select.c
index 9f217b9..0e32653 100644
--- a/src/network/select.c
+++ b/src/network/select.c
@@ -101,8 +101,8 @@ int net_backend_process()
 	FD_ZERO(&g_backend->wfds);
 
 	size_t secs = timeout_queue_get_next_timeout(&g_backend->timeout_queue, g_backend->now);
-	tval.tv_secs = secs;
-	tval.tv_usecs = 0;
+	tval.tv_sec = secs;
+	tval.tv_usec = 0;
 
 	for (n = 0, found = 0; found < g_backend->num && n < g_backend->max; n++)
 	{