int start

(

int

initState

)

Definition at line 1740 of file feeserver.c.

References ack_service(), cleanUp(), command_handler(), createHeader(), createLogMessage(), dis_add_cmnd, dis_add_service, dis_remove_service, dis_start_serving, Memory::free(), Memory::malloc(), provideUpdateRate(), sprintf(), startLogWatchDogThread(), and startMonitorThread().

Referenced by EventBuilderWrapper::applyCalib(), DrsCalibrate::ApplyCh(), Compress(), createBenchmark(), Decompress(), FactGui::DisplayEventData(), initialize(), main(), UIConnector::on_autoScaleColor_clicked(), Queue< pair< Time, GUI_STAT > >::Queue(), AutoScheduler< T >::Schedule(), MyTimer::timerHandler(), Tools::Trim(), FitsFile::WriteData(), DataWriteFits2::WriteFooter(), DataWriteFits::WriteFooter(), and FitsFile::WriteKeyNT().

                         {
        int nRet = FEE_UNKNOWN_RETVAL;
        char* serviceName = 0;
        char* messageName = 0;
        char* commandName = 0;
        char msgStructure[50];

        if (state == COLLECTING) {
                //----- add service for acknowledge -----
                serviceName = (char*) malloc(serverNameLength + 13);
                if (serviceName == 0) {
                        //no memory available!
#                       ifdef __DEBUG
                        printf("no memory available while trying to create ACK channel!\n");
                        fflush(stdout);
#                       endif
                        // !!! unable to run FeeServer, write msg in kernel logger !!! (-> Tobias)
                        cleanUp();
                        exit(201);
                }
                // compose ACK channel name and terminate with '\0'
                serviceName[sprintf(serviceName, "%s_Acknowledge", serverName)] = 0;
                if (cmndACK != 0) {
                        free(cmndACK);
                        cmndACK = 0;
                }
                // take created header
                cmndACK = createHeader(0, initState, false, false, 0);
                cmndACKSize = HEADER_SIZE;
                // add ACK channel as service to DIM
                serviceACKID = dis_add_service(serviceName, "C", 0, 0, &ack_service,
                                ACK_SERVICE_TAG);
                free(serviceName);

                //----- add message service -----
                messageName = (char*) malloc(serverNameLength + 9);
                if (messageName == 0) {
                        //no memory available!
#                       ifdef __DEBUG
                        printf("no memory available while trying to create message channel!\n");
                        fflush(stdout);
#                       endif
                        // !!! unable to run FeeServer, write msg in kernel logger !!! (->Tobias)
                        cleanUp();
                        exit(201);
                }
                // compose message channel name and terminate with '\0'
                messageName[sprintf(messageName, "%s_Message", serverName)] = 0;
                // compose message structure
                msgStructure[sprintf(msgStructure, "I:1;C:%d;C:%d;C:%d;C:%d",
                                MSG_DETECTOR_SIZE, MSG_SOURCE_SIZE, MSG_DESCRIPTION_SIZE,
                                MSG_DATE_SIZE)] = 0;
                // add message channel as service to DIM
                messageServiceID = dis_add_service(messageName, msgStructure, (int*) &message,
                                sizeof(unsigned int) + MSG_DETECTOR_SIZE + MSG_SOURCE_SIZE +
                                MSG_DESCRIPTION_SIZE + MSG_DATE_SIZE, 0, 0);
                free(messageName);

                //----- before start serving we add the only command handled by the server -----
                commandName = (char*) malloc(serverNameLength + 9);
                if (commandName == 0) {
                        //no memory available!
#                       ifdef __DEBUG
                        printf("no memory available while trying to create CMD channel!\n");
                        fflush(stdout);
#                       endif
                        // !!! unable to run FeeServer, write msg in kernel logger !!! (->Tobias)
                        cleanUp();
                        exit(201);
                }
                // compose Command channel name and terminate with '\0'
                commandName[sprintf(commandName, "%s_Command", serverName)] = 0;
                // add CMD channel as command to DIM, no tag needed,
                // only one command possible
                commandID = dis_add_cmnd(commandName, "C", &command_handler, 0);
                free(commandName);

                //-- now start serving --
                if (dis_start_serving(serverName) == 1) {
                        // if start server was successful
                        if (initState == FEE_OK) {
                                state = RUNNING;
                                // start monitoring thread now
                                nRet = startMonitorThread();
                                if (nRet != FEE_OK) {
#                                       ifdef __DEBUG
                                        printf("Could NOT start monitor thread, error: %d\n", nRet);
                                        fflush(stdout);
#                                       endif
                                        createLogMessage(MSG_ERROR,
                                                        "Unable to start monitor thread on FeeServer.", 0);
                                        return nRet;
                                }
                                // inform CE about update rate
                                provideUpdateRate();
                                createLogMessage(MSG_INFO,
                                                "FeeServer started correctly, including monitor thread.", 0);
                                nRet = FEE_OK;
                        } else {
                                state = ERROR_STATE;
                                createLogMessage(MSG_ERROR,
                                                "Initialisation of ControlEngine failed. FeeServer is running in ERROR state (without CE).",
                                                0);
                                // starting itself worked, so nRet is OK
                                nRet = FEE_OK;
                        }
                        // start "relicated log messages" watchdog now
                        nRet = startLogWatchDogThread();
            if (nRet != FEE_OK) {
#               ifdef __DEBUG
                printf("Could NOT start log watch dog thread, error: %d; FeeServer will run without it.\n",
                                                nRet);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Can not start LogWatchDog thread (filters replicated MSGs). Uncritical error - running without it.",
                                                 0);
            }
                } else {
                        // starting server was not successful, so remove added core - services
                        // so they can be added again by next start() - call
                        dis_remove_service(serviceACKID);
                        free(cmndACK);
                        cmndACK = 0;
                        cmndACKSize = 0;
                        dis_remove_service(messageServiceID);
                        dis_remove_service(commandID);
                        nRet = FEE_FAILED;
                }
                return nRet;
        }
        //server is already running
        return FEE_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function: