recv.h

Go to the documentation of this file.

#ifndef UDP_BC_BROKER_RECV_H_
#define UDP_BC_BROKER_RECV_H_

#include <iostream>
#include <stdio.h>
#include <vector>
#include <sys/socket.h>
#include <unistd.h>
#include <sys/types.h>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <boost/function.hpp>
#include <boost/bind.hpp>
#include <boost/thread.hpp>

using namespace std;

namespace udp_bc_broker{

    class UdpRecver {
        public:
            UdpRecver(int port);
            ~UdpRecver();
            void receive(boost::function<void(const vector<uint8_t>&)> callBack);
        private:
            void process_msg();
            boost::function<void(const vector<uint8_t>&)> callback;
            int sock;
            struct sockaddr_in addrto;
            struct sockaddr_in from;
            int nlen;
            int len;
            char *buf;
            boost::thread* process_thread_;
    };
};

#endif