From 92efa896ace2c1ef6e1a356ba7d2e38294583f7e Mon Sep 17 00:00:00 2001
From: Christian Pointner <equinox@anytun.org>
Date: Tue, 18 Mar 2008 19:49:38 +0000
Subject: anyrtpproxy bugfix

---
 anyrtpproxy/anyrtpproxy.cpp    | 5 +----
 anyrtpproxy/commandHandler.cpp | 2 --
 rtpSession.h                   | 2 +-
 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;
-- 
cgit v1.2.3