X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=send_common.c;h=354c9ed509deddc14f4528ce318e0d1ad90a8b7e;hp=e786f996ad3b85218d9953a01fee6a86f34b6de4;hb=d0d27cfa56d05eaa0e5567c75adfe606eab2957e;hpb=a24d175e6d093d6d9f6e583c3026e45924bad621 diff --git a/send_common.c b/send_common.c index e786f996..354c9ed5 100644 --- a/send_common.c +++ b/send_common.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2011 Andre Noll + * Copyright (C) 2005-2012 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -22,6 +22,7 @@ #include "send.h" #include "close_on_fork.h" #include "chunk_queue.h" +#include "sched.h" #include "vss.h" /** Clients will be kicked if there are more than that many bytes pending. */ @@ -112,7 +113,7 @@ int send_queued_chunks(int fd, struct chunk_queue *cq) int ret; cq_get(qc, &buf, &len); - ret = write_nonblock(fd, buf, len); + ret = xwrite(fd, buf, len); if (ret < 0) return ret; cq_update(cq, ret);