void monitorIntValues

(

)

Definition at line 3540 of file feeserver.c.

References checkIntLocation(), createLogMessage(), dis_update_service, firstIntNode, and sprintf().

Referenced by startMonitorThread().

                        {
        int status = -1;
        int nRet;
        unsigned long sleepTime = 0;
        IntItemNode* 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
        intMonitorThreadStarted = true;

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

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

        while (1) {
                current = firstIntNode;
                sleepTime = (unsigned long) (updateRate / intNodesAmount);
                while (current != 0) { // is lastIntNode->next (end of list)
                        if (!checkIntLocation(current)) {
                                msg[sprintf(msg, "Value of item %s (int) is corrupt, reconstruction failed. Ignoring!",
                                                current->intItem->name)] = 0;
                                createLogMessage(MSG_ERROR, msg, 0);
                                // message and do some stuff (like invalidate value)
                                // (test, what happens if pointer is redirected ???)
                        } else {
                                if ((abs((*(current->intItem->location)) - current->lastTransmittedIntValue)
                                                >= current->threshold) || (outerCounter ==
                                                (innerCounter * TIME_INTERVAL_MULTIPLIER))) {
                                        nRet = dis_update_service(current->id);
                                        current->lastTransmittedIntValue = *(current->intItem->location);
#                                       ifdef __DEBUG
                                        printf("CE triggered an updated on %d clients for service %s [int]: %d\n",
                                                        nRet, current->intItem->name, *(current->intItem->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 >= (intNodesAmount * 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: