ptconnection.cpp

来自「基于sipfoundy 公司开发的sipx协议API」· C++ 代码 · 共 783 行 · 第 1/2 页

//
// Copyright (C) 2004, 2005 Pingtel Corp.
// 
//
// $$
////////////////////////////////////////////////////////////////////////
//////


// SYSTEM INCLUDES
#include <assert.h>

#ifdef __pingtel_on_posix__
#include <stdlib.h>
#endif

// APPLICATION INCLUDES
#include "ptapi/PtConnection.h"
#include "ptapi/PtAddress.h"
#include "ptapi/PtCall.h"
#include "ptapi/PtTerminal.h"
#include "ptapi/PtAddress.h"
#include "ptapi/PtTerminalConnection.h"
#include "cp/Connection.h"
#include "cp/CpGatewayManager.h"
#include "os/OsStatus.h"
#include "tao/TaoClientTask.h"
#include "tao/TaoServerTask.h"
#include "tao/TaoEvent.h"
#include "tao/TaoString.h"
#include "net/SipMessage.h"


// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STATIC VARIABLE INITIALIZATIONS
OsBSem               PtConnection::semInit(OsBSem::Q_PRIORITY, OsBSem::FULL) ;
TaoReference            *PtConnection::mpTransactionCnt = 0;
unsigned int            PtConnection::mRef = 0;


/* //////////////////////////// PUBLIC //////////////////////////////////// */

/* ============================ CREATORS ================================== */

// Constructor
PtConnection::PtConnection()
{
        initialize();
        mpClient = 0;
        mState = IDLE;

}

PtConnection::PtConnection(TaoClientTask *pClient, const char* address, const char* callId)
{
        mpClient = pClient;

        if (address)
                mAddress = address;

        if (callId)
                mCallId = callId;

        mState = ESTABLISHED;

        initialize();

        if (mpClient && !(mpClient->isStarted()))
        {
                mpClient->start();
        }
}

// Copy constructor
PtConnection::PtConnection(const PtConnection& rPtConnection)
{
        mAddress = rPtConnection.mAddress;
        mCallId = rPtConnection.mCallId;
        mState = rPtConnection.mState;
        mpClient = rPtConnection.mpClient;

        initialize();
}

// Destructor
PtConnection::~PtConnection()
{
   semInit.acquire() ;
        mRef--;
        if (mRef < 1)
        {
                if(mpTransactionCnt)
                {
                        delete mpTransactionCnt;
                        mpTransactionCnt = 0;
                }
        }
   semInit.release() ;
}

void PtConnection::initialize()
{
        mpEventMgr = OsProtectEventMgr::getEventMgr();
        mTimeOut = OsTime(PT_CONST_EVENT_WAIT_TIMEOUT, 0);
    semInit.acquire() ;

        mRef++;

        if (!mpTransactionCnt)
                mpTransactionCnt = new TaoReference();

   semInit.release() ;

}
/* ============================ MANIPULATORS ============================== */
// Assignment operator
PtConnection&
PtConnection::operator=(const PtConnection& rhs)
{
        if (this == &rhs)            // handle the assignment to self case
          return *this;

        mAddress.remove(0);
        mCallId.remove(0);
        if (!rhs.mAddress.isNull())
                mAddress = rhs.mAddress;
        if (!rhs.mCallId.isNull())
                mCallId = rhs.mCallId;
        mState = rhs.mState;
        mpClient = rhs.mpClient;
        mTimeOut = rhs.mTimeOut;

        return *this;
}

