void monitorValues

(

)

Definition at line 1944 of file feeserver.c.

References checkLocation(), createLogMessage(), dis_update_service, firstNode, and sprintf().

Referenced by startMonitorThread().

                     {
        int status = -1;
        int nRet;
        unsigned long sleepTime = 0;
        ItemNode* current = 0;
        char msg[120];
    unsigned long innerCounter = 0; // used for update check after time interval
    unsigned long outerCounter = 0; // used for update check after time interval

        // set flag, that monitor thread has been started
        monitorThreadStarted = true;

        // set cancelation type
        status = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, 0);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set cancel state error [mon - float]: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to configure monitor thread (float) properly. Monitoring is not affected.", 0);
        }
        status = pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set cancel type error [mon - float]: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to configure monitor thread (float) properly. Monitoring is not affected.", 0);
        }

        createLogMessage(MSG_DEBUG, "Started monitor thread for FLOAT values successfully.", 0);

        while (1) {
                current = firstNode;
                sleepTime = (unsigned long) (updateRate / nodesAmount);
                while (current != 0) { // is lastNode->next (end of list)
                        if (!checkLocation(current)) {
                                msg[sprintf(msg, "Value of item %s (float) is corrupt, reconstruction failed. Ignoring!",
                                                current->item->name)] = 0;
                                createLogMessage(MSG_ERROR, msg, 0);
                                // message and do some stuff (like invalidate value)
                                // (test, what happens if pointer is redirected ???)
                        } else {
                                if ((fabsf((*(current->item->location)) - current->lastTransmittedValue)
                                                >= current->threshold) || (outerCounter ==
                                                (innerCounter * TIME_INTERVAL_MULTIPLIER))) {
                                        nRet = dis_update_service(current->id);
                                        current->lastTransmittedValue = *(current->item->location);
#                                       ifdef __DEBUG
                                        //printf("Updated %d clients for service %s [float]: %f\n", nRet,
                                        //              current->item->name, *(current->item->location));
                                        //fflush(stdout);
#                                       endif
                                }
                        }

                        ++innerCounter;
                        current = current->next;
                        usleep(sleepTime * 1000);
                        // sleeps xy microseconds, needed milliseconds-> "* 1000"
                }
                // with the check of both counter, each service is at least updated after
                // every (deadband updateRate * nodesAmount) seconds
                innerCounter = 0;
                ++outerCounter;
                // after every service in list is updated set counter back to 0
                // the TIME_INTERVAL_MULTIPLIER is used to enlarge the time interval of
                // the request of services without touching the deadband checker updateRate
                if (outerCounter >= (nodesAmount * TIME_INTERVAL_MULTIPLIER)) {
                        outerCounter = 0;
                }
        }
        // should never be reached !
        pthread_exit(0);
}

Here is the call graph for this function:

Here is the caller graph for this function: