void* threadIssue

(

void *

threadParam

)

Definition at line 2243 of file feeserver.c.

References createLogMessage().

Referenced by command_handler().

                                     {
        IssueStruct* issueParam = (IssueStruct*) threadParam;
        int status;

        status = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, 0);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set cancel state error: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to configure issue thread properly. Execution might eventually be affected.", 0);
        }

        status = pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set cancel type error error: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to configure issue thread properly. Execution might eventually be affected.", 0);
        }

        // executing command inside CE
        issueParam->nRet = issue(issueParam->command, &(issueParam->result), &(issueParam->size));

    //set cancel type to deferred
    status = pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, 0);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Set cancel type error: %d\n", status);
                fflush(stdout);
#          endif
                createLogMessage(MSG_WARNING,
                        "Unable to configure issue thread properly. Execution might eventually be affected.", 0);
    }

        //lock the mutex before broadcast
        status = pthread_mutex_lock(&wait_mut);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Lock cond mutex error: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to lock condition mutex for watchdog in issue thread. Execution might eventually be affected.",
                        0);
        }

        //signal that issue has returned from ControlEngine
        // maybe try the call pthread_cond_signal instead for performance
        pthread_cond_broadcast(&cond);

        // unlock mutex
        status = pthread_mutex_unlock(&wait_mut);
        if (status != 0) {
#               ifdef __DEBUG
                printf("Unlock cond mutex error: %d\n", status);
                fflush(stdout);
#               endif
                createLogMessage(MSG_WARNING,
                        "Unable to unlock condition mutex for watchdog in issue thread. Execution might eventually be affected.",
                        0);
        }

//      not needed, return 0 is better solution
//      pthread_exit(0);
        return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function: