ss7_mtp2_array.h~

实现了SS7中MTP2层的基本功能

// File Name: SS7_MTP2_Array.h
/////////////////////////////////////////////////

#ifndef _EASYTELECOM_SS7_MTP2_ARRAY_H_XING_20080903_
#define _EASYTELECOM_SS7_MTP2_ARRAY_H_XING_20080903_

#include "SS7_MTP2.h"
#include "CircularBuffer.h"

class MTP2Config {
private:
    int portNumber;
    int recvBufferSize;
    int sendbufferSize;

public:
    MTP2Config() {}
    ~MTP2Config() {}
};


class SS7_MTP2_Array {

public:
    SS7_MTP2_Array(int _portCount, MTP2Config * _portConfigList );
    virtual ~SS7_MTP2_Array(void);

public:
    int          mtp2_port_count;
    SS7_MTP2   * mtp2Array;
    bool         toTerminate;

private:
    MTP2Config * mtp2ConfigList;

    // for the eight ports on the card, we have only one channel for
    // receiving and sending respectively, so we 
    pthread_t   threadTransmit;
    pthread_t   threadReceive;
    pthread_t   threadCheckTimers;
    pthread_t   threadUpdateMTP2FSMs;

    fd_set      rdfdset;
    fd_set      wrfdset;
    int         devfd;
    int         maxfd;

public:
    fd_set * getRdfdSet(void) { return (&rdfdset); }
    fd_set * getWrfdSet(void) { return (&wrfdset); }
    int getMaxfd(void) { return maxfd; }
    int getDevfd(void) { return devfd; }

public:

    int  run(void);
    void terminate(void);

    int  joinThread();

    // primitives for MTP-3
    int sendMessage(unsigned char * _data, int _count, int _portNumber );
    int readMessage(unsigned char * _buffer, int _len, int _portNumber);

    // other primitives
    int L3Start(void);
    int L3Stop();
    int L3RetrieveBSNT();
    int L3RetrievalRequestAndFSNC();
    int L3FlushBuffers();
    int L3Continue();
    int L3Emergency();
    int L3EmergencyCease();
    int L3LocalProcRecovered();

    int L3Msg4Transmission();
};

#endif // _EASYTELECOM_SS7_MTP2_ARRAY_H_XING_20080903_