/*

* $Id$

*

* Copyright (C) 2001-2003 FhG Fokus

* Copyright (C) 2005-2006 Voice Sistem S.R.L

*

* This file is part of opensips, a free SIP server.

*

* opensips is free software; you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation; either version 2 of the License, or

* (at your option) any later version

*

* opensips is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

*

* History:

* -------

* 2002-01-29 argc/argv globalized via my_{argc|argv} (jiri)

* 2003-01-23 mhomed added (jiri)

* 2003-03-19 replaced all malloc/frees w/ pkg_malloc/pkg_free (andrei)

* 2003-03-29 pkg cleaners for fifo and script callbacks introduced (jiri)

* 2003-03-31 removed snmp part (obsolete & no place in core) (andrei)

* 2003-04-06 child_init called in all processes (janakj)

* 2003-04-08 init_mallocs split into init_{pkg,shm}_mallocs and

* init_shm_mallocs called after cmd. line parsing (andrei)

* 2003-04-15 added tcp_disable support (andrei)

* 2003-05-09 closelog() before openlog to force opening a new fd

* (needed on solaris) (andrei)

* 2003-06-11 moved all signal handlers init. in install_sigs and moved it

* after daemonize (so that we won't catch anymore our own

* SIGCHLD generated when becoming session leader) (andrei)

* changed is_main default value to 1 (andrei)

* 2003-06-28 kill_all_children is now used instead of kill(0, sig)

* see comment above it for explanations. (andrei)

* 2003-06-29 replaced port_no_str snprintf w/ int2str (andrei)

* 2003-10-10 added switch for config check (-c) (andrei)

* 2003-10-24 converted to the new socket_info lists (andrei)

* 2004-03-30 core dump is enabled by default

* added support for increasing the open files limit (andrei)

* 2004-04-28 sock_{user,group,uid,gid,mode} added

* user2uid() & user2gid() added (andrei)

* 2004-09-11 added timeout on children shutdown and final cleanup

* (if it takes more than 60s => something is definitely wrong

* => kill all or abort) (andrei)

* force a shm_unlock before cleaning-up, in case we have a

* crashed childvwhich still holds the lock (andrei)

* 2004-12-02 removed -p, extended -l to support [proto:]address[:port],

* added parse_phostport, parse_proto (andrei)

* 2005-06-16 always record the pid in pt[process_no].pid twice: once in the

* parent & once in the child to avoid a short window when one

* of them might use it "unset" (andrei)

* 2005-12-22 added tos configurability (thanks to Andreas Granig)

* 2006-04-26 2-stage TLS init: before and after config file parsing (klaus)

*/

/*!

* \file main.c

* \brief Command line parsing, initializiation and server startup.

*

* Contains methods for parsing the command line, the initialization of

* the execution environment (signals, config file parsing) and forking

* the TCP, UDP, timer and fifo children.

*/

#include <stdio.h>

#include <stdlib.h>

#include <errno.h>

#include <ctype.h>

#include <string.h>

#include <netdb.h>

#include <unistd.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <netinet/in_systm.h>

#include <netinet/ip.h>

#include <arpa/inet.h>

#include <sys/utsname.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <sys/mman.h>

#include <fcntl.h>

#include <sys/time.h>

#include <sys/wait.h>

#include <pwd.h>

#include <grp.h>

#include <signal.h>

#include <time.h>

#include <sys/ioctl.h>

#include <net/if.h>

#ifdef HAVE_SYS_SOCKIO_H

#include <sys/sockio.h>

#endif

#include "help_msg.h"

#include "config.h"

#include "dprint.h"

#include "daemonize.h"

#include "route.h"

#include "udp_server.h"

#include "globals.h"

#include "mem/mem.h"

#ifdef SHM_MEM

#include "mem/shm_mem.h"

#endif

#include "sr_module.h"

#include "timer.h"

#include "parser/msg_parser.h"

#include "ip_addr.h"

#include "resolve.h"

#include "parser/parse_hname2.h"

#include "parser/digest/digest_parser.h"

#include "name_alias.h"

#include "hash_func.h"

#include "pt.h"

#include "script_cb.h"

#include "blacklists.h"

#include "pt.h"

#include "ut.h"

#include "serialize.h"

#include "statistics.h"

#include "core_stats.h"

#include "pvar.h"

#ifdef USE_TCP

#include "poll_types.h"

#include "tcp_init.h"

#ifdef USE_TLS

#include "tls/tls_init.h"

#endif

#endif

#ifdef USE_SCTP

#include "sctp_server.h"

#endif

#include "version.h"

#include "mi/mi_core.h"

#include "db/db_insertq.h"

static char id[]="@(#) $Id$";

static char* version=OPENSIPS_FULL_VERSION;

static char* flags=OPENSIPS_COMPILE_FLAGS;

char compiled[]= __TIME__ " " __DATE__ ;

/**

* Print compile-time constants

*/

void print_ct_constants(void)

{

#ifdef ADAPTIVE_WAIT

printf("ADAPTIVE_WAIT_LOOPS=%d, ", ADAPTIVE_WAIT_LOOPS);

#endif

printf("MAX_RECV_BUFFER_SIZE %d, MAX_LISTEN %d,"

" MAX_URI_SIZE %d, BUF_SIZE %d\n",

MAX_RECV_BUFFER_SIZE, MAX_LISTEN, MAX_URI_SIZE,

BUF_SIZE );

#ifdef USE_TCP

printf("poll method support: %s.\n", poll_support);

#endif

printf("svnrevision: %s\n",

#ifdef SVNREVISION

SVNREVISION

#else

"unknown"

#endif

);

}

/* global vars */

int own_pgid = 0; /* whether or not we have our own pgid (and it's ok

to use kill(0, sig) */

char* cfg_file = 0;

unsigned int maxbuffer = MAX_RECV_BUFFER_SIZE; /* maximum buffer size we do

not want to exceed during the

auto-probing procedure; may

be re-configured */

int children_no = 0; /* number of children processing requests */

#ifdef USE_TCP

int tcp_children_no = 0;

int tcp_disable = 0; /* 1 if tcp is disabled */

int tcp_crlf_pingpong = 1; /* 0: send CRLF pong to incoming CRLFCRLF ping */

#endif

#ifdef USE_TLS

int tls_disable = 1; /* 1 if tls is disabled */

#endif

#ifdef USE_SCTP

int sctp_disable = 0; /* 1 if sctp is disabled */

#endif

int sig_flag = 0; /* last signal received */

#ifdef CHANGEABLE_DEBUG_LEVEL

int debug_init = L_NOTICE;

int *debug = &debug_init;

#else

int debug = L_NOTICE;

#endif

int dont_fork = 0;

/* start by logging to stderr */

int log_stderr = 1;

/* log facility (see syslog(3)) */

int log_facility = LOG_DAEMON;

/* the id to be printed in syslog */

char *log_name = 0;

int config_check = 0;

/* check if reply first via host==us */

int check_via = 0;

/* debugging level for memory stats */

int memlog = L_DBG + 10;

int memdump = L_DBG + 10;

/* debugging in case msg processing takes. too long disabled by default */

int execmsgthreshold = 0;

/* debugging in case dns takes too long. disabled by default */

int execdnsthreshold = 0;

/* debugging in case tcp stuff take too long. disabled by default */

int tcpthreshold = 0;

/* should replies include extensive warnings? by default yes,

good for trouble-shooting

*/

int sip_warning = 0;

/* should localy-generated messages include server's signature? */

int server_signature=1;

/* Server header to be used when proxy generates request as UAS.

Default is to use SERVER_HDR CRLF (assigned later).

*/

str server_header = {SERVER_HDR,sizeof(SERVER_HDR)-1};

/* User-Agent header to be used when proxy generates request as UAC.

Default is to use USER_AGENT CRLF (assigned later).

*/

str user_agent_header = {USER_AGENT,sizeof(USER_AGENT)-1};

/* should opensips try to locate outbound interface on multihomed

* host? by default not -- too expensive

*/

int mhomed=0;

/* use dns and/or rdns or to see if we need to add

a ;received=x.x.x.x to via: */

int received_dns = 0;

char* working_dir = 0;

char* chroot_dir = 0;

char* user=0;

char* group=0;

int uid = 0;

int gid = 0;

/* more config stuff */

int disable_core_dump=0; /* by default enabled */

int open_files_limit=-1; /* don't touch it by default */

