version 1.6.2.2, 2014/02/21 09:47:00
|
version 1.6.2.3, 2014/02/24 14:38:47
|
Line 45 SUCH DAMAGE.
|
Line 45 SUCH DAMAGE.
|
*/ |
*/ |
#include "global.h" |
#include "global.h" |
#include "exec.h" |
#include "exec.h" |
|
#include "buf.h" |
#include "srv.h" |
#include "srv.h" |
|
|
|
|
Line 55 timeoutSession(sched_task_t *task)
|
Line 56 timeoutSession(sched_task_t *task)
|
|
|
ETRACE(); |
ETRACE(); |
|
|
|
if (bf) |
|
flushBuffer(cli.fd); |
|
|
/* drop session */ |
/* drop session */ |
if (cli.fd > 2) |
if (cli.fd > 2) |
close(cli.fd); |
close(cli.fd); |
Line 331 RQ(sched_task_t *task)
|
Line 335 RQ(sched_task_t *task)
|
code = htons(3); |
code = htons(3); |
else if (errno == EEXIST) |
else if (errno == EEXIST) |
code = htons(6); |
code = htons(6); |
|
else if (errno == ENOENT) |
|
code = htons(1); |
else |
else |
code = htons(0); |
code = htons(0); |
ESYSERR(0); |
ESYSERR(0); |
Line 467 DATA(sched_task_t *task)
|
Line 473 DATA(sched_task_t *task)
|
|
|
EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len); |
EVERBOSE(3, "DATA:: seq=%hu; len=%d", cli.seq, len); |
|
|
len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); | if (!bf) |
| len = pwrite(cli.fd, RPACK_NEXT(pkt), len, (cli.seq - 1) * cli.siz); |
| else |
| len = bfwrite(cli.fd, RPACK_NEXT(pkt), len); |
if (len == -1) { |
if (len == -1) { |
ESYSERR(0); |
ESYSERR(0); |
code = htons(3); |
code = htons(3); |