diff options
| -rw-r--r-- | anyrtpproxy/anyrtpproxy.cpp | 2 | ||||
| -rw-r--r-- | anyrtpproxy/commandHandler.cpp | 2 | ||||
| -rw-r--r-- | rtpSession.h | 6 |
3 files changed, 2 insertions, 8 deletions
diff --git a/anyrtpproxy/anyrtpproxy.cpp b/anyrtpproxy/anyrtpproxy.cpp index a0f94fa..9501dfc 100644 --- a/anyrtpproxy/anyrtpproxy.cpp +++ b/anyrtpproxy/anyrtpproxy.cpp @@ -201,7 +201,7 @@ void* listenerManager(void* dont_use_me) gRtpSessionTable.delSession(call_id); continue; } - // TODO: reinit if session is changed or cleanup if it is daed + // TODO: reinit if session changed } } catch(std::exception &e) diff --git a/anyrtpproxy/commandHandler.cpp b/anyrtpproxy/commandHandler.cpp index 78cff4b..76134f1 100644 --- a/anyrtpproxy/commandHandler.cpp +++ b/anyrtpproxy/commandHandler.cpp @@ -218,8 +218,6 @@ string CommandHandler::handleResponse(string modifiers, string call_id, string a SyncCommand sc(call_id); queue_.push(sc); - gCallIdQueue.push(call_id); - ostringstream oss; oss << session.getLocalPort1(); return oss.str(); diff --git a/rtpSession.h b/rtpSession.h index 16b0e5b..8fa73f7 100644 --- a/rtpSession.h +++ b/rtpSession.h @@ -83,10 +83,6 @@ private: { Lock lock(mutex_); - std::string old_local_addr = local_addr_; - u_int16_t old_local_port1 = local_port1_; - u_int16_t old_local_port2 = local_port2_; - ar & dead_; ar & complete_; ar & local_addr_; @@ -99,7 +95,7 @@ private: ar & seen1_; ar & seen2_; - if(old_local_port1 != local_port1_ || old_local_port2 != local_port2_ || old_local_addr != local_addr_) + if(complete_) reinit(); in_sync_ = true; |