#ifdef USE_MCAST

int mcast_loopback = 0;

int mcast_ttl = -1; /* if -1, don't touch it, use the default (usually 1) */

#endif /* USE_MCAST */

int tos = IPTOS_LOWDELAY;

struct socket_info* udp_listen=0;

#ifdef USE_TCP

struct socket_info* tcp_listen=0;

#endif

#ifdef USE_TLS

struct socket_info* tls_listen=0;

#endif

#ifdef USE_SCTP

struct socket_info* sctp_listen=0;

#endif

struct socket_info* bind_address=0; /* pointer to the crt. proc.

listening address*/

struct socket_info* sendipv4; /* ipv4 socket to use when msg. comes from ipv6*/

struct socket_info* sendipv6; /* same as above for ipv6 */

#ifdef USE_TCP

struct socket_info* sendipv4_tcp;

struct socket_info* sendipv6_tcp;

#endif

#ifdef USE_TLS

struct socket_info* sendipv4_tls;

struct socket_info* sendipv6_tls;

#endif

#ifdef USE_SCTP

struct socket_info* sendipv4_sctp;

struct socket_info* sendipv6_sctp;

#endif

/* if aliases should be automatically discovered and added

* during fixing listening sockets */

int auto_aliases=1;

/* if the stateless forwarding support in core should be

* disabled or not */

int sl_fwd_disabled=-1;

unsigned short port_no=0; /* default port*/

#ifdef USE_TLS

unsigned short tls_port_no=0; /* default port */

#endif

/* process number - 0 is the main process */

int process_no = 0;

/* cfg parsing */

int cfg_errors=0;

/* start-up time */

time_t startup_time = 0;

/* shared memory (in MB) */

unsigned long shm_mem_size=SHM_MEM_SIZE * 1024 * 1024;

/* shared memory (in MB) */

unsigned long pkg_mem_size=PKG_MEM_SIZE * 1024 * 1024;

/* export command-line to anywhere else */

int my_argc;

char **my_argv;

extern FILE* yyin;

extern int yyparse();

int is_main = 1; /* flag = is this the "main" process? */

char* pid_file = 0; /* filename as asked by user */

char* pgid_file = 0;

/**

* Clean up on exit. This should be called before exiting.

* \param show_status set to one to display the mem status

*/

void cleanup(int show_status)

{

LM_INFO("cleanup\n");

/*clean-up*/

if (mem_lock)

shm_unlock(); /* hack: force-unlock the shared memory lock in case

some process crashed and let it locked; this will

allow an almost gracious shutdown */

handle_ql_shutdown();

destroy_modules();

#ifdef USE_TCP

destroy_tcp();

#endif

#ifdef USE_TLS

destroy_tls();

#endif

destroy_timer();

destroy_stats_collector();

destroy_script_cb();

pv_free_extra_list();

destroy_argv_list();

destroy_black_lists();

#ifdef CHANGEABLE_DEBUG_LEVEL

if (debug!=&debug_init) {

reset_proc_debug_level();

debug_init = *debug;

shm_free(debug);

debug = &debug_init;

}

#endif

#ifdef PKG_MALLOC

if (show_status){

LM_GEN1(memdump, "Memory status (pkg):\n");

pkg_status();

}

#endif

#ifdef SHM_MEM

if (pt) shm_free(pt);

pt=0;

if (show_status){

LM_GEN1(memdump, "Memory status (shm):\n");

shm_status();

}

/* zero all shmem alloc vars that we still use */

shm_mem_destroy();

#endif

if (pid_file) unlink(pid_file);

if (pgid_file) unlink(pgid_file);

}

/**

* Tries to send a signal to all our processes

* If daemonized is ok to send the signal to all the process group,

* however if not daemonized we might end up sending the signal also

* to the shell which launched us => most signals will kill it if

* it's not in interactive mode and we don't want this. The non-daemonized

* case can occur when an error is encountered before daemonize is called

* (e.g. when parsing the config file) or when opensips is started in

* "dont-fork" mode.

* \param signum signal for killing the children

*/

static void kill_all_children(int signum)

{

int r;

if (own_pgid) kill(0, signum);

else if (pt)

for (r=1; r<counted_processes; r++)

if (pt[r].pid) kill(pt[r].pid, signum);

}

