deleted file mode 100644

@@ -1,2661 +0,0 @@

-/*

- * Copyright (C) 2001-2003 FhG Fokus

- *

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

- *

- * Kamailio 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

- *

- * Kamailio 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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA

- *

- */

-

-/** Kamailio core :: main file (init, daemonize, startup)

- * @file main.c

- * @ingroup core

- * Module: core

- */

-

-/*! @defgroup core Kamailio core

- *

- * sip router core part.

- */

-

-#include <stdio.h>

-#include <stdlib.h>

-#include <errno.h>

-#include <ctype.h>

-#include <string.h>

-#include <netdb.h>

-#include <unistd.h>

-#include <sys/types.h>

-#include <sys/socket.h>

-#if defined(HAVE_NETINET_IN_SYSTM)

-#include <netinet/in_systm.h>

-#endif

-#include <netinet/in.h>

-#include <netinet/ip.h>

-#include <arpa/inet.h>

-#include <sys/utsname.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 <sys/ioctl.h>

-#include <net/if.h>

-#ifdef HAVE_SYS_SOCKIO_H

-#include <sys/sockio.h>

-#endif

-

-#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"

-#include "shm_init.h"

-#endif /* SHM_MEM */

-#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 "nonsip_hooks.h"

-#include "ut.h"

-#include "events.h"

-#include "signals.h"

-#ifdef USE_RAW_SOCKS

-#include "raw_sock.h"

-#endif /* USE_RAW_SOCKS */

-#ifdef USE_TCP

-#include "poll_types.h"

-#include "tcp_init.h"

-#include "tcp_options.h"

-#ifdef CORE_TLS

-#include "tls/tls_init.h"

-#define tls_has_init_si() 1

-#define tls_loaded() 1

-#else

-#include "tls_hooks_init.h"

-#endif /* CORE_TLS */

-#endif /* USE_TCP */

-#ifdef USE_SCTP

-#include "sctp_core.h"

-#endif

-#include "usr_avp.h"

-#include "rpc_lookup.h"

-#include "core_cmd.h"

-#include "flags.h"

-#include "lock_ops_init.h"

-#include "atomic_ops_init.h"

-#ifdef USE_DNS_CACHE

-#include "dns_cache.h"

-#endif

-#ifdef USE_DST_BLACKLIST

-#include "dst_blacklist.h"

-#endif

-#include "rand/fastrand.h" /* seed */

-#include "rand/kam_rand.h"

-

-#include "stats.h"

-#include "counters.h"

-#include "cfg/cfg.h"

-#include "cfg/cfg_struct.h"

-#include "cfg_core.h"

-#include "endianness.h" /* init */

-#include "basex.h" /* init */

-#include "pvapi.h" /* init PV api */

-#include "pv_core.h" /* register core pvars */

-#include "ppcfg.h"

-#include "sock_ut.h"

-#include "async_task.h"

-#include "dset.h"

-#include "timer_proc.h"

-#include "srapi.h"

-

-#ifdef DEBUG_DMALLOC

-#include <dmalloc.h>

-#endif

-#include "ver.h"

-

-/* define SIG_DEBUG by default */

-#ifdef NO_SIG_DEBUG

-#undef SIG_DEBUG

-#else

-#define SIG_DEBUG

-#endif

-

-

-

-static char help_msg[]= "\

-Usage: " NAME " [options]\n\

-Options:\n\

-    -f file      Configuration file (default: " CFG_FILE ")\n\

-    -L path      Modules search path (default: " MODS_DIR ")\n\

-    -c           Check configuration file for errors\n\

-    -l address   Listen on the specified address/interface (multiple -l\n\

-                  mean listening on more addresses).  The address format is\n\

-                  [proto:]addr_lst[:port], where proto=udp|tcp|tls|sctp, \n\

-                  addr_lst= addr|(addr, addr_lst) and \n\

-                  addr= host|ip_address|interface_name. \n\

-                  E.g: -l locahost, -l udp:127.0.0.1:5080, -l eth0:5062,\n\

-                  -l \"sctp:(eth0)\", -l \"(eth0, eth1, 127.0.0.1):5065\".\n\

-                  The default behaviour is to listen on all the interfaces.\n\

-    -n processes Number of child processes to fork per interface\n\

-                  (default: 8)\n\

-    -r           Use dns to check if is necessary to add a \"received=\"\n\

