signalmanager.h

Go to the documentation of this file.

#ifndef SIGNALMANAGER_H
#define SIGNALMANAGER_H

#include <stdio.h>
#include <linux/types.h>
#include <vector>
#include <time.h>
#include <pthread.h>
#include <assert.h>
#include "buffer.h"
#include "signals.h"

using namespace std;

namespace SMP{

class SMPKernel;

class SMPSignalManager
{
private:
    //SMPKernel *kernel;

    static int *interval; 
    vector<int> sig_fid;
    vector<pthread_t> sig_tid;
    static void *monitor_thread(void *arg);

public:
    SMPSignalManager(SMPKernel *k);
    ~SMPSignalManager();

    void register_thread(int fid, pthread_t tid);

    void start();
    void stop(bool wait_handler);
    void clear();
    
    //user functions...

    void monitor(int id);
    void signal(int id);

    int get_thread_id(int fid);
    inline int get_filter_id(int id);
    inline void set_timeout_f(int fid, int ms);
    inline int get_timeout_f(int fid);
    inline static int get_timeout(int id);
};


int SMPSignalManager::get_filter_id(int id)
{
    assert(id >= 0);
    return sig_fid[id];
}

void SMPSignalManager::set_timeout_f(int fid, int ms)
{
    assert(fid >= 0);
    int id = get_thread_id(fid);
    interval[id] = ms;
}

int SMPSignalManager::get_timeout_f(int fid)
{
    assert(fid >= 0);
    int id = get_thread_id(fid);
    return interval[id];
}

int SMPSignalManager::get_timeout(int id)
{
    assert(id >= 0);
    return interval[id];
}

} //end namespace
#endif

---