MKControl.h

#ifndef MKCONTROL_H
#define MKCONTROL_H

#include <stdint.h>
#include <pthread.h>
#include <vector>
#include <map>

#include "include/bson/bson.h"

#include "include/commmodel.hpp"
#include "MKConfig.h"
#include "MKRequest.h"

class MKCommModel;

class MKControl {
public:

        ~MKControl();

        static MKControl *start(MKCommModel *model);
        static void *initThread(void *);

private:

        enum { kMsgBufSize = 65000 };

        MKControl(MKCommModel *);

        void begin(); // start

        MKCommModel *model;
        pthread_t thread;

};

#endif