-                  field to a via\n\

-    -R           Same as `-r` but use reverse dns;\n\

-                  (to use both use `-rR`)\n\

-    -K           Turn on \"via:\" host checking when forwarding replies\n\

-    -d           Debugging mode (multiple -d increase the level)\n\

-    -D           Control how daemonize is done:\n\

-                  -D..do not fork (almost) anyway;\n\

-                  -DD..do not daemonize creator;\n\

-                  -DDD..daemonize (default)\n\

-    -E           Log to stderr\n\

-    -e           Log messages printed in terminal colors (requires -E)\n"

-#ifdef USE_TCP

-"    -T           Disable tcp\n\

-    -N           Number of tcp child processes (default: equal to `-n')\n\

-    -W type      poll method (depending on support in OS, it can be: poll,\n\

-                  epoll_lt, epoll_et, sigio_rt, select, kqueue, /dev/poll)\n"

-#endif

-#ifdef USE_SCTP

-"    -S           disable sctp\n\

-    -Q            Number of sctp child processes (default: equal to `-n')\n"

-#endif /* USE_SCTP */

-"    -v (-V)      Version number\n\

-    -h           This help message\n\

-    -I           Print more internal compile flags and options\n\

-    -b nr        Maximum receive buffer size which will not be exceeded by\n\

-                  auto-probing procedure even if  OS allows\n\

-    -m nr        Size of shared memory allocated in Megabytes\n\

-    -M nr        Size of private memory allocated, in Megabytes\n\

-    -w dir       Change the working directory to \"dir\" (default: \"/\")\n\

-    -t dir       Chroot to \"dir\"\n\

-    -u uid       Change uid \n\

-    -g gid       Change gid \n\

-    -P file      Create a pid file\n\

-    -G file      Create a pgid file\n\

-    -Y dir       Runtime dir\n\

-    -O nr        Script optimization level (debugging option)\n\

-    -a mode      Auto aliases mode: enable with yes or on,\n\

-                  disable with no or off\n\

-    -A define    Add config pre-processor define (e.g., -A WITH_AUTH)\n\

-    -x name      Specify internal manager for shared memory (shm)\n\

-                  - can be: fm, qm or tlsf\n\

-    -X name      Specify internal manager for private memory (pkg)\n\

-                  - if omitted, the one for shm is used\n"

-#ifdef STATS

-"    -s file     File to which statistics is dumped (disabled otherwise)\n"

-#endif

-;

-

-

-/* print compile-time constants */

-void print_ct_constants(void)

-{

-#ifdef ADAPTIVE_WAIT

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

-#endif

-/*

-#ifdef SHM_MEM

-	printf("SHM_MEM_SIZE=%d, ", SHM_MEM_SIZE);

-#endif

-*/

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

-			" MAX_URI_SIZE %d, BUF_SIZE %d, DEFAULT PKG_SIZE %uMB\n",

-		MAX_RECV_BUFFER_SIZE, MAX_LISTEN, MAX_URI_SIZE,

-		BUF_SIZE, PKG_MEM_SIZE);

-#ifdef USE_TCP

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

-#endif

-}

-

-/* print compile-time constants */

-void print_internals(void)

-{

-	printf("Print out of %s internals\n", NAME);

-	printf("  Version: %s\n", full_version);

-	printf("  Default config: %s\n", CFG_FILE);

-	printf("  Default paths to modules: %s\n", MODS_DIR);

-	printf("  Compile flags: %s\n", ver_flags );

-	printf("  MAX_RECV_BUFFER_SIZE=%d\n", MAX_RECV_BUFFER_SIZE);

-	printf("  MAX_LISTEN=%d\n", MAX_LISTEN);

-	printf("  MAX_URI_SIZE=%d\n", MAX_URI_SIZE);

-	printf("  BUF_SIZE=%d\n", BUF_SIZE);

-	printf("  DEFAULT PKG_SIZE=%uMB\n", PKG_MEM_SIZE);

-#ifdef SHM_MEM

-	printf("  DEFAULT SHM_SIZE=%uMB\n", SHM_MEM_SIZE);

-#endif

-#ifdef ADAPTIVE_WAIT

-	printf("  ADAPTIVE_WAIT_LOOPS=%d\n", ADAPTIVE_WAIT_LOOPS);

-#endif

-#ifdef USE_TCP

-	printf("  TCP poll methods: %s\n", poll_support);

-#endif

-	printf("  Source code revision ID: %s\n", ver_id);

-	printf("  Compiled with: %s\n", ver_compiler);

-	printf("  Compiled on: %s\n", ver_compiled_time);

-	printf("Thank you for flying %s!\n", NAME);

-}

