From dc3e77c4284b84b71ddabf1a813b18224b775217 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Mon, 17 Mar 2008 18:48:16 +0000 Subject: finally added callIdQueue (sorry) threads get started @ sync now TODO: cleanup threads and session on daed --- rtpSession.cpp | 21 ++++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) (limited to 'rtpSession.cpp') diff --git a/rtpSession.cpp b/rtpSession.cpp index a547519..3dcc14b 100644 --- a/rtpSession.cpp +++ b/rtpSession.cpp @@ -30,8 +30,11 @@ #include "rtpSession.h" -RtpSession::RtpSession() : in_sync_(false), dead_(false), local_addr_(""), local_port1_(0), local_port2_(0), - remote_addr1_(""), remote_addr2_(""), remote_port1_(0), remote_port2_(0) +#include "anyrtpproxy/callIdQueue.h" + +RtpSession::RtpSession(const std::string& call_id) : in_sync_(false), call_id_(call_id) , dead_(false), complete_(false), + local_addr_("") , local_port1_(0), local_port2_(0), + remote_addr1_(""), remote_addr2_(""), remote_port1_(0), remote_port2_(0) { } @@ -39,7 +42,7 @@ void RtpSession::reinit() { Lock lock(mutex_); -// TODO: inform threads of reinit + gCallIdQueue.push(call_id_); } bool RtpSession::isDead() @@ -54,6 +57,18 @@ bool RtpSession::isDead(bool d) return dead_ = d; } +bool RtpSession::isComplete() +{ + Lock lock(mutex_); + return complete_; +} + +bool RtpSession::isComplete(bool c) +{ + Lock lock(mutex_); + return complete_ = c; +} + std::string RtpSession::getLocalAddr() { Lock lock(mutex_); -- cgit v1.2.3