summaryrefslogtreecommitdiff
path: root/anyrtpproxy
diff options
context:
space:
mode:
Diffstat (limited to 'anyrtpproxy')
-rw-r--r--anyrtpproxy/anyrtpproxy.cpp5
-rw-r--r--anyrtpproxy/commandHandler.cpp2
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();