[BACK]Return to srv.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

Diff for /libaitrpc/src/srv.c between versions 1.21.2.3 and 1.22

version 1.21.2.3, 2013/11/15 00:21:46 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 448  txUDPPacket(sched_task_t *task) Line 448  txUDPPacket(sched_task_t *task)
         rpc_func_t *f = NULL;          rpc_func_t *f = NULL;
         u_char *buf = AIT_GET_BUF(&c->cli_buf);          u_char *buf = AIT_GET_BUF(&c->cli_buf);
         struct tagRPCCall *rpc = (struct tagRPCCall*) buf;          struct tagRPCCall *rpc = (struct tagRPCCall*) buf;
        int ret, wlen = sizeof(struct tagRPCCall);        int ret, estlen, wlen = sizeof(struct tagRPCCall);
         struct timespec ts = { DEF_RPC_TIMEOUT, 0 };          struct timespec ts = { DEF_RPC_TIMEOUT, 0 };
         struct pollfd pfd;          struct pollfd pfd;
   
Line 464  txUDPPacket(sched_task_t *task) Line 464  txUDPPacket(sched_task_t *task)
                         rpc->call_rep.ret = RPC_ERROR(-1);                          rpc->call_rep.ret = RPC_ERROR(-1);
                         rpc->call_rep.eno = RPC_ERROR(rpc_Errno);                          rpc->call_rep.eno = RPC_ERROR(rpc_Errno);
                 } else {                  } else {
                           /* calc estimated length */
                           estlen = ait_resideVars(RPC_RETVARS(c)) + wlen;
                           if (estlen > AIT_LEN(&c->cli_buf))
                                   AIT_RE_BUF(&c->cli_buf, estlen);
                           buf = AIT_GET_BUF(&c->cli_buf);
                           rpc = (struct tagRPCCall*) buf;
   
                         rpc->call_argc = htons(array_Size(RPC_RETVARS(c)));                          rpc->call_argc = htons(array_Size(RPC_RETVARS(c)));
                         /* Go Encapsulate variables */                          /* Go Encapsulate variables */
                         ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen,                           ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, 
Line 495  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 568  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;
Removed from v.1.21.2.3  
changed lines
  Added in v.1.22

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>