📄 sipmessage.cxx
字号:
// empty?
if (hfvs == 0)
{
// create the list with a new component
hfvs = new HeaderFieldValueList;
mHeaders[type] = hfvs;
if (single)
{
HeaderFieldValue* hfv = new HeaderFieldValue;
hfvs->push_back(hfv);
}
}
// !dlb! not thrilled about checking this every access
else if (single)
{
if (hfvs->parsedEmpty())
{
// create an unparsed shared header field value // !dlb! when will this happen?
hfvs->push_back(new HeaderFieldValue(Data::Empty.data(), 0));
}
}
return hfvs;
}
HeaderFieldValueList*
SipMessage::ensureHeaders(Headers::Type type, bool single) const
{
HeaderFieldValueList* hfvs = mHeaders[type];
// empty?
if (hfvs == 0)
{
// header missing
// assert(false);
InfoLog( << "Missing Header [" << Headers::getHeaderName(type) << "]");
DebugLog (<< *this);
throw Exception("Missing header " + Headers::getHeaderName(type), __FILE__, __LINE__);
}
// !dlb! not thrilled about checking this every access
else if (single)
{
if (hfvs->parsedEmpty())
{
// !dlb! when will this happen?
// assert(false);
InfoLog( << "Missing Header " << Headers::getHeaderName(type) );
DebugLog (<< *this);
throw Exception("Empty header", __FILE__, __LINE__);
}
}
return hfvs;
}
// type safe header accessors
bool
SipMessage::exists(const HeaderBase& headerType) const
{
return mHeaders[headerType.getTypeNum()] != 0;
};
void
SipMessage::remove(const HeaderBase& headerType)
{
delete mHeaders[headerType.getTypeNum()];
mHeaders[headerType.getTypeNum()] = 0;
};
#ifndef PARTIAL_TEMPLATE_SPECIALIZATION
#undef defineHeader
#define defineHeader(_header, _name, _type, _rfc) \
const H_##_header::Type& \
SipMessage::header(const H_##_header& headerType) const \
{ \
HeaderFieldValueList* hfvs = ensureHeaders(headerType.getTypeNum(), true); \
if (hfvs->getParserContainer() == 0) \
{ \
hfvs->setParserContainer(new ParserContainer<H_##_header::Type>(hfvs, headerType.getTypeNum())); \
} \
return dynamic_cast<ParserContainer<H_##_header::Type>*>(hfvs->getParserContainer())->front(); \
} \
\
H_##_header::Type& \
SipMessage::header(const H_##_header& headerType) \
{ \
HeaderFieldValueList* hfvs = ensureHeaders(headerType.getTypeNum(), true); \
if (hfvs->getParserContainer() == 0) \
{ \
hfvs->setParserContainer(new ParserContainer<H_##_header::Type>(hfvs, headerType.getTypeNum())); \
} \
return dynamic_cast<ParserContainer<H_##_header::Type>*>(hfvs->getParserContainer())->front(); \
}
#undef defineMultiHeader
#define defineMultiHeader(_header, _name, _type, _rfc) \
const H_##_header##s::Type& \
SipMessage::header(const H_##_header##s& headerType) const \
{ \
HeaderFieldValueList* hfvs = ensureHeaders(headerType.getTypeNum(), false); \
if (hfvs->getParserContainer() == 0) \
{ \
hfvs->setParserContainer(new H_##_header##s::Type(hfvs, headerType.getTypeNum())); \
} \
return *dynamic_cast<H_##_header##s::Type*>(hfvs->getParserContainer()); \
} \
\
H_##_header##s::Type& \
SipMessage::header(const H_##_header##s& headerType) \
{ \
HeaderFieldValueList* hfvs = ensureHeaders(headerType.getTypeNum(), false); \
if (hfvs->getParserContainer() == 0) \
{ \
hfvs->setParserContainer(new H_##_header##s::Type(hfvs, headerType.getTypeNum())); \
} \
return *dynamic_cast<H_##_header##s::Type*>(hfvs->getParserContainer()); \
}
defineHeader(ContentDisposition, "Content-Disposition", Token, "RFC 3261");
defineHeader(ContentEncoding, "Content-Encoding", Token, "RFC 3261");
defineHeader(MIMEVersion, "Mime-Version", Token, "RFC 3261");
defineHeader(Priority, "Priority", Token, "RFC 3261");
defineHeader(Event, "Event", Token, "RFC 3265");
defineHeader(SubscriptionState, "Subscription-State", Token, "RFC 3265");
defineHeader(SIPETag, "SIP-ETag", Token, "RFC 3903");
defineHeader(SIPIfMatch, "SIP-If-Match", Token, "RFC 3903");
defineHeader(ContentId, "Content-ID", Token, "RFC 2045");
defineMultiHeader(AllowEvents, "Allow-Events", Token, "RFC 3265");
defineHeader(Identity, "Identity", StringCategory, "draft-sip-identity-03");
defineMultiHeader(AcceptEncoding, "Accept-Encoding", Token, "RFC 3261");
defineMultiHeader(AcceptLanguage, "Accept-Language", Token, "RFC 3261");
defineMultiHeader(Allow, "Allow", Token, "RFC 3261");
defineMultiHeader(ContentLanguage, "Content-Language", Token, "RFC 3261");
defineMultiHeader(ProxyRequire, "Proxy-Require", Token, "RFC 3261");
defineMultiHeader(Require, "Require", Token, "RFC 3261");
defineMultiHeader(Supported, "Supported", Token, "RFC 3261");
defineMultiHeader(Unsupported, "Unsupported", Token, "RFC 3261");
defineMultiHeader(SecurityClient, "Security-Client", Token, "RFC 3329");
defineMultiHeader(SecurityServer, "Security-Server", Token, "RFC 3329");
defineMultiHeader(SecurityVerify, "Security-Verify", Token, "RFC 3329");
defineMultiHeader(RequestDisposition, "Request-Disposition", Token, "RFC 3841");
defineMultiHeader(Reason, "Reason", Token, "RFC 3326");
defineMultiHeader(Privacy, "Privacy", Token, "RFC 3323");
defineMultiHeader(PMediaAuthorization, "P-Media-Authorization", Token, "RFC 3313");
defineHeader(ReferSub, "Refer-Sub", Token, "draft-ietf-sip-refer-with-norefersub-03");
defineHeader(AnswerMode, "Answer-Mode", Token, "draft-ietf-answermode-01");
defineHeader(PrivAnswerMode, "Priv-Answer-Mode", Token, "draft-ietf-answermode-01");
defineMultiHeader(Accept, "Accept", Mime, "RFC 3261");
defineHeader(ContentType, "Content-Type", Mime, "RFC 3261");
defineMultiHeader(CallInfo, "Call-Info", GenericUri, "RFC 3261");
defineMultiHeader(AlertInfo, "Alert-Info", GenericUri, "RFC 3261");
defineMultiHeader(ErrorInfo, "Error-Info", GenericUri, "RFC 3261");
defineHeader(IdentityInfo, "Identity-Info", GenericUri, "draft-sip-identity-03");
defineMultiHeader(RecordRoute, "Record-Route", NameAddr, "RFC 3261");
defineMultiHeader(Route, "Route", NameAddr, "RFC 3261");
defineMultiHeader(Contact, "Contact", NameAddr, "RFC 3261");
defineHeader(From, "From", NameAddr, "RFC 3261");
defineHeader(To, "To", NameAddr, "RFC 3261");
defineHeader(ReplyTo, "Reply-To", NameAddr, "RFC 3261");
defineHeader(ReferTo, "Refer-To", NameAddr, "RFC 3515");
defineHeader(ReferredBy, "Referred-By", NameAddr, "RFC 3892");
defineMultiHeader(Path, "Path", NameAddr, "RFC 3327");
defineMultiHeader(AcceptContact, "Accept-Contact", NameAddr, "RFC 3841");
defineMultiHeader(RejectContact, "Reject-Contact", NameAddr, "RFC 3841");
defineMultiHeader(PAssertedIdentity, "P-Asserted-Identity", NameAddr, "RFC 3325");
defineMultiHeader(PPreferredIdentity, "P-Preferred-Identity", NameAddr, "RFC 3325");
defineHeader(PCalledPartyId, "P-Called-Party-ID", NameAddr, "RFC 3455");
defineMultiHeader(PAssociatedUri, "P-Associated-URI", NameAddr, "RFC 3455");
defineMultiHeader(ServiceRoute, "Service-Route", NameAddr, "RFC 3608");
defineHeader(ContentTransferEncoding, "Content-Transfer-Encoding", StringCategory, "RFC ?");
defineHeader(Organization, "Organization", StringCategory, "RFC 3261");
defineHeader(Server, "Server", StringCategory, "RFC 3261");
defineHeader(Subject, "Subject", StringCategory, "RFC 3261");
defineHeader(UserAgent, "User-Agent", StringCategory, "RFC 3261");
defineHeader(Timestamp, "Timestamp", StringCategory, "RFC 3261");
defineHeader(ContentLength, "Content-Length", UInt32Category, "RFC 3261");
defineHeader(MaxForwards, "Max-Forwards", UInt32Category, "RFC 3261");
defineHeader(MinExpires, "Min-Expires", Uint32Category, "RFC 3261");
defineHeader(RSeq, "RSeq", UInt32Category, "RFC 3261");
// !dlb! this one is not quite right -- can have (comment) after field value
defineHeader(RetryAfter, "Retry-After", UInt32Category, "RFC 3261");
defineHeader(Expires, "Expires", ExpiresCategory, "RFC 3261");
defineHeader(SessionExpires, "Session-Expires", ExpiresCategory, "RFC 4028");
defineHeader(MinSE, "Min-SE", ExpiresCategory, "RFC 4028");
defineHeader(CallID, "Call-ID", CallID, "RFC 3261");
defineHeader(Replaces, "Replaces", CallID, "RFC 3261");
defineHeader(InReplyTo, "In-Reply-To", CallID, "RFC 3261");
defineHeader(Join, "Join", CallId, "RFC 3911");
defineHeader(TargetDialog, "Target-Dialog", CallId, "Target Dialog draft");
defineHeader(AuthenticationInfo, "Authentication-Info", Auth, "RFC 3261");
defineMultiHeader(Authorization, "Authorization", Auth, "RFC 3261");
defineMultiHeader(ProxyAuthenticate, "Proxy-Authenticate", Auth, "RFC 3261");
defineMultiHeader(ProxyAuthorization, "Proxy-Authorization", Auth, "RFC 3261");
defineMultiHeader(WWWAuthenticate, "Www-Authenticate", Auth, "RFC 3261");
defineHeader(CSeq, "CSeq", CSeqCategory, "RFC 3261");
defineHeader(Date, "Date", DateCategory, "RFC 3261");
defineMultiHeader(Warning, "Warning", WarningCategory, "RFC 3261");
defineMultiHeader(Via, "Via", Via, "RFC 3261");
defineHeader(RAck, "RAck", RAckCategory, "RFC 3262");
#endif
const HeaderFieldValueList*
SipMessage::getRawHeader(Headers::Type headerType) const
{
return mHeaders[headerType];
}
void
SipMessage::setRawHeader(const HeaderFieldValueList* hfvs, Headers::Type headerType)
{
if (mHeaders[headerType] != hfvs)
{
delete mHeaders[headerType];
mHeaders[headerType] = new HeaderFieldValueList(*hfvs);
}
}
void
SipMessage::setForceTarget(const Uri& uri)
{
if (mForceTarget)
{
*mForceTarget = uri;
}
else
{
mForceTarget = new Uri(uri);
}
}
void
SipMessage::clearForceTarget()
{
delete mForceTarget;
mForceTarget = 0;
}
const Uri&
SipMessage::getForceTarget() const
{
assert(mForceTarget);
return *mForceTarget;
}
bool
SipMessage::hasForceTarget() const
{
return (mForceTarget != 0);
}
SipMessage&
SipMessage::mergeUri(const Uri& source)
{
header(h_RequestLine).uri() = source;
header(h_RequestLine).uri().removeEmbedded();
if (source.exists(p_method))
{
header(h_RequestLine).method() = getMethodType(source.param(p_method));
header(h_RequestLine).uri().remove(p_method);
}
//19.1.5
//dangerous headers not included in merge:
// From, Call-ID, Cseq, Via, Record Route, Route, Accept, Accept-Encoding,
// Accept-Langauge, Allow, Contact, Organization, Supported, User-Agent
//from the should-verify section, remove for now, some never seem to make
//sense:
// Content-Encoding, Content-Language, Content-Length, Content-Type, Date,
// Mime-Version, and TimeStamp
if (source.hasEmbedded())
{
h_AuthenticationInfo.merge(*this, source.embedded());
h_ContentTransferEncoding.merge(*this, source.embedded());
h_Event.merge(*this, source.embedded());
h_Expires.merge(*this, source.embedded());
h_SessionExpires.merge(*this, source.embedded());
h_MinSE.merge(*this, source.embedded());
h_InReplyTo.merge(*this, source.embedded());
h_MaxForwards.merge(*this, source.embedded());
h_MinExpires.merge(*this, source.embedded());
h_Priority.merge(*this, source.embedded());
h_ReferTo.merge(*this, source.embedded());
h_ReferredBy.merge(*this, source.embedded());
h_Replaces.merge(*this, source.embedded());
h_ReplyTo.merge(*this, source.embedded());
h_RetryAfter.merge(*this, source.embedded());
h_Server.merge(*this, source.embedded());
h_SIPETag.merge(*this, source.embedded());
h_SIPIfMatch.merge(*this, source.embedded());
h_Subject.merge(*this, source.embedded());
h_SubscriptionState.merge(*this, source.embedded());
h_To.merge(*this, source.embedded());
h_Warnings.merge(*this, source.embedded());
h_SecurityClients.merge(*this, source.embedded());
h_SecurityServers.merge(*this, source.embedded());
h_SecurityVerifys.merge(*this, source.embedded());
h_Authorizations.merge(*this, source.embedded());
h_ProxyAuthenticates.merge(*this, source.embedded());
h_WWWAuthenticates.merge(*this, source.embedded());
h_ProxyAuthorizations.merge(*this, source.embedded());
h_AlertInfos.merge(*this, source.embedded());
h_AllowEvents.merge(*this, source.embedded());
h_CallInfos.merge(*this, source.embedded());
h_ErrorInfos.merge(*this, source.embedded());
h_ProxyRequires.merge(*this, source.embedded());
h_Requires.merge(*this, source.embedded());
h_Unsupporteds.merge(*this, source.embedded());
h_AnswerMode.merge(*this, source.embedded());
h_PrivAnswerMode.merge(*this, source.embedded());
h_RSeq.merge(*this, source.embedded());
h_RAck.merge(*this, source.embedded());
}
//unknown header merge
return *this;
}
void
SipMessage::setSecurityAttributes(auto_ptr<SecurityAttributes> sec) const
{
mSecurityAttributes = sec;
}
void
SipMessage::callOutboundDecorators(const Tuple &src, const Tuple &dest)
{
std::vector<MessageDecorator*>::iterator i;
for (i = mOutboundDecorators.begin();
i != mOutboundDecorators.end(); i++)
{
(*i)->decorateMessage(*this, src, dest);
}
}
/* ====================================================================
* 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 vocal@vovida.org.
*
* 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/>.
*
*/
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -