[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.26.2.8 and 1.26.2.10

version 1.26.2.8, 2015/06/29 22:29:26 version 1.26.2.10, 2015/06/30 14:11:55
Line 70  static void *rxEXTPacket(sched_task_t *); Line 70  static void *rxEXTPacket(sched_task_t *);
 static void *txEXTPacket(sched_task_t *);  static void *txEXTPacket(sched_task_t *);
   
 static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = {  static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = {
        { acceptClients, closeClient, rxPacket, txPacket },     /* SOCK_STREAM */        { acceptClients, closeClient, rxPacket, txPacket },             /* SOCK_STREAM */
        { acceptClients, closeClient, rxPacket, txPacket },     /* SOCK_STREAM */        { acceptClients, closeClient, rxPacket, txPacket },             /* SOCK_STREAM */
        { rxUDPPacket, freeClient, rxUDPPacket, txUDPPacket },        /* SOCK_DGRAM */        { rxUDPPacket, freeClient, NULL /*rxUDPPacket*/, txUDPPacket },        /* SOCK_DGRAM */
        { rxRAWPacket, freeClient, rxRAWPacket, txRAWPacket },        /* SOCK_RAW */        { rxRAWPacket, freeClient, NULL /*rxRAWPacket*/, txRAWPacket },        /* SOCK_RAW */
        { rxBPFPacket, freeClient, rxBPFPacket, txBPFPacket },        /* SOCK_BPF */        { rxBPFPacket, freeClient, NULL /*rxBPFPacket*/, txBPFPacket },        /* SOCK_BPF */
        { rxEXTPacket, freeClient, rxEXTPacket, txEXTPacket } /* SOCK_EXT */        { rxEXTPacket, freeClient, NULL /*rxEXTPacket*/, txEXTPacket } /* SOCK_EXT */
 };  };
   
 /* Global Signal Argument when kqueue support disabled */  /* Global Signal Argument when kqueue support disabled */
Line 313  rxPacket(sched_task_t *task) Line 313  rxPacket(sched_task_t *task)
         u_short crc;          u_short crc;
 #endif  #endif
         u_char *buf = AIT_GET_BUF(&c->cli_buf);          u_char *buf = AIT_GET_BUF(&c->cli_buf);
           u_char b[sizeof(struct tagRPCCall)];
         struct tagRPCCall *rpc = (struct tagRPCCall*) buf;          struct tagRPCCall *rpc = (struct tagRPCCall*) buf;
 #ifdef TCP_SESSION_TIMEOUT  #ifdef TCP_SESSION_TIMEOUT
         struct timespec ts = { DEF_RPC_TIMEOUT, 0 };          struct timespec ts = { DEF_RPC_TIMEOUT, 0 };
Line 322  rxPacket(sched_task_t *task) Line 323  rxPacket(sched_task_t *task)
                          TASK_ARG(task), ts, TASK_ARG(task), 0);                           TASK_ARG(task), ts, TASK_ARG(task), 0);
 #endif  #endif
   
           /* prepare rx */
           len = recv(TASK_FD(task), b, sizeof b, MSG_PEEK);
           if (len == sizeof b)
                   rlen = ntohl(((struct tagRPCCall*) b)->call_len);
   
         rlen = recv(TASK_FD(task), buf, rlen, 0);          rlen = recv(TASK_FD(task), buf, rlen, 0);
         if (rlen == -1) {          if (rlen == -1) {
                 /* close connection */                  /* close connection */
Line 613  txRAWPacket(sched_task_t *task) Line 619  txRAWPacket(sched_task_t *task)
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         if (ret == -1) {                          if (ret == -1) {
                                 rpc_SetErr(EBADRPC, "Prepare RPC packet failed");                                  rpc_SetErr(EBADRPC, "Prepare RPC packet failed");
   
                                 rpc->call_argc ^= rpc->call_argc;                                  rpc->call_argc ^= rpc->call_argc;
                                 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);
Removed from v.1.26.2.8  
changed lines
  Added in v.1.26.2.10

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