[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.8.2.6 and 1.8.2.7

version 1.8.2.6, 2012/05/11 13:23:12 version 1.8.2.7, 2012/05/11 13:35:22
Line 94  txPacket(sched_task_t *task) Line 94  txPacket(sched_task_t *task)
         else if (ret != wlen)          else if (ret != wlen)
                 rpc_SetErr(EPROCUNAVAIL, "RPC reply, should be send %d bytes, "                  rpc_SetErr(EPROCUNAVAIL, "RPC reply, should be send %d bytes, "
                                 "really sended %d bytes", wlen, ret);                                  "really sended %d bytes", wlen, ret);
         else  
                 ioDEBUG(RPC_DEBUG_LEVEL, "Sended %d bytes", ret);  
   
         return NULL;          return NULL;
 }  }
Line 131  execCall(sched_task_t *task) Line 129  execCall(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 {
                 ioDEBUG(RPC_DEBUG_LEVEL, "RPC function %s from module %s",   
                                 AIT_GET_STR(&f->func_name), AIT_GET_LIKE(&f->func_file, char*));  
   
                 /* if client doesn't want reply */                  /* if client doesn't want reply */
                 argc = rpc->call_req.flags & RPC_NOREPLY;                  argc = rpc->call_req.flags & RPC_NOREPLY;
                 rpc->call_rep.ret = RPC_ERROR(rpc_srv_execCall(f, rpc, arr));                  rpc->call_rep.ret = RPC_ERROR(rpc_srv_execCall(f, rpc, arr));
Line 176  rxPacket(sched_task_t *task) Line 171  rxPacket(sched_task_t *task)
         } else if (!rlen) {     /* receive EOF */          } else if (!rlen) {     /* receive EOF */
                 s->srv_kill = s->srv_blob.state = kill;                  s->srv_kill = s->srv_blob.state = kill;
                 return NULL;                  return NULL;
        } else        }
                ioDEBUG(RPC_DEBUG_LEVEL, "Readed %d bytes", rlen); 
   
         do {          do {
                 if (rlen < sizeof(struct tagRPCCall)) {                  if (rlen < sizeof(struct tagRPCCall)) {
Line 300  txBLOB(sched_task_t *task) Line 294  txBLOB(sched_task_t *task)
         else if (wlen != sizeof(struct tagBLOBHdr))          else if (wlen != sizeof(struct tagBLOBHdr))
                 rpc_SetErr(EPROCUNAVAIL, "RPC reply, should be send %d bytes, "                  rpc_SetErr(EPROCUNAVAIL, "RPC reply, should be send %d bytes, "
                                 "really sended %d bytes", sizeof(struct tagBLOBHdr), wlen);                                  "really sended %d bytes", sizeof(struct tagBLOBHdr), wlen);
         else  
                 ioDEBUG(RPC_DEBUG_LEVEL, "Sended %d bytes", wlen);  
   
         return NULL;          return NULL;
 }  }
Line 338  rxBLOB(sched_task_t *task) Line 330  rxBLOB(sched_task_t *task)
         } else if (!rlen || s->srv_kill == kill) { /* receive EOF */          } else if (!rlen || s->srv_kill == kill) { /* receive EOF */
                 s->srv_blob.state = kill;                  s->srv_blob.state = kill;
                 return NULL;                  return NULL;
        } else        }
                ioDEBUG(RPC_DEBUG_LEVEL, "Readed %d bytes", rlen); 
   
         if (rlen < sizeof(struct tagBLOBHdr)) {          if (rlen < sizeof(struct tagBLOBHdr)) {
                 rpc_SetErr(ERPCMISMATCH, "Too short BLOB packet");                  rpc_SetErr(ERPCMISMATCH, "Too short BLOB packet");
Removed from v.1.8.2.6  
changed lines
  Added in v.1.8.2.7

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