#include <recv.h>
Public Member Functions | |
void | receive (boost::function< void(const vector< uint8_t > &)> callBack) |
UdpRecver (int port) | |
~UdpRecver () | |
Private Member Functions | |
void | process_msg () |
Private Attributes | |
struct sockaddr_in | addrto |
char * | buf |
boost::function< void(const vector< uint8_t > &)> | callback |
struct sockaddr_in | from |
int | len |
int | nlen |
boost::thread * | process_thread_ |
int | sock |
udp_bc_broker::UdpRecver::UdpRecver | ( | int | port | ) |
void udp_bc_broker::UdpRecver::process_msg | ( | ) | [private] |
void udp_bc_broker::UdpRecver::receive | ( | boost::function< void(const vector< uint8_t > &)> | callBack | ) |
struct sockaddr_in udp_bc_broker::UdpRecver::addrto [private] |
char* udp_bc_broker::UdpRecver::buf [private] |
boost::function<void(const vector<uint8_t>&)> udp_bc_broker::UdpRecver::callback [private] |
struct sockaddr_in udp_bc_broker::UdpRecver::from [private] |
int udp_bc_broker::UdpRecver::len [private] |
int udp_bc_broker::UdpRecver::nlen [private] |
boost::thread* udp_bc_broker::UdpRecver::process_thread_ [private] |
int udp_bc_broker::UdpRecver::sock [private] |