~ubuntu-branches/ubuntu/saucy/resiprocate/saucy-proposed

 

 

#include <syslog.h>

 

#include "B2BCallManager.hxx"

#include "Logging.hxx"

 

using namespace b2bua;

using namespace resip;

using namespace std;

 

B2BCallManager::B2BCallManager(resip::DialogUsageManager& dum, AuthorizationManager *authorizationManager, CDRHandler& cdrHandler) : dum(dum), authorizationManager(authorizationManager), cdrHandler(cdrHandler) {

  stopping = false;

  mustStopCalls = false;

}

 

B2BCallManager::~B2BCallManager() {

}

 

void B2BCallManager::setAuthorizationManager(AuthorizationManager *authorizationManager) {

  this->authorizationManager = authorizationManager;

}

 

TaskManager::TaskResult B2BCallManager::doTaskProcessing() {

  time_t now;

 

  if(mustStopCalls) {

    B2BUA_LOG_NOTICE("notifying calls to stop");

    list<B2BCall *>::iterator call = calls.begin();

    while(call != calls.end()) {

      (*call)->onStopping();

      call++;

    }

    mustStopCalls = false;

  }

 

  time(&now);

  list<B2BCall *>::iterator i = calls.begin();

  while(i != calls.end()) {

    (*i)->checkProgress(now, stopping);

    if((*i)->isComplete()) {

      B2BCall *call = *i;

      i++;

      calls.remove(call);

      delete call;

    } else

      i++;

  }

  if(stopping && calls.begin() == calls.end()) {

    B2BUA_LOG_NOTICE("no (more) calls in progress");

    return TaskManager::TaskComplete;

  }

  return TaskManager::TaskNotComplete;

}

 

void B2BCallManager::stop() {

  stopping = true;

  mustStopCalls = true;

}

 

bool B2BCallManager::isStopping() {

  return stopping;

}

 

void B2BCallManager::onNewCall(MyAppDialog *aLegDialog, const resip::NameAddr& sourceAddr, const resip::Uri& destinationAddr, const resip::Data& authRealm, const resip::Data& authUser, const resip::Data& authPassword, const resip::Data& srcIp, const resip::Data& contextId, const resip::Data& accountId, const resip::Data& baseIp, const resip::Data& controlId) {

 

  B2BCall *call = new B2BCall(cdrHandler, dum, *authorizationManager, aLegDialog, sourceAddr, destinationAddr, authRealm, authUser, authPassword, srcIp, contextId, accountId, baseIp, controlId);

 

  calls.push_back(call);

 

}

 

void B2BCallManager::logStats() {

  int preDial = 0, dialing = 0, connected = 0, finishing = 0, unknown = 0;

  list<B2BCall *>::iterator call = calls.begin();

  while(call != calls.end()) {

    switch((*call)->getStatus()) {

    case B2BCall::PreDial:

      preDial++;

      break;

    case B2BCall::Dialing:

      dialing++;

      break;

    case B2BCall::Connected:

      connected++;

      break;

    case B2BCall::Finishing:

      finishing++;

      break;

    default:

      unknown++;

      break;

    }

    call++;

  }

  B2BUA_LOG_NOTICE("call info: preDial = %d, dialing = %d, connected = %d, finishing = %d, unknown = %d, total = %d", preDial, dialing, connected, finishing, unknown, (preDial + dialing + connected + finishing + unknown));

}

 

/* ====================================================================

 *

 * Copyright 2012 Daniel Pocock.  All rights reserved.

 *

 * Redistribution and use in source and binary forms, with or without

 * modification, are permitted provided that the following conditions

 * are met:

 *

 * 1. Redistributions of source code must retain the above copyright

 *    notice, this list of conditions and the following disclaimer.

 *

 * 2. Redistributions in binary form must reproduce the above copyright

 *    notice, this list of conditions and the following disclaimer in

 *    the documentation and/or other materials provided with the

 *    distribution.

 *

 * 3. Neither the name of the author(s) nor the names of any contributors

 *    may be used to endorse or promote products derived from this software

 *    without specific prior written permission.

 *

 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR(S) AND CONTRIBUTORS "AS IS" AND

 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE

 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR(S) OR CONTRIBUTORS BE LIABLE

 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS

 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)

 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY

 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF

 * SUCH DAMAGE.

 *

 * ====================================================================

 *

 *

 */