/**

* Timeout handler during wait for children exit.

* If this handler is called, a critical timeout has occured while

* waiting for the children to finish => we should kill everything and exit

* \param signo signal for killing the children

*/

static void sig_alarm_kill(int signo)

{

kill_all_children(SIGKILL); /* this will kill the whole group

including "this" process;

for debugging replace with SIGABRT

(but warning: it might generate lots

of cores) */

}

/**

* Timeout handler during wait for children exit.

* like sig_alarm_kill, but the timeout has occured when cleaning up,

* try to leave a core for future diagnostics

* \param signo signal for killing the children

* \see sig_alarm_kill

*/

static void sig_alarm_abort(int signo)

{

/* LOG is not signal safe, but who cares, we are abort-ing anyway :-) */

LM_CRIT("BUG - shutdown timeout triggered, dying...");

abort();

}

/**

* Signal handler for the server.

*/

void handle_sigs(void)

{

pid_t chld;

int chld_status,overall_status=0;

int i;

int do_exit;

const unsigned int shutdown_time = 60; /* one minute close timeout */

switch(sig_flag){

case 0: break; /* do nothing*/

case SIGPIPE:

/* SIGPIPE might be rarely received on use of

exec module; simply ignore it

*/

LM_WARN("SIGPIPE received and ignored\n");

break;

case SIGINT:

case SIGTERM:

/* we end the program in all these cases */

if (sig_flag==SIGINT)

LM_DBG("INT received, program terminates\n");

else

LM_DBG("SIGTERM received, program terminates\n");

/* first of all, kill the children also */

kill_all_children(SIGTERM);

if (signal(SIGALRM, sig_alarm_kill) == SIG_ERR ) {

LM_ERR("could not install SIGALARM handler\n");

/* continue, the process will die anyway if no

* alarm is installed which is exactly what we want */

}

alarm(shutdown_time);

while(wait(0) > 0); /* Wait for all the children to terminate */

signal(SIGALRM, sig_alarm_abort);

cleanup(1); /* cleanup & show status*/

alarm(0);

signal(SIGALRM, SIG_IGN);

dprint("Thank you for flying " NAME "\n");

exit(0);

break;

case SIGUSR1:

#ifdef PKG_MALLOC

LM_GEN1(memdump, "Memory status (pkg):\n");

pkg_status();

#endif

#ifdef SHM_MEM

LM_GEN1(memdump, "Memory status (shm):\n");

shm_status();

#endif

break;

case SIGUSR2:

#ifdef PKG_MALLOC

set_pkg_stats( get_pkg_status_holder(process_no) );

#endif

break;

case SIGCHLD:

do_exit = 0;

while ((chld=waitpid( -1, &chld_status, WNOHANG ))>0) {

/* is it a process we know about? */

for( i=0 ; i<counted_processes ; i++ )

if (pt[i].pid==chld) break;

if (i==counted_processes) {

LM_DBG("unkown child process %d ended. Ignoring\n",chld);

continue;

}

do_exit = 1;

/* process the signal */

overall_status |= chld_status;

LM_DBG("status = %d\n",overall_status);

if (WIFEXITED(chld_status))

LM_INFO("child process %d exited normally,"

" status=%d\n", chld,

WEXITSTATUS(chld_status));

else if (WIFSIGNALED(chld_status)) {

LM_INFO("child process %d exited by a signal"

" %d\n", chld, WTERMSIG(chld_status));

#ifdef WCOREDUMP

LM_INFO("core was %sgenerated\n",

WCOREDUMP(chld_status) ? "" : "not " );

#endif

}else if (WIFSTOPPED(chld_status))

LM_INFO("child process %d stopped by a"

" signal %d\n", chld,

WSTOPSIG(chld_status));

}

if (!do_exit)

break;

LM_INFO("terminating due to SIGCHLD\n");

/* exit */

kill_all_children(SIGTERM);

if (signal(SIGALRM, sig_alarm_kill) == SIG_ERR ) {

LM_ERR("could not install SIGALARM handler\n");

/* continue, the process will die anyway if no

* alarm is installed which is exactly what we want */

}

alarm(shutdown_time);

while(wait(0) > 0); /* wait for all the children to terminate*/

signal(SIGALRM, sig_alarm_abort);

cleanup(1); /* cleanup & show status*/

alarm(0);

signal(SIGALRM, SIG_IGN);

LM_DBG("terminating due to SIGCHLD\n");

exit(overall_status ? -1 : 0);

break;

case SIGHUP: /* ignoring it*/

LM_DBG("SIGHUP received, ignoring it\n");

break;

default:

LM_CRIT("unhandled signal %d\n", sig_flag);

}

sig_flag=0;

}

