[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.4 and 1.26.2.5

version 1.26.2.4, 2015/06/24 23:02:28 version 1.26.2.5, 2015/06/25 22:39:05
Line 212  txPacket(sched_task_t *task) Line 212  txPacket(sched_task_t *task)
                         /* 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, 
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         /* Free return values */  
                         ait_freeVars(&c->cli_vars);  
                         if (ret == -1) {                          if (ret == -1) {
                                 rpc_SetErr(EBADRPC, "Prepare RPC packet failed");                                  rpc_SetErr(EBADRPC, "Prepare RPC packet failed");
   
Line 225  txPacket(sched_task_t *task) Line 223  txPacket(sched_task_t *task)
                 }                  }
         }          }
   
           /* Free return values */
           ait_freeVars(&c->cli_vars);
   
         rpc->call_len = htonl(wlen);          rpc->call_len = htonl(wlen);
         rpc->call_io = RPC_ACK;          rpc->call_io = RPC_ACK;
   
Line 303  execCall(sched_task_t *task) Line 304  execCall(sched_task_t *task)
                                 rpc->call_rep.eno = RPC_ERROR(rpc_Errno);                                  rpc->call_rep.eno = RPC_ERROR(rpc_Errno);
                         }                          }
                         rpc->call_argc ^= rpc->call_argc;                          rpc->call_argc ^= rpc->call_argc;
                           ait_freeVars(&c->cli_vars);
                 } else {                  } else {
                         rpc->call_rep.eno ^= rpc->call_rep.eno;                          rpc->call_rep.eno ^= rpc->call_rep.eno;
                         if (argc) {                          if (argc) {
Line 501  txUDPPacket(sched_task_t *task) Line 503  txUDPPacket(sched_task_t *task)
                         /* 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, 
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         /* Free return values */  
                         ait_freeVars(&c->cli_vars);  
                         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;
Line 513  txUDPPacket(sched_task_t *task) Line 513  txUDPPacket(sched_task_t *task)
                 }                  }
         }          }
   
           /* Free return values */
           ait_freeVars(&c->cli_vars);
   
         rpc->call_len = htonl(wlen);          rpc->call_len = htonl(wlen);
         rpc->call_io = RPC_ACK;          rpc->call_io = RPC_ACK;
   
Line 693  txRAWPacket(sched_task_t *task) Line 696  txRAWPacket(sched_task_t *task)
                         /* 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, 
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         /* Free return values */  
                         ait_freeVars(&c->cli_vars);  
                         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;
Line 705  txRAWPacket(sched_task_t *task) Line 706  txRAWPacket(sched_task_t *task)
                 }                  }
         }          }
   
           /* Free return values */
           ait_freeVars(&c->cli_vars);
   
         rpc->call_len = htonl(wlen);          rpc->call_len = htonl(wlen);
         rpc->call_io = RPC_ACK;          rpc->call_io = RPC_ACK;
   
Line 866  txBPFPacket(sched_task_t *task) Line 870  txBPFPacket(sched_task_t *task)
                         /* 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, 
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         /* Free return values */  
                         ait_freeVars(&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;
Line 878  txBPFPacket(sched_task_t *task) Line 880  txBPFPacket(sched_task_t *task)
                 }                  }
         }          }
   
           /* Free return values */
           ait_freeVars(&RPC_RETVARS(c));
   
         rpc->call_len = htonl(wlen);          rpc->call_len = htonl(wlen);
         rpc->call_io = RPC_ACK;          rpc->call_io = RPC_ACK;
   
Line 1036  txEXTPacket(sched_task_t *task) Line 1041  txEXTPacket(sched_task_t *task)
                         /* 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, 
                                         RPC_RETVARS(c));                                          RPC_RETVARS(c));
                         /* Free return values */  
                         ait_freeVars(&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;
Line 1047  txEXTPacket(sched_task_t *task) Line 1050  txEXTPacket(sched_task_t *task)
                                 wlen += ret;                                  wlen += ret;
                 }                  }
         }          }
   
           /* Free return values */
           ait_freeVars(&RPC_RETVARS(c));
   
         rpc->call_len = htonl(wlen);          rpc->call_len = htonl(wlen);
         rpc->call_io = RPC_ACK;          rpc->call_io = RPC_ACK;
Removed from v.1.26.2.4  
changed lines
  Added in v.1.26.2.5

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