[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.3.2.3 and 1.3.2.6

version 1.3.2.3, 2011/08/18 21:20:54 version 1.3.2.6, 2011/08/19 07:39:29
Line 421  rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, int Line 421  rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, int
         }          }
   
         /* create BLOB server socket */          /* create BLOB server socket */
           srv->srv_blob.server.cli_type = sockType ? sockType : SOCK_STREAM;
         srv->srv_blob.server.cli_sock = socket(srv->srv_server.cli_sa.sa_family,           srv->srv_blob.server.cli_sock = socket(srv->srv_server.cli_sa.sa_family, 
                        sockType ? sockType : SOCK_STREAM, 0);                        srv->srv_blob.server.cli_type, 0);
         if (srv->srv_blob.server.cli_sock == -1) {          if (srv->srv_blob.server.cli_sock == -1) {
                 LOGERR;                  LOGERR;
                 return -1;                  return -1;
Line 535  rpc_srv_execBLOBServer(rpc_srv_t * __restrict srv) Line 536  rpc_srv_execBLOBServer(rpc_srv_t * __restrict srv)
                         return -1;                          return -1;
                 }                  }
   
        while (!blob_Kill && !rpc_Kill) {        while (srv->srv_blob.state != kill && srv->srv_kill != kill) {
                 for (c = srv->srv_blob.clients, i = 0; i < srv->srv_numcli && c; i++, c++)                  for (c = srv->srv_blob.clients, i = 0; i < srv->srv_numcli && c; i++, c++)
                         if (!c->cli_sa.sa_family)                          if (!c->cli_sa.sa_family)
                                 break;                                  break;
Line 673  rpc_srv_initServer(u_int regProgID, u_int regProcID, i Line 674  rpc_srv_initServer(u_int regProgID, u_int regProcID, i
         }          }
   
         /* create server socket */          /* create server socket */
        srv->srv_server.cli_sock = socket(family, sockType ? sockType : SOCK_STREAM, 0);        srv->srv_server.cli_type = sockType ? sockType : SOCK_STREAM;
         srv->srv_server.cli_sock = socket(family, srv->srv_server.cli_type, 0);
         if (srv->srv_server.cli_sock == -1) {          if (srv->srv_server.cli_sock == -1) {
                 LOGERR;                  LOGERR;
                 free(srv);                  free(srv);
                 return NULL;                  return NULL;
        } else        }
                srv->srv_server.cli_type = sockType; 
         if (setsockopt(srv->srv_server.cli_sock, SOL_SOCKET, SO_REUSEADDR, &n, sizeof n) == -1) {          if (setsockopt(srv->srv_server.cli_sock, SOL_SOCKET, SO_REUSEADDR, &n, sizeof n) == -1) {
                 LOGERR;                  LOGERR;
                 close(srv->srv_server.cli_sock);                  close(srv->srv_server.cli_sock);
Line 786  rpc_srv_execServer(rpc_srv_t * __restrict srv) Line 787  rpc_srv_execServer(rpc_srv_t * __restrict srv)
                         return -1;                          return -1;
                 }                  }
   
        while (!rpc_Kill) {        while (srv->srv_kill != kill) {
                 for (c = srv->srv_clients, i = 0; i < srv->srv_numcli && c; i++, c++)                  for (c = srv->srv_clients, i = 0; i < srv->srv_numcli && c; i++, c++)
                         if (!c->cli_sa.sa_family)                          if (!c->cli_sa.sa_family)
                                 break;                                  break;
Removed from v.1.3.2.3  
changed lines
  Added in v.1.3.2.6

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