sipbasetransactionid.hxx

Vovida 社区开源的 SIP 协议源码

#ifndef SIPBASETRANSACTIONID_HXX_
#define SIPBASETRANSACTIONID_HXX_

/* ====================================================================
 * The Vovida Software License, Version 1.0 
 * 
 * Copyright (c) 2000 Vovida Networks, Inc.  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. The names "VOCAL", "Vovida Open Communication Application Library",
 *    and "Vovida Open Communication Application Library (VOCAL)" must
 *    not be used to endorse or promote products derived from this
 *    software without prior written permission. For written
 *    permission, please contact [e-mail].
 *
 * 4. Products derived from this software may not be called "VOCAL", nor
 *    may "VOCAL" appear in their name, without prior written
 *    permission of Vovida Networks, Inc.
 * 
 * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
 * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
 * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
 * IN EXCESS OF $1,000, NOR FOR ANY 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.
 * 
 * ====================================================================
 * 
 * This software consists of voluntary contributions made by Vovida
 * Networks, Inc. and many individuals on behalf of Vovida Networks,
 * Inc.  For more information on Vovida Networks, Inc., please see
 * <http://www.vovida.org/>.
 *
 */

static const char* const SipTransactionId_hxx_Version =
    "$Id: SipBaseTransactionId.hxx,v 1.4.24.1 2003/01/15 21:37:28 sprajpat Exp $";

#include "global.h"
#include "Data.hxx"
#include "SipCallId.hxx"
#include "SipCSeq.hxx"
#include "Sptr.hxx"
#include "SipMsg.hxx"
#include "Md5.hxx"

#if defined(__linux__)
#include <hash_map>
#endif

namespace Vocal
{

using Crypto::Md5;

/// data container for TransactionId header
class SipBaseTransactionId
{
    public:
        /// Create one with default values
        SipBaseTransactionId();
        ///
        SipBaseTransactionId(const SipMsg&, bool useVia = true);
        ///
        SipBaseTransactionId(const SipBaseTransactionId& other);

        ///
        void setToTag(const Data& toTag);

	/// get the To tag
	Data getToTag() const;

        ///
        void setFromTag(const Data& fromTag);

        ///
        bool operator == (const SipBaseTransactionId& other) const;
        ///
        bool operator < (const SipBaseTransactionId& other) const;
        ///
        bool operator > (const SipBaseTransactionId& other) const;
        ///
        const SipBaseTransactionId& operator =(const SipBaseTransactionId& src);
    
        ///
        void print() const;
        ///
	Data getSummary() const;
       
        void printComparison( const SipBaseTransactionId& other) const;
	///
        void replaceCSeqMethod( Method method );
        ///
        bool toBeDeleted(time_t timeNow) const ;

	///compare two transactionids, omitting the Via
	bool compareOmitVia(const SipBaseTransactionId& other) const;
	

	///
	size_t hashfn() const;
    private:
	void setMethodFromData(const Data& data);
	///
	Md5 mySum;
	///
	Data myToTag;
	///
	Data myFromTag;
	///
	Data myMethod;
        ///
	Data myViaHost;
        ///
	Data myViaPort;
        ///
	Data myBranchTag;

