diff options
Diffstat (limited to 'anyrtpproxy/anyrtpproxy.cpp')
-rw-r--r-- | anyrtpproxy/anyrtpproxy.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/anyrtpproxy/anyrtpproxy.cpp b/anyrtpproxy/anyrtpproxy.cpp index 9079994..3b0c488 100644 --- a/anyrtpproxy/anyrtpproxy.cpp +++ b/anyrtpproxy/anyrtpproxy.cpp @@ -35,8 +35,8 @@ public: private: Mutex mutex; - std::map<ControlHost, std::pair<UDPSocket*, pthread_t>> control_hosts_; -} + std::map<ControlHost, std::pair<UDPSocket*, pthread_t> > control_hosts_; +}; void* sender(void* dont_use_me) { @@ -50,10 +50,10 @@ void* sender(void* dont_use_me) u_int16_t remote_port; while(1) { buf.setLength(MAX_PACKET_SIZE); - u_int32_t len = control_sock_.recvFrom(buf.getBuf(), buf.getLength(), remote_host, remote_port); + u_int32_t len = control_sock.recvFrom(buf.getBuf(), buf.getLength(), remote_host, remote_port); buf.setLength(len); - param->control_.setHost(remote_host, remote_port); +//TODO????//TODO????//TODO????//TODO????//TODO????//TODO????//TODO???? control.setHost(remote_host, remote_port); // SenderThreadParam receiverParam = {control_host, control_sock, sock, gOpt.getRemoteHosts().front()}; // pthread_t receiverThread; @@ -62,8 +62,8 @@ void* sender(void* dont_use_me) HostList::const_iterator it = remote_host_list.begin(); - for(;it != remote_host_list.end(); it++) - param->sock_.sendTo(buf.getBuf(), buf.getLength(), it->addr_, it->port_); +// for(;it != remote_host_list.end(); it++) +// param->sock_.sendTo(buf.getBuf(), buf.getLength(), it->addr_, it->port_); } } catch(std::exception &e) |