PtStatus PtConnection::accept()
{
        EVENT_TRACE("Entering PtConnection::accept\n") ;
        UtlString arg = mCallId + TAOMESSAGE_DELIMITER + mAddress;

        mpTransactionCnt->add();
        unsigned int transactionId = mpTransactionCnt->getRef();

        OsProtectedEvent *pe = mpEventMgr->alloc();
        TaoMessage      msg(TaoMessage::REQUEST_CONNECTION,
                                                                        TaoMessage::ACCEPT,
                                                                        transactionId,
                                                                        0,
                                                                        (TaoObjHandle)pe,
                                                                        2,
                                                                        arg);
        mpClient->sendRequest(msg);

        int rc;
        if (OS_SUCCESS != pe->wait(msg.getCmd(), mTimeOut))
        {
                mpClient->resetConnectionSocket(msg.getMsgID());
        // If the event has already been signalled, clean up
        if(OS_ALREADY_SIGNALED == pe->signal(0))
        {
            mpEventMgr->release(pe);
        }
                return PT_BUSY;
        }

        pe->getEventData((int &)rc);
#ifdef PTAPI_TEST
        int cmd;
        pe->getIntData2(cmd);
        assert(cmd == TaoMessage::ACCEPT);
#endif
        mpEventMgr->release(pe);
        EVENT_TRACE("Exiting PtConnection::accept\n") ;

        return PT_SUCCESS;
}

PtStatus PtConnection::disconnect()
{
        EVENT_TRACE("Entering PtConnection::disconnect\n") ;

        mpTransactionCnt->add();
        unsigned int transactionId = mpTransactionCnt->getRef();

        UtlString arg(mCallId);

        arg += TAOMESSAGE_DELIMITER + mAddress;

        OsProtectedEvent *pe = mpEventMgr->alloc();
        TaoMessage      msg(TaoMessage::REQUEST_CONNECTION,
                                                                        TaoMessage::DISCONNECT,
                                                                        transactionId,
                                                                        0,
                                                                        (TaoObjHandle)pe,
                                                                        2,
                                                                        arg);
        mpClient->sendRequest(msg);

        int rc;
        if (OS_SUCCESS != pe->wait(msg.getCmd(), mTimeOut))
        {
                mpClient->resetConnectionSocket(msg.getMsgID());
        // If the event has already been signalled, clean up
        if(OS_ALREADY_SIGNALED == pe->signal(0))
        {
            mpEventMgr->release(pe);
        }
                return PT_BUSY;
        }

        pe->getEventData((int &)rc);
#ifdef PTAPI_TEST
        int cmd;
        pe->getIntData2(cmd);
        assert(cmd == TaoMessage::DISCONNECT);
#endif
        mpEventMgr->release(pe);

        mState = DISCONNECTED;
        EVENT_TRACE("Exiting PtConnection::disconnect\n") ;

        return PT_SUCCESS;
}

PtStatus PtConnection::getTerminalConnections(PtTerminalConnection termConnections[],
                                                                                           int size,
                                                                                           int& nItems)
{
        EVENT_TRACE("Entering PtConnection::getTerminalConnections\n") ;
        PtStatus statusRC = PT_NO_MORE_DATA ;
        UtlString arg = mCallId + TAOMESSAGE_DELIMITER + mAddress;

        mpTransactionCnt->add();
        unsigned int transactionId = mpTransactionCnt->getRef();

        OsProtectedEvent *pe = mpEventMgr->alloc();
        TaoMessage      msg(TaoMessage::REQUEST_CONNECTION,
                                                                        TaoMessage::GET_TERM_CONNECTIONS,
                                                                        transactionId,
                                                                        0,
                                                                        (TaoObjHandle)pe,
                                                                        2,
                                                                        arg);
        mpClient->sendRequest(msg);

        arg.remove(0);
        if (OS_SUCCESS != pe->wait(msg.getCmd(), mTimeOut))
        {
                mpClient->resetConnectionSocket(msg.getMsgID());
                EVENT_TRACE("Exiting PtConnection::getTerminalConnections: TIME OUT!!\n") ;
        // If the event has already been signalled, clean up
        if(OS_ALREADY_SIGNALED == pe->signal(0))
        {
            mpEventMgr->release(pe);
        }
                return PT_BUSY;
        }

        pe->getStringData((UtlString &)arg);
#ifdef PTAPI_TEST
        int cmd;
        pe->getIntData2(cmd);
        assert(cmd == TaoMessage::GET_TERM_CONNECTIONS);
#endif
        mpEventMgr->release(pe);

        TaoString argList(arg, TAOMESSAGE_DELIMITER);

        nItems = (argList.getCnt() - 2) / 2 ;

        int cnt = (nItems > size) ? size : nItems ;

        nItems = 0;
        for (int i = 0; i < cnt; i++)
        {
                int j = 2 * i;
                int isLocal = atoi(argList[j + 3]);
                PtTerminalConnection tc = PtTerminalConnection(mpClient,
                                                                                                           mAddress.data(),
                                                                                                           argList[i+2],
                                                                                                           mCallId.data(),
                                                                                                           isLocal);
#ifdef TEST
                osPrintf("~~~ PtConnection::getTerminalConnections connection %s terminal %s is local: %d ~~~\n", mAddress.data(), argList[j+2].data(), isLocal);
#endif
                termConnections[nItems++] = tc;
                statusRC = PT_SUCCESS ;
        }

#ifdef TEST
        osPrintf("~~~ number of tc %d ~~~\n", nItems);
#endif

        EVENT_TRACE("Exiting PtConnection::getTerminalConnections\n") ;
        return statusRC ;
}


