cmppmain.c

Unix/Linux下的cmpp实现源程序

#include "kevopsall.ext"
#include "cmpp.h"


/*
#define INSTALL_DIR "/home/ke"
#define LOCK_FILE "./c.lck"
*/


ASSOC assocTab [] = {
        { "cmpp", cmpp_type_init },
        { NULL, NULL }
};


void cmpp_associate (CVOPS_STATE * cvState)
{
    if (!cvState) return;
}


void exitall ()
{
    exit(1);
}


void * cmppmain (void * arg)
{
    SPCMPP      * cmarg          = NULL;
    CVOPS_STATE * cvState        = NULL;

    cmarg = (SPCMPP *)arg;

    cvState = createSubSystem (assocTab);
    if (!cvState) {
        fprintf(stderr, "\nCMPP sub-system creation fails.\n");
        return NULL;
    }

    cvState->ref = cmarg;

    initializeSubSystem(cvState, cmpp_associate);

    cmarg->cvstate = cvState;
    cmarg->entity = getVtask(cvState, "cmpp");

    sem_post (&cmarg->init_end);

    schedulerOfSubSystem (cvState);

#ifdef _DEBUG
info("CMPP Protocol thread exited.\n");
#endif

    return 0;
}