BaseOFServer.hh

#ifndef __BASEOFSERVER_HH__
#define __BASEOFSERVER_HH__

#include <pthread.h>
#include <string>

#include "EventLoop.hh"
#include "BaseOFConnection.hh"

#include <stdio.h>

namespace fluid_base {

class BaseOFServer : public BaseOFHandler {
public:
    BaseOFServer(const char* address,
                 const int port,
                 const int nevloops = 1,
                 const bool secure = false);
    virtual ~BaseOFServer();

    virtual bool start(bool block = false);

    virtual void stop();

    // BaseOFHandler methods
    virtual void base_connection_callback(BaseOFConnection* conn,
                                          BaseOFConnection::Event event_type);
    virtual void base_message_callback(BaseOFConnection* conn,
                                       void* data,
                                       size_t len) { printf("Calling fake msgcb\n"); };
    virtual void free_data(void* data);
    
private:
    // TODO: hide part of this in LibEventBaseOFServer
    char* address;
    char port[6];

    EventLoop** eventloops;
    EventLoop* main;
    pthread_t* threads;
    bool blocking;
    bool secure;

    int eventloop;
    int nthreads;
    int nconn;

    bool listen(EventLoop* w);
    EventLoop* choose_eventloop();

    class LibEventBaseOFServer;
    friend class LibEventBaseOFServer;
    LibEventBaseOFServer* m_implementation;
};

}

#endif