-

-/* debugging function */

-/*

-void receive_stdin_loop(void)

-{

-	#define BSIZE 1024

-	char buf[BSIZE+1];

-	int len;

-

-	while(1){

-		len=fread(buf,1,BSIZE,stdin);

-		buf[len+1]=0;

-		receive_msg(buf, len);

-		printf("-------------------------\n");

-	}

-}

-*/

-

-/* global vars */

-

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

-					 to use kill(0, sig) */

-

-char* mods_dir = MODS_DIR;  /* search path for dyn. loadable modules */

-int   mods_dir_cmd = 0; /* mods dir path set in command lin e*/

-

-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 */

-unsigned int sql_buffer_size = 65535; /* Size for the SQL buffer. Defaults to 64k. 

-                                         This may be re-configured */

-int socket_workers = 0;		/* number of workers processing requests for a socket

-							   - it's reset everytime with a new listen socket */

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

-#ifdef USE_TCP

-int tcp_cfg_children_no = 0; /* set via config or command line option */

-int tcp_children_no = 0; /* based on socket_workers and tcp_cfg_children_no */

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

-#endif

-#ifdef USE_TLS

-#ifdef	CORE_TLS

-int tls_disable = 0;  /* tls enabled by default */

-#else

-int tls_disable = 1;  /* tls disabled by default */

-#endif /* CORE_TLS */

-#endif /* USE_TLS */

-#ifdef USE_SCTP

-int sctp_children_no = 0;

-int sctp_disable = 2; /* 1 if sctp is disabled, 2 if auto mode, 0 enabled */

-#endif /* USE_SCTP */

-

-struct process_table *pt=0;		/*array with children pids, 0= main proc,

-									alloc'ed in shared mem if possible*/

-int *process_count = 0;			/* Total number of SER processes currently

-								   running */

-gen_lock_t* process_lock;		/* lock on the process table */

-int process_no = 0;				/* index of process in the pt */

-

-time_t up_since;

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

-int dont_fork = 0;

-int dont_daemonize = 0;

-int log_stderr = 0;

-int log_color = 0;

-/* set custom app name for syslog printing */

-char *log_name = 0;

-char *log_prefix_fmt = 0;

-pid_t creator_pid = (pid_t) -1;

-int config_check = 0;

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

-int check_via =  0;

-/* translate user=phone URIs to TEL URIs */

-int phone2tel = 1;

-/* debugging level for timer debugging */

-int timerlog = L_WARN;

-/* should replies include extensive warnings? by default no,

-   good for trouble-shooting

-*/

-int sip_warning = 0;

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

-   be default yes, good for trouble-shooting

-*/

-int server_signature=1;

-str server_hdr = {SERVER_HDR, SERVER_HDR_LEN};

-str user_agent_hdr = {USER_AGENT, USER_AGENT_LEN};

-str version_table = {VERSION_TABLE, VERSION_TABLE_LEN};

-/* should ser 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;

-/* add or not the rev dns names to aliases list */

-int sr_auto_aliases=1;

-char* working_dir = 0;

-char* chroot_dir = 0;

-char* runtime_dir = "" RUN_DIR;

-char* user=0;

-char* group=0;

-int uid = 0;

-int gid = 0;

-char* sock_user=0;

-char* sock_group=0;

-int sock_uid= -1;

-int sock_gid= -1;

-int sock_mode= S_IRUSR| S_IWUSR| S_IRGRP| S_IWGRP; /* rw-rw---- */

-

-int server_id = 0; /* Configurable unique ID of the server */

-

-/* maximum number of branches for transaction */

-unsigned int sr_dst_max_branches = MAX_BRANCHES_DEFAULT;

-

-/* set timeval for each received sip message */

-int sr_msg_time = 1;

-

-/* onsend_route is executed for replies*/

-int onsend_route_reply = 0;

-

-/* more config stuff */

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

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

-

-/* memory options */

-int shm_force_alloc=0; /* force immediate (on startup) page allocation

-						  (by writting 0 in the pages), useful if

-						  mlock_pages is also 1 */

