|
|
| version 1.21.2.4, 2013/11/15 09:04:10 | version 1.22, 2013/11/15 09:55:53 |
|---|---|
| Line 223 txPacket(sched_task_t *task) | Line 223 txPacket(sched_task_t *task) |
| if (ret) | if (ret) |
| LOGERR; | LOGERR; |
| else | else |
| rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond"); | rpc_SetErr(ETIMEDOUT, "Timeout reached! Client not respond"); |
| /* close connection */ | /* close connection */ |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], |
| TASK_ARG(task), 0, NULL, 0); | TASK_ARG(task), 0, NULL, 0); |
| Line 346 rxPacket(sched_task_t *task) | Line 346 rxPacket(sched_task_t *task) |
| if (rlen) | if (rlen) |
| LOGERR; | LOGERR; |
| else | else |
| rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond"); | rpc_SetErr(ETIMEDOUT, "Timeout reached! Client not respond"); |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], |
| TASK_ARG(task), 0, NULL, 0); | TASK_ARG(task), 0, NULL, 0); |
| return NULL; | return NULL; |
| Line 502 txUDPPacket(sched_task_t *task) | Line 502 txUDPPacket(sched_task_t *task) |
| if (ret) | if (ret) |
| LOGERR; | LOGERR; |
| else | else |
| rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond"); | rpc_SetErr(ETIMEDOUT, "Timeout reached! Client not respond"); |
| /* close connection */ | /* close connection */ |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], |
| TASK_ARG(task), 0, NULL, 0); | TASK_ARG(task), 0, NULL, 0); |
| Line 510 txUDPPacket(sched_task_t *task) | Line 510 txUDPPacket(sched_task_t *task) |
| } | } |
| ret = sendto(TASK_FD(task), buf, MIN(wlen, s->srv_netbuf), MSG_NOSIGNAL, | ret = sendto(TASK_FD(task), buf, MIN(wlen, s->srv_netbuf), MSG_NOSIGNAL, |
| &c->cli_sa.sa, c->cli_sa.sa.sa_len); | &c->cli_sa.sa, c->cli_sa.sa.sa_len); |
| printf("wl=%d l=%d\n", wlen, ret); | |
| if (ret == -1) { | if (ret == -1) { |
| /* close connection */ | /* close connection */ |
| schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], | schedEvent(TASK_ROOT(task), cbProto[s->srv_proto][CB_CLOSECLIENT], |
| Line 576 rxUDPPacket(sched_task_t *task) | Line 575 rxUDPPacket(sched_task_t *task) |
| if (rlen) | if (rlen) |
| LOGERR; | LOGERR; |
| else | else |
| rpc_SetErr(ETIMEDOUT, "Timeout reached! Server not respond"); | rpc_SetErr(ETIMEDOUT, "Timeout reached! Client not respond"); |
| schedEvent(TASK_ROOT(task), cbProto[srv->srv_proto][CB_CLOSECLIENT], | schedEvent(TASK_ROOT(task), cbProto[srv->srv_proto][CB_CLOSECLIENT], |
| c, 0, NULL, 0); | c, 0, NULL, 0); |
| return NULL; | return NULL; |