anyrtpproxy bugfix

3 files changed, 2 insertions, 7 deletions

diff --git a/anyrtpproxy/anyrtpproxy.cpp b/anyrtpproxy/anyrtpproxy.cpp
index 9501dfc..ac2670a 100644
--- a/anyrtpproxy/anyrtpproxy.cpp
+++ b/anyrtpproxy/anyrtpproxy.cpp
@@ -124,13 +124,10 @@ void* listener(void* p)
 			}
 
       if(param->dir_ == 1)
-			{
         param->sock2_.sendTo(buf.getBuf(), buf.getLength(), session.getRemoteAddr2(), session.getRemotePort2());
-			}
       else if(param->dir_ == 2)
-			{
         param->sock1_.sendTo(buf.getBuf(), buf.getLength(), session.getRemoteAddr1(), session.getRemotePort1());
-			}
+      else break;
     }  
   }
   catch(std::exception &e)
diff --git a/anyrtpproxy/commandHandler.cpp b/anyrtpproxy/commandHandler.cpp
index 76134f1..032d001 100644
--- a/anyrtpproxy/commandHandler.cpp
+++ b/anyrtpproxy/commandHandler.cpp
@@ -188,8 +188,6 @@ string CommandHandler::handleRequest(string modifiers, string call_id, string ad
     iss >> rport;
     session.setRemotePort1(rport);
     session.setRemoteAddr1(addr);
-    SyncCommand sc(call_id);
-    queue_.push(sc);
 
     ostringstream oss;
     oss << session.getLocalPort2();
diff --git a/rtpSession.h b/rtpSession.h
index 8fa73f7..0102f7e 100644
--- a/rtpSession.h
+++ b/rtpSession.h
@@ -95,7 +95,7 @@ private:
 		ar & seen1_;
 		ar & seen2_;
 
-    if(complete_)
+    if(complete_ && !dead_)
       reinit();
 
     in_sync_ = true;