-int mlock_pages=0; /* default off, try to disable swapping */

-

-/* real time options */

-int real_time=0; /* default off, flags: 1 on only timer, 2  slow timer,

-										4 all procs (7=all) */

-int rt_prio=0;

-int rt_policy=0; /* SCHED_OTHER */

-int rt_timer1_prio=0;  /* "fast" timer */

-int rt_timer2_prio=0;  /* "slow" timer */

-int rt_timer1_policy=0; /* "fast" timer, SCHED_OTHER */

-int rt_timer2_policy=0; /* "slow" timer, SCHED_OTHER */

-

-

-/* a hint to reply modules whether they should send reply

-   to IP advertised in Via or IP from which a request came

-*/

-int reply_to_via=0;

-

-#ifdef USE_MCAST

-int mcast_loopback = 0;

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

-char* mcast = 0;

-#endif /* USE_MCAST */

-

-int tos = IPTOS_LOWDELAY;

-int pmtu_discovery = 0;

-

-int auto_bind_ipv6 = 0;

-

-#if 0

-char* names[MAX_LISTEN];              /* our names */

-int names_len[MAX_LISTEN];            /* lengths of the names*/

-struct ip_addr addresses[MAX_LISTEN]; /* our ips */

-int addresses_no=0;                   /* number of names/ips */

-#endif

-struct socket_info* udp_listen=0;

-#ifdef USE_TCP

-int tcp_main_pid=0; /* set after the tcp main process is started */

-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_RAW_SOCKS

-int raw_udp4_send_sock = -1; /* raw socket used for sending udp4 packets */

-#endif /* USE_RAW_SOCKS */

-#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

-

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

-#ifdef USE_TLS

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

-#endif

-

-struct host_alias* aliases=0; /* name aliases list */

-

-/* Parameter to child_init */

-int child_rank = 0;

-

-/* how much to wait for children to terminate, before taking extreme measures*/

-int ser_kill_timeout=DEFAULT_SER_KILL_TIMEOUT;

-

-/* process_bm_t process_bit = 0; */

-#ifdef ROUTE_SRV

-#endif

-

-/* cfg parsing */

-int cfg_errors=0;

-int cfg_warnings=0;

-

-

-/* shared memory (in MB) */

-unsigned long shm_mem_size=0;

-/* private (pkg) memory (in MB) */

-unsigned long pkg_mem_size=0;

-

-/* export command-line to anywhere else */

-int my_argc;

-char **my_argv;

-

-/* set to 1 when the cfg framework and core cfg is initialized/registered */

-static int cfg_ok=0;

-

-#define MAX_FD 32 /* maximum number of inherited open file descriptors,

