信号量处理类实现

 

signalhand.h

#include "ace/Basic_Types.h"
#include "ace/Signal.h"

/*************************************************
Class: CSignalHandlerImpl
Description: 信号量处理类实现
*************************************************/
class CSignalHandler : public ACE_Event_Handler
{
public:
    CSignalHandler();
    virtual ~CSignalHandler();

public:
    ACE_INT32 Init();//初始化
    ACE_INT32 Exit();

public:
    virtual ACE_INT32 handle_signal (ACE_INT32 signum, siginfo_t * = 0, ucontext_t * = 0); //实现这个回调函数

private:
    ACE_Sig_Action no_sigpipe;
};

 

 

评论

1 楼 sblig 2010-12-20  

signalhand.cpp


/*************************************************
Function:         initial
Description:     初始化函数，进行信号量注册
*************************************************/
ACE_INT32 CSignalHandler::Init()
{
    CAppManager::Instance()->GetReactor().register_handler(SIGHUP, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGINT, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGABRT, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGALRM, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGUSR1, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGUSR2, this);
#ifndef ACE_CONFIG_WIN32_H
    CAppManager::Instance()->GetReactor().register_handler(SIGPOLL, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGVTALRM, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGPROF, this);
#endif
    CAppManager::Instance()->GetReactor().register_handler(SIGCLD, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGTERM, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGCHLD, this);
    CAppManager::Instance()->GetReactor().register_handler(SIGIO, this);

    no_sigpipe.register_action (SIGPIPE, NULL);

    return 0;
}


/*************************************************
Function:         handle_signal
Description:     系统回调函数，这里不对信号量
                进行处理，只是进行标志位置位
                然后唤醒信号量处理线程进行处理
*************************************************/
ACE_INT32 CSignalHandler::handle_signal (ACE_INT32 signum, siginfo_t * , ucontext_t *)
{
    ACE_Sig_Set sigs;

    sigs.sig_add (SIGHUP);
    sigs.sig_add (SIGINT);
    sigs.sig_add (SIGABRT);
    sigs.sig_add (SIGALRM);
    sigs.sig_add (SIGUSR1);
    sigs.sig_add (SIGUSR2);
    sigs.sig_add (SIGCLD);
    sigs.sig_add (SIGTERM);
    sigs.sig_add (SIGCHLD);
    sigs.sig_add (SIGIO);

#ifndef ACE_CONFIG_WIN32_H
    sigs.sig_add (SIGPOLL);
    sigs.sig_add (SIGVTALRM);
    sigs.sig_add (SIGPROF);
#endif

    ACE_Sig_Guard guard (&sigs);

    if (SIGINT == signum || SIGTERM == signum)
    {
    	//会检测并退出系统的
    }
    else if (SIGUSR1 == signum)
    {
        // 自定义处理线程处理
    }

    return 0;
}