finally added callIdQueue (sorry)

threads get started @ sync now
TODO: cleanup threads and session on daed

1 files changed, 4 insertions, 18 deletions

diff --git a/rtpSessionTable.cpp b/rtpSessionTable.cpp
index 8b361a4..5beb3d6 100644
--- a/rtpSessionTable.cpp
+++ b/rtpSessionTable.cpp
@@ -54,21 +54,7 @@ RtpSessionTable::~RtpSessionTable()
 {
 } 
 
-void RtpSessionTable::addSession(const std::string & call_id, RtpSession* ses )
-{
-  Lock lock(mutex_);
-	
-	
-  std::pair<RtpSessionMap::iterator, bool> ret = map_.insert(RtpSessionMap::value_type(call_id,ses));
-  if(!ret.second)
-  {
-    map_.erase(ret.first);
-    map_.insert(RtpSessionMap::value_type(call_id,ses));
-  }
-}
-
-
-void RtpSessionTable::delSession(const std::string & call_id )
+void RtpSessionTable::delSession(const std::string & call_id)
 {
   Lock lock(mutex_);
 
@@ -93,9 +79,9 @@ RtpSession& RtpSessionTable::getOrNewSessionUnlocked(const std::string & call_id
     return *(it->second);
 
   is_new = true;
-  map_.insert(RtpSessionMap::value_type(call_id, new RtpSession()));
-  it = map_.find(call_id);
-  return *(it->second);
+  std::pair<RtpSessionMap::iterator, bool> ret = map_.insert(RtpSessionMap::value_type(call_id, NULL));
+  ret.first->second = new RtpSession(ret.first->first);
+  return *(ret.first->second);
 }
 
 RtpSession& RtpSessionTable::getSession(const std::string & call_id)