-		    (normally it shouldn't  be bigger  than 3) */

-

-

-extern FILE* yyin;

-extern int yyparse(void);

-

-

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

-int fixup_complete=0; /* flag = is the fixup complete ? */

-

-char* pid_file = 0; /* filename as asked by use */

-char* pgid_file = 0;

-

-

-/* memory manager */

-#define SR_MEMMNG_DEFAULT	"qm"

-

-char *sr_memmng_pkg = NULL;

-char *sr_memmng_shm = NULL;

-

-/* call it before exiting; if show_status==1, mem status is displayed */

-void cleanup(int show_status)

-{

-	int memlog;

-

-	/*clean-up*/

-#ifndef SHM_SAFE_MALLOC

-	if (_shm_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 */

-#endif

-	destroy_rpcs();

-	destroy_modules();

-#ifdef USE_DNS_CACHE

-	destroy_dns_cache();

-#endif

-#ifdef USE_DST_BLACKLIST

-	destroy_dst_blacklist();

-#endif

-	/* restore the original core configuration before the

-	 * config block is freed, otherwise even logging is unusable,

-	 * it can case segfault */

-	if (cfg_ok){

-		cfg_update();

-		/* copy current config into default_core_cfg */

-		if (core_cfg)

-			default_core_cfg=*((struct cfg_group_core*)core_cfg);

-	}

-	core_cfg = &default_core_cfg;

-	cfg_destroy();

-#ifdef USE_TCP

-	destroy_tcp();

-#ifdef USE_TLS

-	destroy_tls();

-#endif /* USE_TLS */

-#endif /* USE_TCP */

-#ifdef USE_SCTP

-	sctp_core_destroy();

-#endif

-	destroy_timer();

-	pv_destroy_api();

-	destroy_script_cb();

-	destroy_nonsip_hooks();

-	destroy_routes();

-	destroy_atomic_ops();

-	destroy_counters();

-	memlog=cfg_get(core, core_cfg, memlog);

-#ifdef PKG_MALLOC

-	if (show_status && memlog <= cfg_get(core, core_cfg, debug)){

-		if (cfg_get(core, core_cfg, mem_summary) & 1) {

-			LOG(memlog, "Memory status (pkg):\n");

-			pkg_status();

-		}

-		if (cfg_get(core, core_cfg, mem_summary) & 4) {

-			LOG(memlog, "Memory still-in-use summary (pkg):\n");

-			pkg_sums();

-		}

-	}

-#endif

-#ifdef SHM_MEM

-	if (pt) shm_free(pt);

-	pt=0;

-	if (show_status && memlog <= cfg_get(core, core_cfg, debug)){

-		if (cfg_get(core, core_cfg, mem_summary) & 2) {

-			LOG(memlog, "Memory status (shm):\n");

-			shm_status();

-		}

-		if (cfg_get(core, core_cfg, mem_summary) & 8) {

-			LOG(memlog, "Memory still-in-use summary (shm):\n");

-			shm_sums();

-		}

-	}

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

-	shm_destroy_manager();

-#endif

-	destroy_lock_ops();

-	if (pid_file) unlink(pid_file);

-	if (pgid_file) unlink(pgid_file);

-	pkg_destroy_manager();

-}

-

-

-/* 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 ser is started in "dont-fork"

- *  mode. Sending the signal to all the processes in pt[] will not work

- *  for processes forked from modules (which have no correspondent entry in

- *  pt), but this can happen only in dont_fork mode (which is only for

- *  debugging). So in the worst case + "dont-fork" we might leave some

- *  zombies. -- andrei */

-static void kill_all_children(int signum)

-{

-	int r;

-

-	if (own_pgid) kill(0, signum);

-	else if (pt){

-		 /* lock processes table only if this is a child process

-		  * (only main can add processes, so from main is safe not to lock

-		  *  and moreover it avoids the lock-holding suicidal children problem)

-		  */

-		if (!is_main) lock_get(process_lock);

-		for (r=1; r<*process_count; r++){

-			if (r==process_no) continue; /* try not to be suicidal */

-			if (pt[r].pid) {

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

-			}

-			else LM_CRIT("killing: %s > %d no pid!!!\n",

-							pt[r].desc, pt[r].pid);

-		}

-		if (!is_main) lock_release(process_lock);

-	}

-}

-

-

-

-/* if this handler is called, a critical timeout has occurred while

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

-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) */

-}

-

-

-/* like sig_alarm_kill, but the timeout has occurred when cleaning up

- * => try to leave a core for future diagnostics */

-static void sig_alarm_abort(int signo)

-{

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

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

-	abort();

-}

-

-

-

-static void shutdown_children(int sig, int show_status)

-{

-	kill_all_children(sig);

-	if (set_sig_h(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(ser_kill_timeout);

-	while((wait(0) > 0) || (errno==EINTR)); /* wait for all the

-											   children to terminate*/

-	set_sig_h(SIGALRM, sig_alarm_abort);

-	cleanup(show_status); /* cleanup & show status*/

-	alarm(0);

-	set_sig_h(SIGALRM, SIG_IGN);

-}

-

-

-

-void handle_sigs(void)

-{

-	pid_t	chld;

-	int	chld_status;

-	int memlog;

-

-	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");

-			LM_NOTICE("Thank you for flying " NAME "!!!\n");

-			/* shutdown/kill all the children */

-			shutdown_children(SIGTERM, 1);

-			exit(0);

-			break;

-

-		case SIGUSR1:

-#ifdef STATS

-			dump_all_statistic();

-#endif

-		memlog=cfg_get(core, core_cfg, memlog);

-#ifdef PKG_MALLOC

-		if (memlog <= cfg_get(core, core_cfg, debug)){

-			if (cfg_get(core, core_cfg, mem_summary) & 1) {

-				LOG(memlog, "Memory status (pkg):\n");

-				pkg_status();

-			}

-			if (cfg_get(core, core_cfg, mem_summary) & 2) {

-				LOG(memlog, "Memory still-in-use summary (pkg):\n");

-				pkg_sums();

-			}

-		}

-#endif

-#ifdef SHM_MEM

-		if (memlog <= cfg_get(core, core_cfg, debug)){

-			if (cfg_get(core, core_cfg, mem_summary) & 1) {

-				LOG(memlog, "Memory status (shm):\n");

-				shm_status();

-			}

-			if (cfg_get(core, core_cfg, mem_summary) & 2) {

-				LOG(memlog, "Memory still-in-use summary (shm):\n");

-				shm_sums();

-			}

-		}

-#endif

-			break;

-

-		case SIGCHLD:

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

-				if (WIFEXITED(chld_status))

-					LM_ALERT("child process %ld exited normally,"

-							" status=%d\n", (long)chld,

-							WEXITSTATUS(chld_status));

-				else if (WIFSIGNALED(chld_status)) {

-					LM_ALERT("child process %ld exited by a signal"

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

-#ifdef WCOREDUMP

-					LM_ALERT("core was %sgenerated\n",

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

-#endif

-				}else if (WIFSTOPPED(chld_status))

-					LM_ALERT("child process %ld stopped by a"

-								" signal %d\n", (long)chld,

-								 WSTOPSIG(chld_status));

-			}

-#ifndef STOP_JIRIS_CHANGES

-			if (dont_fork) {

-				LM_INFO("dont_fork turned on, living on\n");

-				break;

-			}

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

-#endif

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

-			/* exit */

-			shutdown_children(SIGTERM, 1);

-			if (WIFSIGNALED(chld_status)) {

-				exit(1);

-			} else {

-				exit(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;

-}

-

-

-

-/* added by jku; allows for regular exit on a specific signal;

-   good for profiling which only works if exited regularly and

-   not by default signal handlers

-    - modified by andrei: moved most of the stuff to handle_sigs,

-       made it safer for the "fork" case

-*/

-void sig_usr(int signo)

-{

-

-#ifdef PKG_MALLOC

-	int memlog;

-#endif

-

-	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:

-#ifdef SIG_DEBUG /* signal unsafe stuff follows */

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

-#endif

-				break;

-			case SIGINT:

-			case SIGTERM:

-#ifdef SIG_DEBUG /* signal unsafe stuff follows */

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

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

-					#ifdef PKG_MALLOC

-					/* make sure we have current cfg values, but update only

-					  the safe part (values not requiring callbacks), to

-					  account for processes that might not have registered

-					  config support */

-					cfg_update_no_cbs();

-					memlog=cfg_get(core, core_cfg, memlog);

-					if (memlog <= cfg_get(core, core_cfg, debug)){

-						if (cfg_get(core, core_cfg, mem_summary) & 1) {

-							LOG(memlog, "Memory status (pkg):\n");

-							pkg_status();

-						}

-						if (cfg_get(core, core_cfg, mem_summary) & 2) {

-							LOG(memlog, "Memory still-in-use summary (pkg):"

-									"\n");

-							pkg_sums();

-						}

-					}

-					#endif

-#endif

-					_exit(0);

-					break;

-			case SIGUSR1:

-#ifdef PKG_MALLOC

-					cfg_update_no_cbs();

-					memlog=cfg_get(core, core_cfg, memlog);

-					if (memlog <= cfg_get(core, core_cfg, debug)){

-						if (cfg_get(core, core_cfg, mem_summary) & 1) {

-							LOG(memlog, "Memory status (pkg):\n");

-							pkg_status();

-						}

-						if (cfg_get(core, core_cfg, mem_summary) & 2) {

-							LOG(memlog, "Memory still-in-use summary (pkg):\n");

-							pkg_sums();

-						}

-					}

-#endif

-					break;

-				/* ignored*/

-			case SIGUSR2:

-			case SIGHUP:

-					break;

-			case SIGCHLD:

-#ifndef 			STOP_JIRIS_CHANGES

-#ifdef SIG_DEBUG /* signal unsafe stuff follows */

-					LM_DBG("SIGCHLD received: "

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

-#endif

-#else

-					_exit(0); /* terminate if one child died */

-#endif

-					break;

-		}

-	}

-}

-

-

-

-/* install the signal handlers, returns 0 on success, -1 on error */

-int install_sigs(void)

-{

-	/* added by jku: add exit handler */

-	if (set_sig_h(SIGINT, sig_usr) == SIG_ERR ) {

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