OFServer.hh

#ifndef __OFSERVER_HH__
#define __OFSERVER_HH__

#include <pthread.h>

#include <map>

#include "base/BaseOFConnection.hh"
#include "base/BaseOFServer.hh"
#include "OFConnection.hh"
#include "OFServerSettings.hh"

namespace fluid_base {
class OFServer : private BaseOFServer, public OFHandler {
public:
    OFServer(const char* address,
             const int port,
             const int nthreads = 4,
             const bool secure = false,
             const struct OFServerSettings ofsc = OFServerSettings());
    virtual ~OFServer();

    // We reimplement this so that SWIG bindings don't have know BaseOFServer
    virtual bool start(bool block = false);

    virtual void stop();

    OFConnection* get_ofconnection(int id);

    void set_config(OFServerSettings ofsc);

    virtual void connection_callback(OFConnection* conn, OFConnection::Event event_type) {};
    virtual void message_callback(OFConnection* conn, uint8_t type, void* data, size_t len) {};
    virtual void free_data(void* data);

protected:
    OFServerSettings ofsc;
    std::map<int, OFConnection*> ofconnections;
    pthread_mutex_t ofconnections_lock;
    
    inline void lock_ofconnections() {
        pthread_mutex_lock(&ofconnections_lock);
    }

    inline void unlock_ofconnections() {
        pthread_mutex_unlock(&ofconnections_lock);
    }

    void base_message_callback(BaseOFConnection* c, void* data, size_t len);
    void base_connection_callback(BaseOFConnection* c, BaseOFConnection::Event event_type);
    static void* send_echo(void* arg);
};

}

#endif