X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=9bfe65f68a7bc7634c5ba581589e95c96c434e18;hp=546056a04282b9b87c27b9a4cfb811fd005f761d;hb=8cec3d1edb26b4861e2b5bdbb9f70241cdd7f03b;hpb=8b2c02c8d6255583982e767374d39375b3380c4d

diff --git a/dccp_send.c b/dccp_send.c
index 546056a0..9bfe65f6 100644
--- a/dccp_send.c
+++ b/dccp_send.c
@@ -152,25 +152,25 @@ static void dccp_send(long unsigned current_chunk,
 			continue;
 		if (!dc->header_sent && current_chunk) {
 			header_buf = afs_get_header(&header_len);
-			if (!header_buf || header_len <= 0)
-				continue; /* header not yet available */
-			ret = dccp_write(dc->fd, header_buf, header_len);
-			if (ret != header_len) {
-				int err = errno;
-				PARA_ERROR_LOG("header write: %d/%d (%s)\n",
-					ret, header_len, ret < 0?
-					strerror(err) : "");
-				dccp_shutdown_client(dc);
-				continue;
+			if (header_buf && header_len > 0) {
+				ret = dccp_write(dc->fd, header_buf, header_len);
+				if (ret != header_len) {
+					int err = errno;
+					PARA_ERROR_LOG("header write: %d/%d (%s)\n",
+						ret, header_len, ret < 0?
+						strerror(err) : "");
+					dccp_shutdown_client(dc);
+					continue;
+				}
+				dc->header_sent = 1;
+				ret = write_ok(dc->fd);
+				if (ret < 0) {
+					dccp_shutdown_client(dc);
+					continue;
+				}
+				if (!ret)
+					continue;
 			}
-			dc->header_sent = 1;
-			ret = write_ok(dc->fd);
-			if (ret < 0) {
-				dccp_shutdown_client(dc);
-				continue;
-			}
-			if (!ret)
-				continue;
 		}
 //		PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd);
 		ret = dccp_write(dc->fd, buf, len);