int startMonitorThread

(

)

Definition at line 1878 of file feeserver.c.

References createLogMessage(), monitorIntValues(), and monitorValues().

Referenced by start().

                         {
        int status = -1;
        pthread_attr_t attr;

        // when item lists are empty, no monitor threads are needed
        if ((nodesAmount == 0) && (intNodesAmount == 0)) {
                createLogMessage(MSG_INFO,
                                "No Items (float and int) for monitoring are available.", 0);
                return FEE_OK;
        }

        // init thread attribut and set it
        status = pthread_attr_init(&attr);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Init attribute error [mon]: %d\n", status);
                fflush(stdout);
#               endif
                return FEE_MONITORING_FAILED;
        }
        status = pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set attribute error [mon]: %d\n", status);
                fflush(stdout);
#               endif
                return FEE_MONITORING_FAILED;
        }

        // start the monitor thread for float values
        if (nodesAmount > 0) {
                status = pthread_create(&thread_mon, &attr, (void*)&monitorValues, 0);
                if (status != 0) {
#                       ifdef __DEBUG
                        printf("Create thread error [mon - float]: %d\n", status);
                        fflush(stdout);
#                       endif
                        return FEE_MONITORING_FAILED;
                }
        }

        //start the monitor thread for int values --> NEW v.0.8.1
        if (intNodesAmount > 0) {
                status = pthread_create(&thread_mon_int, &attr, (void*)&monitorIntValues, 0);
                if (status != 0) {
#                       ifdef __DEBUG
                        printf("Create thread error [mon - int]: %d\n", status);
                        fflush(stdout);
#                       endif
                        return FEE_MONITORING_FAILED;
                }
        }

        // cleanup attribut
        status = pthread_attr_destroy(&attr);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Destroy attribute error [mon]: %d\n", status);
                fflush(stdout);
#               endif
                // no error return value necessary !
        }
        return FEE_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function: