anyrtpproxy bugfix

2 files changed, 1 insertions, 6 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();