	///
        time_t myTimeCreated;
};

#if defined(__linux__)
struct hash<SipBaseTransactionId>
{
	inline size_t  
	operator()(const SipBaseTransactionId& s) const 
	{
	    return s.hashfn();
	}
};
#endif


inline
size_t
SipBaseTransactionId::hashfn() const
{
    return mySum.hashfn();
}


inline
SipBaseTransactionId::SipBaseTransactionId()
{
}


inline
SipBaseTransactionId::SipBaseTransactionId(const SipMsg& msg, bool useVia)
{
    Data data = msg.getCallId().getData();
    data += "|";
    data += msg.getCSeq().getCSeqData();
    data += "|";
    data += msg.getTo().getUrl()->getUniqueKey();
    data += "|";
    data += msg.getFrom().getUrl()->getUniqueKey();

    mySum.digest(data);
    myToTag = msg.getTo().getTag();
    myFromTag = msg.getFrom().getTag();
    myMethod = msg.getCSeq().getMethod();
    myViaHost = msg.getVia(0).getHost();
    myViaPort = msg.getVia(0).getPort();
    myBranchTag = msg.getVia(0).getBranch();

    cpLog(LOG_DEBUG_STACK,"TransID is digest[%s] ToTag[%s]...",data.getData(),myToTag.getData());
}


inline
SipBaseTransactionId::SipBaseTransactionId(const SipBaseTransactionId& other)
    :
    mySum(other.mySum),
    myToTag(other.myToTag),
    myFromTag(other.myFromTag),
    myMethod(other.myMethod),
    myViaHost(other.myViaHost),
    myViaPort(other.myViaPort),
    myBranchTag(other.myBranchTag),
    myTimeCreated(other.myTimeCreated)
{
}


inline void 
SipBaseTransactionId::setToTag(const Data& toTag)
{
    myToTag = toTag;
}


inline Data 
SipBaseTransactionId::getToTag() const
{
    return myToTag;
}


inline void 
SipBaseTransactionId::setFromTag(const Data& fromTag)
{
    myFromTag = fromTag;
}

inline void 
SipBaseTransactionId::replaceCSeqMethod( Method method )
{
    switch (method)
    {
        case SIP_INVITE:
        {
            myMethod = INVITE_METHOD;
            break;
        }
        case SIP_ACK:
        {
            myMethod = ACK_METHOD;
            break;
        }
        case SIP_CANCEL:
        {
            myMethod = CANCEL_METHOD;
            break;
        }
        case SIP_BYE:
        {
            myMethod = BYE_METHOD;
            break;
        }
        case SIP_INFO:
        {
            myMethod = INFO_METHOD;
            break;
        }
        case SIP_REGISTER:
        {
            myMethod = REGISTER_METHOD;
            break;
        }
        case SIP_OPTIONS:
        {
            myMethod = OPTIONS_METHOD;
            break;
        }
        case SIP_TRANSFER:
        {
            myMethod = TRANSFER_METHOD;
            break;
        }
        case SIP_SUBSCRIBE:
        {
            myMethod = SUBSCRIBE_METHOD;
            break;
        }
        case SIP_NOTIFY:
        {
            myMethod = NOTIFY_METHOD;
            break;
        }
        default:
        {
            break;
        }
    }//end switch
}


inline bool
SipBaseTransactionId::operator == (const SipBaseTransactionId& other) const
{
    if(&other == this)
    {
	return true;
    }
    else
    {
	return ((mySum == other.mySum) &&
		(myToTag == other.myToTag) &&
		(myFromTag == other.myFromTag) &&
		(myMethod == other.myMethod) &&
		(myViaHost == other.myViaHost) &&
		(myViaPort == other.myViaPort) &&
		(myBranchTag == other.myBranchTag)
	    );
    }
}

inline bool
SipBaseTransactionId::operator < (const SipBaseTransactionId& other) const
{
    if(&other == this)
    {
	return false;
    }
    else
    {
	if(mySum < other.mySum)
	    return true;
	else if (mySum > other.mySum)
	    return false;
	else if(myToTag < other.myToTag)
	    return true;
	else if(myToTag > other.myToTag)
	    return false;
	else if(myFromTag < other.myFromTag)
	    return true;
	else if(myFromTag > other.myFromTag)
	    return false;
	else if(myMethod < other.myMethod)
	    return true;
	else if(myMethod > other.myMethod)
	    return false;
	else if(myViaHost < other.myViaHost)
	    return true;
	else if(myViaHost > other.myViaHost)
	    return false;
	else if(myViaPort < other.myViaPort)
	    return true;
	else if(myViaPort > other.myViaPort)
	    return false;
	else if(myBranchTag < other.myBranchTag)
	    return true;
	else if(myBranchTag > other.myBranchTag)
	    return false;
	else
	    return false;
    }

}


inline bool
SipBaseTransactionId::operator > (const SipBaseTransactionId& other) const
{
    if(&other == this)
    {
	return false;
    }
    else
    {
	if(mySum < other.mySum)
	    return false;
	else if (mySum > other.mySum)
	    return true;
	else if(myToTag < other.myToTag)
	    return false;
	else if(myToTag > other.myToTag)
	    return true;
	else if(myFromTag < other.myFromTag)
	    return false;
	else if(myFromTag > other.myFromTag)
	    return true;
	else if(myMethod < other.myMethod)
	    return false;
	else if(myMethod > other.myMethod)
	    return true;
	else if(myViaHost < other.myViaHost)
	    return false;
	else if(myViaHost > other.myViaHost)
	    return true;
	else if(myViaPort < other.myViaPort)
	    return false;
	else if(myViaPort > other.myViaPort)
	    return true;
	else if(myBranchTag < other.myBranchTag)
	    return false;
	else if(myBranchTag > other.myBranchTag)
	    return true;
	else
	    return false;
    }
}


inline const SipBaseTransactionId& 
SipBaseTransactionId::operator =(const SipBaseTransactionId& src)
{
    if(&src != this)
    {
	mySum = src.mySum;
	myToTag = src.myToTag; 
	myFromTag = src.myFromTag;
	myMethod = src.myMethod; 
	myTimeCreated = src.myTimeCreated;
	myViaHost = src.myViaHost;
	myViaPort = src.myViaPort;
	myBranchTag = src.myBranchTag;
	
    }
    return *this;
}

       
inline void
SipBaseTransactionId::printComparison( const SipBaseTransactionId& other) const
{

}


inline bool 
SipBaseTransactionId::toBeDeleted(time_t timeNow) const
{
    return false;
}


inline bool 
SipBaseTransactionId::compareOmitVia(const SipBaseTransactionId& other) const
{
    if(&other == this)
    {
	return true;
    }
    else
    {
	return ((mySum == other.mySum) &&
		(myToTag == other.myToTag) &&
		(myFromTag == other.myFromTag) &&
		(myMethod == other.myMethod));
    }
}
 
} // namespace Vocal

/* Local Variables: */
/* c-file-style: "stroustrup" */
/* indent-tabs-mode: nil */
/* c-file-offsets: ((access-label . -) (inclass . ++)) */
/* c-basic-offset: 4 */
/* End: */

#endif