summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--anyrtpproxy/anyrtpproxy.cpp2
-rw-r--r--anyrtpproxy/commandHandler.cpp2
-rw-r--r--rtpSession.h6
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;