Session.h

Go to the documentation of this file.

#ifndef SESSION_H
#define SESSION_H

// System includes
#include <netinet/in.h>
#include <pthread.h>
#include <sys/socket.h>

#include <vector>

namespace log4cpp {
    class Category;
}

namespace carma {
namespace canbus {

// Forward declaration
class Message;

namespace canoverip {


class Session {
public:

    Session(int readSock, int writeSock);
    
    ~Session();
   
    typedef struct {
        unsigned int aCode;           // CAN id filter acceptance codes
        unsigned int aMask;           // CAN id filter acceptance masks
        unsigned short busFilter;     // Bus Id Filter
    } FilterType;

    void addFilter(FilterType filter);

    void clearFilters( );

    bool matchesFilter(const carma::canbus::Message & msg);

    inline int getReadSock( ) { return rsd_; };

    inline int getWriteSock( ) { return wsd_; };

protected:
    

private:
    
    typedef union {
        struct sockaddr_in sa_in; // Server addresses
        struct sockaddr sa;
    } SockAddressUnion;
    
    int rsd_;                          // Read Socket Descriptor.
    int wsd_;                          // Write Socket Descriptor.
    SockAddressUnion ra_;              // Read socket address
    SockAddressUnion wa_;              // Write socket address
    pthread_mutex_t mutex_;            // Mutex for data structure access. 
    std::vector<FilterType> filters_;  // Vector to hold filters.
    log4cpp::Category &log_;

    Session &operator=(const Session &);
    Session(const Session &);
    
}; 
}}} // namespace carma::canbus::canoverip
#endif