#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;

/** MKControl sends and receives data with
 * the command and control protocol */
class MKControl {
public:

	~MKControl();

	/** Start the command and control and return a new instance */
	static MKControl *start(MKCommModel *model);
	static void *initThread(void *);

private:

	enum { kMsgBufSize = 65000 };

	MKControl(MKCommModel *);

	void begin(); // start

	MKCommModel *model;
	pthread_t thread;

};

#endif