X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=dccp_send.c;h=128d45b74c271aaeca10abacb5ef50ef197b55a6;hp=3592a2827a70b2441bc51a1bd6cbe7e1181d7374;hb=24152cd83d4165d844ae93a234b1762ed98dd3ab;hpb=32f366d7a0c5c95fdada5355b71c12c4ed2cae92 diff --git a/dccp_send.c b/dccp_send.c index 3592a282..128d45b7 100644 --- a/dccp_send.c +++ b/dccp_send.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2006 Andre Noll + * Copyright (C) 2006-2007 Andre Noll * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -26,7 +26,7 @@ #include "server.h" #include "net.h" #include "list.h" -#include "afs.h" +#include "vss.h" #include "send.h" #include "dccp.h" #include "error.h" @@ -76,7 +76,7 @@ static void dccp_post_select(fd_set *rfds, __a_unused fd_set *wfds) } PARA_NOTICE_LOG("connection from %s\n", inet_ntoa(dc->addr.sin_addr)); dc->fd = ret; - list_add(&dc->node, &clients); + para_list_add(&dc->node, &clients); add_close_on_fork_list(dc->fd); mark_fd_nonblock(dc->fd); } @@ -132,7 +132,7 @@ again: if (ret < 0) { if (errno != EAGAIN || !retries++ > DCCP_RETRIES) goto err_out; - PARA_DEBUG_LOG("EAGAIN #%d@%d/%d\n", retries, written, len); + PARA_DEBUG_LOG("EAGAIN #%d@%zd/%zd\n", retries, written, len); goto again; } retries = 0; @@ -165,7 +165,7 @@ static void dccp_send(long unsigned current_chunk, if (!ret) continue; if (!dc->header_sent && current_chunk) { - header_buf = afs_get_header(&header_len); + header_buf = vss_get_header(&header_len); if (header_buf && header_len > 0) { ret = dccp_write(dc->fd, header_buf, header_len); if (ret != header_len) {