BinaryProtocol.h

См. документацию.

#ifndef BINARYPROTOCOL_H_
#define BINARYPROTOCOL_H_

#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <pthread.h>
#include <string>
#include <iostream>
#include <list>
#include <map>
#include "BPHandler.h"
#include "BinaryPacket.h"
#include "BufferFiller.h"
#include "../BaseConfigFile.h"
using namespace std;
//void* client_threadFunc(void* clnt);
//typedef void (BibaryPacket::*packetRecerver);
//static pthread_mutex_t cs_mutex3 = PTHREAD_MUTEX_INITIALIZER;
//static pthread_mutex_t cs_mutex4 = PTHREAD_MUTEX_INITIALIZER;
//template <class Listener_T>
class BinaryProtocol{
protected:
        pthread_mutex_t exit_mutex;
        pthread_mutex_t cs_mutex4;
        pthread_mutex_t cs_mutex3;
        pthread_attr_t attr;
        size_t max_pktsize;
        BaseConfigFile* cf;
        int skt_id;
        pthread_t clientThread;//TODO разобраться почему ЭТО не в клиенте
        pthread_t binThread;
        void parse();
        list<BPHandler*> handlers;
        map<unsigned long int,BufferFiller*> bufferFillers;
public:
    //typedef void (Listener_T::*packetRecerver)(BibaryPacket);
        BibaryPacket readPacket();
        ssize_t readToBuffer(void* buffer, size_t length);
        BinaryProtocol(BaseConfigFile* cf);
        void disconnect(){};
        static unsigned long int getNextId();//{return ++pktID;}
        //void setRecervedPacketFunc(packetRecerver func,unsigned short pktID){};
        void sendBuffer(const void* buffer, int length);
        void sendPacket(BibaryPacket packet);
        void addHandler(BPHandler* h){handlers.push_back(h);}
        void setFillBuffer(void* buffer,size_t size,unsigned long int pktID);
        void waiteFillBuffer(unsigned int pktID);
        void setSendBufferData(const void* buffer,size_t size,unsigned long int pktID);
        void startTread(int skt_id);
        //void sendPacket(int size, void *data){};
        virtual ~BinaryProtocol();
        friend void* bin_client_threadFunc(void* clnt);
        friend void* binary_threadFunc(void* clnt);
};

#endif /*BINARYPROTOCOL_H_*/