From b9ae5e0ed6e4238c7410265ed5530931d4552f7d Mon Sep 17 00:00:00 2001 From: Othmar Gsenger Date: Sat, 8 Mar 2008 18:39:15 +0000 Subject: added SyncRtpCommand --- anyrtpproxy/anyrtpproxy.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'anyrtpproxy/anyrtpproxy.cpp') 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> control_hosts_; -} + std::map > 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) -- cgit v1.2.3