void runLogWatchDog

(

)

Definition at line 2125 of file feeserver.c.

References checkReplicatedLogMessage(), createLogMessage(), and dtq_sleep().

Referenced by startLogWatchDogThread().

                      {
        int status = -1;
        unsigned int sleepSec = 0;
        unsigned int sleepMilliSec = 0;

    // set cancelation type
    status = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, 0);
    if (status != 0) {
#       ifdef __DEBUG
        printf("Set cancel state error [LogWatchDog]: %d\n", status);
        fflush(stdout);
#       endif
        createLogMessage(MSG_WARNING,
            "Can not set cancel state for LogWatchDog thread. WatchDog should not not be affected.",
                        0);
    }
    status = pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
    if (status != 0) {
#       ifdef __DEBUG
        printf("Set cancel type error [LogWatchDog]: %d\n", status);
        fflush(stdout);
#       endif
        createLogMessage(MSG_WARNING,
            "Can not set cancel type for LogWatchDog thread. WatchDog should not not be affected.",
                        0);
    }

    // thread started successfully, set flag accordingly
    logWatchDogRunning = true;
    createLogMessage(MSG_DEBUG,
            "LogWatchDog thread for filtering replicated log messages successfully started.",
            0);
#   ifdef __DEBUG
    printf("LogWatchDog thread for filtering replicated log messages successfully started.\n");
    fflush(stdout);
#   endif

        while (1) {
                // before test for replicated messages lock mutex,
                // DON'T call createLogMessage() inside mutex lock
        status = pthread_mutex_lock(&log_mut);
        // discard eventual error, this would cause more problems
#       ifdef __DEBUG
        if (status != 0) {
                printf("Lock log mutex error: %d\n", status);
                fflush(stdout);
        }
#       endif

                // perform check here
                checkReplicatedLogMessage();

                // release mutex
        status = pthread_mutex_unlock(&log_mut);
        // discard eventual error, this would cause more problems
#       ifdef __DEBUG
        if (status != 0) {
            printf("Unlock log mutex error: %d\n", status);
            fflush(stdout);
        }
#       endif

                // set cancelation point
                pthread_testcancel();
                // prepare sleep time (timeout)
                sleepSec = logWatchDogTimeout / 1000;
                sleepMilliSec = logWatchDogTimeout % 1000;
                usleep(sleepMilliSec * 1000);
                dtq_sleep(sleepSec);
                // set cancelation point
                pthread_testcancel();
        }

        // should never be reached !
        pthread_exit(0);
}

Here is the call graph for this function:

Here is the caller graph for this function: