X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=887801a92f3a30128928e95e5232d7c39d4a3b59;hp=b1e2f48da54d57662fab5b8a18a2190044e77790;hb=8268a10edbdbb77d9e1b82a27dcc5b2b465412d1;hpb=87e49928cf48ae6368e65a27cfe1a62e33a19e48

diff --git a/dccp_send.c b/dccp_send.c
index b1e2f48d..887801a9 100644
--- a/dccp_send.c
+++ b/dccp_send.c
@@ -32,7 +32,6 @@
 /** the list of connected clients **/
 static struct list_head clients;
 static int listen_fd = -1;
-static struct sender *self;
 
 /** Maximal number of bytes in a chunk queue. */
 #define DCCP_MAX_PENDING_BYTES 40000
@@ -189,9 +188,6 @@ static void dccp_send(long unsigned current_chunk,
 	int ret;
 	char *header_buf;
 
-	if (listen_fd < 0 || !len)
-		return;
-
 	list_for_each_entry_safe(dc, tmp, &clients, node) {
 		if (!dc->header_sent && current_chunk) {
 			size_t header_len;
@@ -207,6 +203,8 @@ static void dccp_send(long unsigned current_chunk,
 			dccp_shutdown_client(dc);
 			continue;
 		}
+		if (!len)
+			continue;
 //		PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd);
 		ret = dccp_write(dc->fd, buf, len);
 		if (ret < 0) {
@@ -270,7 +268,6 @@ void dccp_send_init(struct sender *s)
 	s->client_cmds[SENDER_ALLOW] = NULL;
 	s->client_cmds[SENDER_ADD] = NULL;
 	s->client_cmds[SENDER_DELETE] = NULL;
-	self = s;
 	ret = dccp_open();
 	if (ret < 0)
 		PARA_ERROR_LOG("%s\n", para_strerror(-ret));