|
reSIProcate/stack
9694
|
#include <iostream>#include "resip/stack/SipStack.hxx"#include "resip/stack/Helper.hxx"#include "resip/stack/SipMessage.hxx"#include "resip/stack/Uri.hxx"#include "rutil/Data.hxx"#include "rutil/DnsUtil.hxx"#include "rutil/Logger.hxx"#include "rutil/DataStream.hxx"
Go to the source code of this file.
Defines | |
| #define | RESIPROCATE_SUBSYSTEM Subsystem::SIP |
Functions | |
| int | main (int argc, char *argv[]) |
| #define RESIPROCATE_SUBSYSTEM Subsystem::SIP |
Definition at line 27 of file testResponses.cxx.
| int main | ( | int | argc, |
| char * | argv[] | ||
| ) |
Definition at line 30 of file testResponses.cxx.
References context, resip::SipMessage::encode(), resip::SipMessage::header(), resip::Log::initialize(), resip::DnsUtil::isIpV6Address(), resip::SipMessage::isRequest(), resip::Helper::makeResponse(), received, resipCout, resip::StunDisabled, resip::TCP, resip::WarningCategory::text(), resip::UDP, resip::V4, and resip::V6.
{
const char* logType = "cout";
const char* logLevel = "DEBUG";
int optLoop = 0;
int optPort = 0;
int optTcp = 0;
int optUdp = 0;
char *optBindAddr = 0;
char *optBindTcpAddr = 0;
char *optBindUdpAddr = 0;
#if defined(HAVE_POPT_H)
struct poptOption table[] = {
{"log-type", 'l', POPT_ARG_STRING, &logType, 0,
"where to send logging messages", "syslog|cerr|cout"},
{"log-level", 'v', POPT_ARG_STRING, &logLevel, 0,
"specify the default log level", "DEBUG|INFO|WARNING|ALERT"},
{"loop", 'l', POPT_ARG_NONE, &optLoop, 0, "loop endlessly", 0 },
{"port", 'p', POPT_ARG_INT, &optPort, 0, "port to listen on", 0},
{"tcp", 't', POPT_ARG_NONE, &optTcp, 0, "do not use TCP", 0},
{"udp", 'u', POPT_ARG_NONE, &optUdp, 0, "do not use UDP", 0},
{"bind", 'b', POPT_ARG_STRING, &optBindAddr, 0, "bind to this address globally", 0},
{"bind-tcp", 0, POPT_ARG_STRING, &optBindTcpAddr, 0, "bind TCP Transport to this address", 0},
{"bind-udp", 0, POPT_ARG_STRING, &optBindUdpAddr, 0, "bind UDP Transport to this address", 0},
POPT_AUTOHELP
{ 0 }
};
poptContext context = poptGetContext(0, argc, const_cast<const char**>(argv), table, 0);
poptGetNextOpt(context);
#endif
Log::initialize(logType, logLevel, argv[0]);
optUdp = !optUdp;
optTcp = !optTcp;
if (!optPort) optPort = 5060;
auto_ptr<SipStack> stack(new SipStack());
if (optBindAddr)
{
const char *addr = optBindUdpAddr?optBindUdpAddr:optBindAddr;
stack->addTransport(UDP, optPort, DnsUtil::isIpV6Address(addr)?V6:V4, StunDisabled, addr);
addr = optBindTcpAddr?optBindTcpAddr:optBindAddr;
stack->addTransport(TCP, optPort, DnsUtil::isIpV6Address(addr)?V6:V4, StunDisabled, addr);
}
else
{
stack->addTransport(UDP, optPort);
stack->addTransport(TCP, optPort);
}
int count=1;
bool needToProcessSend = false;
while (optLoop || count > 0 || needToProcessSend)
{
FdSet fdset;
stack->buildFdSet(fdset);
stack->process(fdset);
needToProcessSend = false;
Message* msg = stack->receive();
if (msg)
{
SipMessage* received = dynamic_cast<SipMessage*>(msg);
if (received)
{
--count;
received->encode(resipCout);
if (received->isRequest())
{
SipMessage* resp = Helper::makeResponse(*received, 606);
WarningCategory warn;
warn.text() = "Simple test reply from "__FILE__" driver.";
resp->header(h_Warnings).push_back(warn);
stack->send(*resp);
needToProcessSend = true;
}
}
}
}
return 0;
}

1.7.5.1