PtStatus PtConnection::getAddress(PtAddress& rAddress)
{
        EVENT_TRACE("Entering PtConnection::getAddress\n") ;
        PtStatus rc = PT_SUCCESS;
        if (mpClient && !mAddress.isNull())
        {
                rAddress = PtAddress(mpClient, mAddress.data());
        }
        else
        {
                rc = PT_NO_MORE_DATA;
        }

        EVENT_TRACE("Exiting PtConnection::getAddress\n") ;
        return rc;
}

PtStatus PtConnection::getCall(PtCall& rCall)
{
        EVENT_TRACE("Entering PtConnection::getCall\n") ;
        PtStatus rc = PT_SUCCESS;
        if (mpClient && !mCallId.isNull())
        {
                rCall = PtCall(mpClient, mCallId.data());
        }
        else
        {
                rc = PT_NO_MORE_DATA;
        }
        EVENT_TRACE("Exiting PtConnection::getCall\n");
        return rc;
}

PtStatus PtConnection::getSessionInfo(PtSessionDesc& rSession)
{
        EVENT_TRACE("Entering PtCall::getSessionInfo:\n") ;
        PtStatus ret = PT_FAILED;

        UtlString arg = mCallId + TAOMESSAGE_DELIMITER + mAddress;

        mpTransactionCnt->add();
        unsigned int transactionId = mpTransactionCnt->getRef();

        OsProtectedEvent *pe = mpEventMgr->alloc();
        TaoMessage      msg(TaoMessage::REQUEST_CONNECTION,
                                                                        TaoMessage::GET_SESSION_INFO,
                                                                        transactionId,
                                                                        0,
                                                                        (TaoObjHandle)pe,
                                                                        2,
                                                                        arg);
        mpClient->sendRequest(msg);

        arg.remove(0);
        if (OS_SUCCESS != pe->wait(msg.getCmd(), mTimeOut))
        {
                mpClient->resetConnectionSocket(msg.getMsgID());
        // If the event has already been signalled, clean up
        if(OS_ALREADY_SIGNALED == pe->signal(0))
        {
            mpEventMgr->release(pe);
        }
                return PT_BUSY;
        }

        pe->getStringData((UtlString &)arg);
#ifdef PTAPI_TEST
        int cmd;
        pe->getIntData2(cmd);
        assert(cmd == TaoMessage::GET_FROM_FIELD);
#endif
        mpEventMgr->release(pe);

        TaoString argList(arg, TAOMESSAGE_DELIMITER);

        if (argList.getCnt() == 7)
        {
                rSession = PtSessionDesc(mCallId,
                                                                 argList[0],                    //toUrl
                                                                 argList[1],                    //fromUrl
                                                                 argList[2],    // localContact
                                                                 atoi(argList[3]),      // next CSeq
                                                                 atoi(argList[4]),      // lastFromCseq
                                                                 atoi(argList[5]),      // lastToCseq
                         atoi(argList[6]));     // sessionState

                ret = PT_SUCCESS;
        }

        EVENT_TRACE("Exiting PtCall::getSessionInfo\n") ;
        return ret;
}