#include "dccp_recv.cmdline.h"
-/** the size of the output buffer */
-#define DCCP_BUFSIZE 40960
-
/**
* data specific to the dccp receiver
*
if (pdd && pdd->fd > 0)
close(pdd->fd);
- free(rn->buf);
- rn->buf = NULL;
free(rn->private_data);
rn->private_data = NULL;
}
ret = mark_fd_nonblocking(fd);
if (ret < 0)
goto err;
- rn->buf = para_calloc(DCCP_BUFSIZE);
rn->private_data = pdd = para_calloc(sizeof(struct private_dccp_recv_data));
pdd->btrp = btr_pool_new("dccp_recv", 320 * 1024);
pdd->fd = fd;
return;
if (!FD_ISSET(pdd->fd, &s->rfds))
return; /* nothing to do */
- if (rn->loaded >= DCCP_BUFSIZE) {
- t->error = -E_DCCP_OVERRUN;
- return;
- }
ret = -E_DCCP_OVERRUN;
sz = btr_pool_get_buffer(pdd->btrp, &buf);
if (sz == 0)