/**

* Exit regulary on a specific signal.

* This is good for profiling which only works if exited regularly

* and not by default signal handlers

* \param signo The signal that should be handled

*/

static void sig_usr(int signo)

{

if (is_main){

if (sig_flag==0) sig_flag=signo;

else /* previous sig. not processed yet, ignoring? */

return; ;

if (dont_fork)

/* only one proc, doing everything from the sig handler,

unsafe, but this is only for debugging mode*/

handle_sigs();

}else{

/* process the important signals */

switch(signo){

case SIGPIPE:

LM_INFO("signal %d received\n", signo);

break;

case SIGINT:

case SIGTERM:

LM_INFO("signal %d received\n", signo);

/* print memory stats for non-main too */

#ifdef PKG_MALLOC

LM_GEN1(memdump, "Memory status (pkg):\n");

pkg_status();

#endif

exit(0);

break;

case SIGUSR1:

/* statistics -> show only pkg mem */

#ifdef PKG_MALLOC

LM_GEN1(memdump, "Memory status (pkg):\n");

pkg_status();

#endif

break;

case SIGUSR2:

#ifdef PKG_MALLOC

set_pkg_stats( get_pkg_status_holder(process_no) );

#endif

break;

case SIGHUP:

/* ignored*/

break;

case SIGCHLD:

LM_DBG("SIGCHLD received: "

"we do not worry about grand-children\n");

}

}

}

/**

* Install the signal handlers.

* \return 0 on success, -1 on error

*/

int install_sigs(void)

{

/* added by jku: add exit handler */

if (signal(SIGINT, sig_usr) == SIG_ERR ) {

LM_ERR("no SIGINT signal handler can be installed\n");

goto error;

}

/* if we debug and write to a pipe, we want to exit nicely too */

if (signal(SIGPIPE, sig_usr) == SIG_ERR ) {

LM_ERR("no SIGINT signal handler can be installed\n");

goto error;

}

if (signal(SIGUSR1, sig_usr) == SIG_ERR ) {

LM_ERR("no SIGUSR1 signal handler can be installed\n");

goto error;

}

if (signal(SIGCHLD , sig_usr) == SIG_ERR ) {

LM_ERR("no SIGCHLD signal handler can be installed\n");

goto error;

}

if (signal(SIGTERM , sig_usr) == SIG_ERR ) {

LM_ERR("no SIGTERM signal handler can be installed\n");

goto error;

}

if (signal(SIGHUP , sig_usr) == SIG_ERR ) {

LM_ERR("no SIGHUP signal handler can be installed\n");

goto error;

}

if (signal(SIGUSR2 , sig_usr) == SIG_ERR ) {

LM_ERR("no SIGUSR2 signal handler can be installed\n");

goto error;

}

return 0;

error:

return -1;

}

/**

* Main loop, forks the children, bind to addresses,

* handle signals.

* \return don't return on sucess, -1 on error

*/

static int main_loop(void)

