void createLogMessage	(	unsigned int	type,
		char *	description,
		char *	origin
	)

Definition at line 1530 of file feeserver.c.

References checkLogLevel(), checkReplicatedLogMessage(), dis_update_service, message, time, and type.

Referenced by ack_service(), allocateMemory(), command_handler(), createHeader(), createMemoryNode(), dim_dummy_exit_handler(), dim_error_msg_handler(), fee_exit_handler(), freeMemory(), getDeadband(), getIssueTimeout(), getLogLevel(), getUpdateRate(), initialize(), leaveCommandHandler(), marshallHeader(), monitorIntValues(), monitorValues(), runLogWatchDog(), setDeadband(), setFeeProperty(), setIssueTimeout(), setLogLevel(), setUpdateRate(), start(), startMonitorThread(), threadIssue(), triggerRestart(), unlockIssueMutex(), updateFeeServer(), and updateFeeService().

                                                                          {
        int status = -1; // for mutex
        int descLength = 0;
        int originLength = 0;
        time_t timeVal;
        struct tm* now = 0;

        // check if not in COLLECTING state
        if (state == COLLECTING) {
                return; // no log channel available at that time
        }

        //lock access with mutex due to the fact that FeeServer & CE can use it
        status = pthread_mutex_lock(&log_mut);
        // discard eventual error, this would cause more problems
        // in each case, do NOT call createLogMessage ;) !
#       ifdef __DEBUG
        if (status != 0) {
                printf("Lock log mutex error: %d\n", status);
                fflush(stdout);
        }
#       endif

        if (!checkLogLevel(type)) {   //if not -> unlock mutex -> return
                //unlock mutex
                status = pthread_mutex_unlock(&log_mut);
                // discard eventual error, this would cause more problems
                // in each case, do NOT call createLogMessage ;)
#               ifdef __DEBUG
                if (status != 0) {
                        printf("Unlock log mutex error: %d\n", status);
                        fflush(stdout);
                }
#               endif
                return;
        }

        // check if message is a replicate of the last log message
        if ((logWatchDogRunning) && (strncmp(description, lastMessage.description,
                                (MSG_DESCRIPTION_SIZE - 1)) == 0)) {
                replicatedMsgCount++;

                //unlock mutex
        status = pthread_mutex_unlock(&log_mut);
        // discard eventual error, this would cause more problems
        // in each case, do NOT call createLogMessage ;)
#       ifdef __DEBUG
        if (status != 0) {
            printf("Unlock log mutex error: %d\n", status);
            fflush(stdout);
        }
#       endif
                // message is a replicate of last message, leave Messenger
        return;
        } else {
                // message is not a replicate of last one send,
                // check if replicated log messages are pending
                if (checkReplicatedLogMessage()) {
                        // sleep a small amount to let Dim update channel
//                      usleep(1000);
                }
        }

        // prepare data (cut off overlength)
        if (description != 0) {
                // limit description to maximum of field in message struct if longer
                descLength = ((strlen(description) >= MSG_DESCRIPTION_SIZE)
                                ? (MSG_DESCRIPTION_SIZE - 1) : strlen(description));
        }
        if (origin != 0) {
                // limit origin to maximum of field in message struct if longer
                // be aware that "source" also contains server name and a slash
                originLength = ((strlen(origin) >= MSG_SOURCE_SIZE - serverNameLength - 1)
                                ? (MSG_SOURCE_SIZE - serverNameLength - 2) : strlen(origin));
        }

        //set type
        message.eventType = type;
        //set detector
        memcpy(message.detector, LOCAL_DETECTOR, MSG_DETECTOR_SIZE);
        //set origin
        strcpy(message.source, serverName);
        if (origin != 0) {
                // append slash
                strcpy(message.source + serverNameLength, "/");
                // append origin maximum til end of source field in message struct
                strncpy(message.source + serverNameLength + 1, origin, originLength);
                // terminate with '\0'
                message.source[serverNameLength + 1 + originLength] = 0;
        }
        //set description
        if (description != 0) {
                // fill description field of message struct maximum til end
                strncpy(message.description, description, descLength);
                // terminate with '\0'
                message.description[descLength] = 0;
        } else {
                strcpy(message.description, "No description specified.");
        }
        //set current date and time
        time(&timeVal);
        now = localtime(&timeVal);
        message.date[strftime(message.date, MSG_DATE_SIZE, "%Y-%m-%d %H:%M:%S",
                                now)] = 0;

        //updateService
        dis_update_service(messageServiceID);

        // copy send message to storage of last message
        lastMessage = message;

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

Here is the call graph for this function:

Here is the caller graph for this function: