Ignore:
Timestamp:
Jan 17, 2014, 10:08:51 PM (11 years ago)
Author:
ldelgass
Message:

Restore whitespace fixes

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/packages/vizservers/nanoscale/server.c

    r4130 r4131  
    9898        s++;
    9999    }
    100     length = snprintf(message, MSG_LEN, "nanoscale (%d %d) %s: %s:%d ", 
     100    length = snprintf(message, MSG_LEN, "nanoscale (%d %d) %s: %s:%d ",
    101101        serverPid, getpid(), syslogLevels[priority],  s, lineNum);
    102102    length += vsnprintf(message + length, MSG_LEN - length, fmt, lst);
    … …  
    109109}
    110110
    111 static void 
     111static void
    112112Help(const char *program)
    113113{
    … …  
    139139
    140140static int
    141 ParseSwitches(Tcl_Interp *interp, RenderServer *serverPtr, int *objcPtr, 
     141ParseSwitches(Tcl_Interp *interp, RenderServer *serverPtr, int *objcPtr,
    142142              Tcl_Obj ***objvPtr)
    143143{
    … …  
    158158        if ((c == 'i') && (strcmp(string, "-input") == 0)) {
    159159            int f;
    160            
     160
    161161            if (Tcl_GetIntFromObj(interp, objv[i+1], &f) != TCL_OK) {
    162162                return TCL_ERROR;
    … …  
    165165        } else if ((c == 'o') && (strcmp(string, "-output") == 0)) {
    166166            int f;
    167            
     167
    168168            if (Tcl_GetIntFromObj(interp, objv[i+1], &f) != TCL_OK) {
    169169                return TCL_ERROR;
    … …  
    172172        } else if ((c == 'l') && (strcmp(string, "-logstdout") == 0)) {
    173173            int state;
    174            
     174
    175175            if (Tcl_GetBooleanFromObj(interp, objv[i+1], &state) != TCL_OK) {
    176176                return TCL_ERROR;
    … …  
    210210 *          register_server <name> <port> <cmd> <environ>
    211211 *
    212  *      where 
     212 *      where
    213213 *
    214214 *          name        Token for the render server.
    215215 *          port        Port to listen to accept connections.
    216216 *          cmd         Command to be run to start the render server.
    217  *          environ     Name-value pairs of representing environment 
     217 *          environ     Name-value pairs of representing environment
    218218 *                      variables.
    219219 *
    220  *      Note that "cmd" and "environ" are variable and backslash 
    221  *      substituted.  A listener socket automatically is established on 
    222  *      the given port to accept client requests. 
    223  *     
     220 *      Note that "cmd" and "environ" are variable and backslash
     221 *      substituted.  A listener socket automatically is established on
     222 *      the given port to accept client requests.
     223 *
    224224 *      Example:
    225225 *
    … …  
    248248
    249249    if (objc < 4) {
    250         Tcl_AppendResult(interp, "wrong # args: should be \"", 
    251                 Tcl_GetString(objv[0]), " serverName port ?flags? cmd ?environ?", 
     250        Tcl_AppendResult(interp, "wrong # args: should be \"",
     251                Tcl_GetString(objv[0]), " serverName port ?flags? cmd ?environ?",
    252252                (char *)NULL);
    253253        return TCL_ERROR;
    … …  
    259259    hPtr = Tcl_CreateHashEntry(&serverTable, (char *)((long)port), &isNew);
    260260    if (!isNew) {
    261         Tcl_AppendResult(interp, "a server is already listening on port ", 
     261        Tcl_AppendResult(interp, "a server is already listening on port ",
    262262                Tcl_GetString(objv[2]), (char *)NULL);
    263263        return TCL_ERROR;
    … …  
    271271        goto error;
    272272    }
    273     objPtr = Tcl_SubstObj(interp, objv[3], 
     273    objPtr = Tcl_SubstObj(interp, objv[3],
    274274                          TCL_SUBST_VARIABLES | TCL_SUBST_BACKSLASHES);
    275     if (Tcl_SplitList(interp, Tcl_GetString(objPtr), &numCmdArgs, 
     275    if (Tcl_SplitList(interp, Tcl_GetString(objPtr), &numCmdArgs,
    276276        (const char ***)&cmdArgs) != TCL_OK) {
    277277        goto error;
    … …  
    279279    serverPtr->cmdArgs = cmdArgs;
    280280    serverPtr->numCmdArgs = numCmdArgs;
    281    
     281
    282282    numEnvArgs = 0;
    283283    envArgs = NULL;
    284284    if (objc == 5) {
    285         objPtr = Tcl_SubstObj(interp, objv[4], 
     285        objPtr = Tcl_SubstObj(interp, objv[4],
    286286                TCL_SUBST_VARIABLES | TCL_SUBST_BACKSLASHES);
    287         if (Tcl_SplitList(interp, Tcl_GetString(objPtr), &numEnvArgs, 
     287        if (Tcl_SplitList(interp, Tcl_GetString(objPtr), &numEnvArgs,
    288288                (const char ***)&envArgs) != TCL_OK) {
    289289            goto error;
    290290        }
    291291        if (numEnvArgs & 0x1) {
    292             Tcl_AppendResult(interp, "odd # elements in enviroment list", 
     292            Tcl_AppendResult(interp, "odd # elements in enviroment list",
    293293                             (char *)NULL);
    294294            goto error;
    … …  
    305305        goto error;
    306306    }
    307  
     307
    308308    /* If the render server instance should be killed, drop the socket address
    309309     * reservation immediately, don't linger. */
    … …  
    338338}
    339339
    340 static int 
     340static int
    341341ParseServersFile(const char *fileName)
    342342{
    … …  
    345345    interp = Tcl_CreateInterp();
    346346    Tcl_MakeSafe(interp);
    347     Tcl_CreateObjCommand(interp, "register_server", RegisterServerCmd, NULL, 
     347    Tcl_CreateObjCommand(interp, "register_server", RegisterServerCmd, NULL,
    348348                         NULL);
    349349    if (Tcl_EvalFile(interp, fileName) != TCL_OK) {
    … …  
    355355}
    356356
    357 int 
     357int
    358358main(int argc, char **argv)
    359359{
    … …  
    363363    fd_set serverFds;
    364364    int maxFd;                          /* Highest file descriptor in use. */
    365     char display[200];                  /* String used to manage the X 
    366                                          * DISPLAY variable for each render 
     365    char display[200];                  /* String used to manage the X
     366                                         * DISPLAY variable for each render
    367367                                         * server instance. */
    368368    int maxCards;                       /* Maximum number of video cards, each
    … …  
    373373    Tcl_HashSearch iter;
    374374    const char *fileName;               /* Path to servers file. */
    375  
     375
    376376    serverPid = getpid();
    377377    screenNum = 0;
    … …  
    432432    if (!ParseServersFile(fileName)) {
    433433        exit(1);
    434     }   
     434    }
    435435
    436436    if (serverTable.numEntries == 0) {
    … …  
    453453         hPtr = Tcl_NextHashEntry(&iter)) {
    454454        RenderServer *serverPtr;
    455        
     455
    456456        serverPtr = Tcl_GetHashValue(hPtr);
    457457        FD_SET(serverPtr->listenerFd, &serverFds);
    … …  
    480480            serverPtr = Tcl_GetHashValue(hPtr);
    481481            if (!FD_ISSET(serverPtr->listenerFd, &readFds)) {
    482                 continue;               
     482                continue;
    483483            }
    484484            /* Rotate the display's screen number.  If we have multiple video
    … …  
    491491            length = sizeof(newaddr);
    492492#ifdef HAVE_ACCEPT4
    493             sock = accept4(serverPtr->listenerFd, (struct sockaddr *)&newaddr, 
     493            sock = accept4(serverPtr->listenerFd, (struct sockaddr *)&newaddr,
    494494                        &length, SOCK_CLOEXEC);
    495495#else
    496             sock = accept(serverPtr->listenerFd, (struct sockaddr *)&newaddr, 
     496            sock = accept(serverPtr->listenerFd, (struct sockaddr *)&newaddr,
    497497                       &length);
    498498#endif
    499499            if (sock < 0) {
    500                 ERROR("Can't accept server \"%s\": %s", serverPtr->name, 
     500                ERROR("Can't accept server \"%s\": %s", serverPtr->name,
    501501                      strerror(errno));
    502502                exit(1);
    … …  
    506506            flags |= FD_CLOEXEC;
    507507            if (fcntl(sock, F_SETFD, flags) < 0) {
    508                 ERROR("Can't set FD_CLOEXEC on socket \"%s\": %s", 
     508                ERROR("Can't set FD_CLOEXEC on socket \"%s\": %s",
    509509                        serverPtr->name, strerror(errno));
    510510                exit(1);
    511511            }
    512512#endif
    513             INFO("Connecting \"%s\" to %s\n", serverPtr->name, 
     513            INFO("Connecting \"%s\" to %s\n", serverPtr->name,
    514514                 inet_ntoa(newaddr.sin_addr));
    515515
    … …  
    517517            child = fork();
    518518            if (child < 0) {
    519                 ERROR("Can't fork \"%s\": %s", serverPtr->name, 
     519                ERROR("Can't fork \"%s\": %s", serverPtr->name,
    520520                      strerror(errno));
    521521                continue;
    522             } 
     522            }
    523523            if (child == 0) {           /* Child process. */
    524524                int i;
    … …  
    526526                umask(0);
    527527                if ((!debug) && (setsid() < 0)) {
    528                     ERROR("Can't setsid \"%s\": %s", serverPtr->name, 
     528                    ERROR("Can't setsid \"%s\": %s", serverPtr->name,
    529529                          strerror(errno));
    530530                    exit(1);
    531531                }
    532532                if ((!debug) && ((chdir("/")) < 0)) {
    533                     ERROR("Can't change to root directory for \"%s\": %s", 
     533                    ERROR("Can't change to root directory for \"%s\": %s",
    534534                          serverPtr->name, strerror(errno));
    535535                    exit(1);
    … …  
    539539                    int newFd;
    540540
    541                     sprintf(path, "%s/%s-%d.log", LOGDIR, 
     541                    sprintf(path, "%s/%s-%d.log", LOGDIR,
    542542                        serverPtr->name, getpid());
    543543                    if (serverPtr->logStdout) {
    … …  
    546546                        newFd = open("/dev/null", O_WRONLY, 0600);
    547547                    }
    548                     if (newFd < 0) { 
     548                    if (newFd < 0) {
    549549                        ERROR("%s: can't open \"%s\": %s", serverPtr->name,
    550550                              path, strerror(errno));
    551551                        exit(1);
    552                     } 
    553                     if (dup2(newFd, 1) < 0) { 
    554                         ERROR("%s: can't dup stdout to \"%s\": %s", 
     552                    }
     553                    if (dup2(newFd, 1) < 0) {
     554                        ERROR("%s: can't dup stdout to \"%s\": %s",
    555555                              serverPtr->name, path, strerror(errno));
    556556                        exit(1);
    557557                    }
    558558                    if (dup2(newFd, 2) < 0) {
    559                         ERROR("%s: can't dup stderr to \"%s\": %s", 
     559                        ERROR("%s: can't dup stderr to \"%s\": %s",
    560560                              serverPtr->name, path, strerror(errno));
    561561                        exit(1);
    … …  
    565565                    int newFd;
    566566
    567                     sprintf(path, "%s/%s-%d.stdout", LOGDIR, 
     567                    sprintf(path, "%s/%s-%d.stdout", LOGDIR,
    568568                        serverPtr->name, getpid());
    569569                    if (serverPtr->logStdout) {
    … …  
    572572                        newFd = open("/dev/null", O_WRONLY, 0600);
    573573                    }
    574                     if (newFd < 0) { 
     574                    if (newFd < 0) {
    575575                        ERROR("%s: can't open \"%s\": %s", serverPtr->name,
    576576                              path, strerror(errno));
    577577                        exit(1);
    578                     } 
    579                     if (dup2(newFd, 1) < 0) { 
    580                         ERROR("%s: can't dup stdout to \"%s\": %s", 
     578                    }
     579                    if (dup2(newFd, 1) < 0) {
     580                        ERROR("%s: can't dup stdout to \"%s\": %s",
    581581                              serverPtr->name, path, strerror(errno));
    582582                        exit(1);
    583583                    }
    584                     sprintf(path, "%s/%s-%d.stderr", LOGDIR, 
     584                    sprintf(path, "%s/%s-%d.stderr", LOGDIR,
    585585                        serverPtr->name, getpid());
    586586                    if (serverPtr->logStderr) {
    … …  
    589589                        newFd = open("/dev/null", O_WRONLY, 0600);
    590590                    }
    591                     if (newFd < 0) { 
     591                    if (newFd < 0) {
    592592                        ERROR("%s: can't open \"%s\": %s", serverPtr->name,
    593593                              path, strerror(errno));
    594594                        exit(1);
    595                     } 
    596                     if (dup2(newFd, 1) < 0) { 
    597                         ERROR("%s: can't dup stderr to \"%s\": %s", 
     595                    }
     596                    if (dup2(newFd, 1) < 0) {
     597                        ERROR("%s: can't dup stderr to \"%s\": %s",
    598598                              serverPtr->name, path, strerror(errno));
    599599                        exit(1);
    600600                    }
    601                 } 
     601                }
    602602                /* Dup the socket to descriptors, normally 3 and 4 */
    603603                if (dup2(sock, serverPtr->inputFd) < 0)  { /* Stdin */
    604                     ERROR("%s: can't dup stdin: %s", serverPtr->name, 
     604                    ERROR("%s: can't dup stdin: %s", serverPtr->name,
    605605                        strerror(errno));
    606606                    exit(1);
    607607                }
    608608                if (dup2(sock, serverPtr->outputFd) < 0) { /* Stdout */
    609                     ERROR("%s: can't dup stdout: %s", serverPtr->name, 
     609                    ERROR("%s: can't dup stdout: %s", serverPtr->name,
    610610                          strerror(errno));
    611611                    exit(1);
    … …  
    622622                    setenv(serverPtr->envArgs[i], serverPtr->envArgs[i+1], 1);
    623623                }
    624                 INFO("Executing %s: client %s, %s in=%d out=%d on DISPLAY=%s", 
    625                      serverPtr->name, inet_ntoa(newaddr.sin_addr), 
     624                INFO("Executing %s: client %s, %s in=%d out=%d on DISPLAY=%s",
     625                     serverPtr->name, inet_ntoa(newaddr.sin_addr),
    626626                     serverPtr->cmdArgs[0], serverPtr->inputFd,
    627627                     serverPtr->outputFd, display);
    628628                /* Replace the current process with the render server. */
    629629                execvp(serverPtr->cmdArgs[0], serverPtr->cmdArgs);
    630                 ERROR("Can't execute \"%s\": %s", serverPtr->cmdArgs[0], 
     630                ERROR("Can't execute \"%s\": %s", serverPtr->cmdArgs[0],
    631631                      strerror(errno));
    632632                exit(1);
    … …  
    634634                close(sock);
    635635            }
    636         } 
     636        }
    637637    }
    638638    exit(1);
Note: See TracChangeset for help on using the changeset viewer.