Method newDriveIncoming

SIP/SIP2Interface.cpp:401–442

}

void SipInterface::newDriveIncoming(char *content)
{
	LOG(DEBUG) << "SIP recv:"<<content;

	SipMessage *msg = sipParseBuffer(content);
	if (!msg) { return; }

	WATCH("SIP recv "<<msg->smGetPrecis());

	try {
		if (newCheckInvite(msg)) { delete msg; return; }

		const char *methodname = msg->smGetMethodName();	// May be empty, but never NULL
		if (*methodname) { LOG(DEBUG) << "non-initiating SIP method " << methodname; }

		if (checkTU(msg)) { delete msg; return; }

		// Send message to the appropriate SipDialog.
		SipDialog *dialog = findDialogByMsg(msg);
		if (dialog) {
			if (msg->smGetCode()) {
				// All replies go to the TUs, so if we did not find one above, this is an error.
				LOG(NOTICE) << "SIP reply to non-existent SIP transaction "<<msg;
				newSendEarlyError(msg,500,"Server Error");
			}
			dialog->dialogWriteDownlink(msg);
		} else {
			string callid = msg->smGetCallId();
			LOG(NOTICE) << "unrecognized"<<LOGVAR(callid) <<LOGVAR2("SIP Message:",msg);
			// Alert the SIP peer that this user is bogus.  We did not do this pre-l3-rewrite.
			// Asterisk seems to send 500 for this type of error.
			newSendEarlyError(msg,404,"Not Found");
			delete msg;
		}

	} catch(exception &e) {
		LOG(ERR) << "SIP processing exception "<<e.what() << " " << typeid(&e).name();
	} catch(...) {
		LOG(CRIT) << "Unhandled exception attempted to kill OpenBTS SIP processor";	// pat added
		devassert(0);
	}
}