{

static int chd_rank;

int i,rc;

pid_t pid;

struct socket_info* si;

int* startup_done = NULL;

stat_var *load_p = NULL;

chd_rank=0;

if (dont_fork){

if (create_status_pipe() < 0) {

LM_ERR("failed to create status pipe");

goto error;

}

if (udp_listen==0){

LM_ERR("no fork mode requires at least one"

" udp listen address, exiting...\n");

goto error;

}

/* only one address, we ignore all the others */

if (udp_init(udp_listen)==-1) goto error;

bind_address=udp_listen;

sendipv4=bind_address;

sendipv6=bind_address; /*FIXME*/

if (udp_listen->next){

LM_WARN("using only the first listen address (no fork)\n");

}

/* try to drop privileges */

if (do_suid(uid, gid)==-1)

goto error;

if (start_module_procs()!=0) {

LM_ERR("failed to fork module processes\n");

goto error;

}

/* we need another process to act as the timer*/

if (start_timer_processes()!=0) {

LM_CRIT("cannot start timer process(es)\n");

goto error;

}

/* main process, receive loop */

set_proc_attrs("stand-alone SIP receiver %.*s",

bind_address->sock_str.len, bind_address->sock_str.s );

/* We will call child_init even if we

* do not fork - and it will be called with rank 1 because

* in fact we behave like a child, not like main process */

if (init_child(1) < 0) {

LM_ERR("init_child failed in don't fork\n");

goto error;

}

if (startup_rlist.a)

run_startup_route();

is_main=1;

if (register_udp_load_stat(&udp_listen->sock_str,

&pt[process_no].load, 1)!=0) {

LM_ERR("failed to init udp load statistics\n");

goto error;

}

clean_write_pipeend();

LM_DBG("waiting for status code from children\n");

rc = wait_for_all_children();

if (rc < 0) {

LM_ERR("failed to succesfully init children\n");

return rc;

}

return udp_rcv_loop();

} else { /* don't fork */

for(si=udp_listen;si;si=si->next){

/* create the listening socket (for each address)*/

/* udp */

if (udp_init(si)==-1) goto error;

/* get first ipv4/ipv6 socket*/

if ((si->address.af==AF_INET)&&

((sendipv4==0)||(sendipv4->flags&SI_IS_LO)))

sendipv4=si;

#ifdef USE_IPV6

if((sendipv6==0)&&(si->address.af==AF_INET6))

sendipv6=si;

#endif

}

#ifdef USE_TCP

if (!tcp_disable){

for(si=tcp_listen; si; si=si->next){

/* same thing for tcp */

if (tcp_init(si)==-1) goto error;

/* get first ipv4/ipv6 socket*/

if ((si->address.af==AF_INET)&

((sendipv4_tcp==0)||(sendipv4_tcp->flags&SI_IS_LO)))

sendipv4_tcp=si;

#ifdef USE_IPV6

if((sendipv6_tcp==0)&&(si->address.af==AF_INET6))

sendipv6_tcp=si;

#endif

}

}

#ifdef USE_TLS

if (!tls_disable){

for(si=tls_listen; si; si=si->next){

/* same as for tcp*/

if (tls_init(si)==-1) goto error;

/* get first ipv4/ipv6 socket*/

if ((si->address.af==AF_INET)&&

((sendipv4_tls==0)||(sendipv4_tls->flags&SI_IS_LO)))

sendipv4_tls=si;

#ifdef USE_IPV6

if((sendipv6_tls==0)&&(si->address.af==AF_INET6))

sendipv6_tls=si;

#endif

}

}

#endif /* USE_TLS */

#endif /* USE_TCP */

#ifdef USE_SCTP

if (!sctp_disable){

for(si=sctp_listen; si; si=si->next){

/* same thing for sctp */

if (sctp_server_init(si)==-1) goto error;

/* get first ipv4/ipv6 socket*/

if ((si->address.af==AF_INET)&&

((sendipv4_sctp==0)||(sendipv4_sctp->flags&SI_IS_LO)))

sendipv4_sctp=si;

#ifdef USE_IPV6

if((sendipv6_sctp==0)&&(si->address.af==AF_INET6))

sendipv6_sctp=si;

#endif

}

}

#endif /* USE_SCTP */

/* all processes should have access to all the sockets (for sending)

* so we open all first*/

if (do_suid(uid, gid)==-1) goto error; /* try to drop privileges */

if (start_module_procs()!=0) {

LM_ERR("failed to fork module processes\n");

goto error;

}

if(startup_rlist.a) {/* if a startup route was defined */

startup_done = (int*)shm_malloc(sizeof(int));

if(startup_done == NULL) {

LM_ERR("No more shared memory\n");

goto error;

}

*startup_done = 0;

}

/* udp processes */

for(si=udp_listen; si; si=si->next){

if(register_udp_load_stat(&si->sock_str,&load_p,si->children)!=0){

LM_ERR("failed to init load statistics\n");

goto error;

}

for(i=0;i<si->children;i++){

chd_rank++;

if ( (pid=internal_fork( "UDP receiver"))<0 ) {

LM_CRIT("cannot fork UDP process\n");

goto error;

} else {

if (pid==0) {

/* new UDP process */

/* set a more detailed description */

set_proc_attrs("SIP receiver %.*s ",

si->sock_str.len, si->sock_str.s);

bind_address=si; /* shortcut */

if (init_child(chd_rank) < 0) {

LM_ERR("init_child failed for UDP listener\n");

if (send_status_code(-1) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

if (chd_rank == 1 && startup_done)

*startup_done = -1;

exit(-1);

}

/* first UDP proc runs statup_route (if defined) */

if(chd_rank == 1 && startup_done!=NULL) {

LM_DBG("runing startup for first UDP\n");

if(run_startup_route()< 0) {

if (send_status_code(-1) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

*startup_done = -1;

LM_ERR("Startup route processing failed\n");

exit(-1);

}

*startup_done = 1;

}

if (send_status_code(0) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

/* all UDP listeners on same interface

* have same SHM load pointer */

pt[process_no].load = load_p;

udp_rcv_loop();

exit(-1);

}

else {

/* wait for first proc to finish the startup route */

if(chd_rank == 1 && startup_done!=NULL)

while( !(*startup_done) ) {usleep(5);handle_sigs();}

}

}

}

/*parent*/

/*close(udp_sock)*/; /*if it's closed=>sendto invalid fd errors?*/

}

}

#ifdef USE_SCTP

if(!sctp_disable){

for(si=sctp_listen; si; si=si->next){

for(i=0;i<si->children;i++){

chd_rank++;

if ( (pid=internal_fork( "SCTP receiver"))<0 ) {

LM_CRIT("cannot fork SCTP process\n");

goto error;

} else if (pid==0){

/* new SCTP process */

/* set a more detailed description */

set_proc_attrs("SIP receiver %.*s ",

si->sock_str.len, si->sock_str.s);

bind_address=si; /* shortcut */

if (init_child(chd_rank) < 0) {

LM_ERR("init_child failed\n");

if (send_status_code(-1) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

if( (si==sctp_listen && i==0) && startup_done)

*startup_done = -1;

exit(-1);

}

/* was startup route executed so far ? if not, run it only by the

* first SCTP proc (first proc from first interface) */

if( (si==sctp_listen && i==0) && startup_done!=NULL && *startup_done==0) {

LM_DBG("runing startup for first SCTP\n");

if(run_startup_route()< 0) {

LM_ERR("Startup route processing failed\n");

if (send_status_code(-1) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

*startup_done = -1;

exit(-1);

}

*startup_done = 1;

}

if (send_status_code(0) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

sctp_server_rcv_loop();

exit(-1);

} else {

/* wait for first proc to finish the startup route */

if( (si==sctp_listen && i==0) && startup_done!=NULL)

while( !(*startup_done) ) {usleep(5);handle_sigs();}

}

}

}

}

#endif /* USE_SCTP */

/* this is the main process -> it shouldn't send anything */

bind_address=0;

/* fork for the timer process*/

if (start_timer_processes()!=0) {

LM_CRIT("cannot start timer process(es)\n");

goto error;

}

#ifdef USE_TCP

if (!tcp_disable){

/* start tcp & tls receivers */

if (tcp_init_children(&chd_rank, startup_done)<0) goto error;

/* wait for the startup route to be executed */

if( startup_done!=NULL)

while( !(*startup_done) ) {usleep(5);handle_sigs();}

/* start tcp+tls master proc */

if ( (pid=internal_fork( "TCP main"))<0 ) {

LM_CRIT("cannot fork tcp main process\n");

goto error;

}else if (pid==0){

/* child */

/* close the TCP inter-process sockets */

close(unix_tcp_sock);

unix_tcp_sock = -1;

close(pt[process_no].unix_sock);

pt[process_no].unix_sock = -1;

/* init modules */

if (init_child(PROC_TCP_MAIN) < 0) {

LM_ERR("error in init_child for tcp main\n");

if (send_status_code(-1) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

exit(-1);

}

if (send_status_code(0) < 0)

LM_ERR("failed to send status code\n");

clean_write_pipeend();

tcp_main_loop();

exit(-1);

}

}

#endif