utils.c File Reference

#include "gw-config.h"
#include <ctype.h>
#include <errno.h>
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <termios.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/stat.h>
#include <sys/utsname.h>
#include <fcntl.h>
#include <pwd.h>
#include <grp.h>
#include <libgen.h>
#include "gwlib.h"

Go to the source code of this file.

Macros
#define	PANIC_SCRIPT_MAX_LEN   4096

Functions
static void	fatal_handler (int sig, siginfo_t *info, void *secret)
static void	parachute_sig_handler (int signum)
static void	parachute_init_signals (int child)
static int	is_executable (const char *filename)
static int	become_daemon (void)
static	PRINTFLIKE (2, 3)
static void	parachute_start (const char *myname, const char *panic_script)
static void	write_pid_file (void)
static void	remove_pid_file (void)
static int	change_user (const char *user)
MultibyteInt	get_variable_value (Octet *source, int *len)
int	write_variable_value (MultibyteInt value, Octet *dest)
Octet	reverse_octet (Octet source)
void	init_fatal_signals ()
void	report_versions (const char *boxname)
Octstr *	version_report_string (const char *boxname)
int	get_and_set_debugs (int argc, char **argv, int(*find_own)(int index, int argc, char **argv))
static int	pattern_matches_ip (Octstr *pattern, Octstr *ip)
static int	pattern_list_matches_ip (Octstr *pattern_list, Octstr *ip)
int	is_allowed_ip (Octstr *allow_ip, Octstr *deny_ip, Octstr *ip)
int	connect_denied (Octstr *allow_ip, Octstr *ip)
int	does_prefix_match (Octstr *prefix, Octstr *number)
int	normalize_number (char *dial_prefixes, Octstr **number)
long	decode_network_long (unsigned char *data)
void	encode_network_long (unsigned char *data, unsigned long value)
void	kannel_cfmakeraw (struct termios *tio)
int	gw_isdigit (int c)
int	gw_isxdigit (int c)
int	roundup_div (int a, int b)
unsigned long long	gw_generate_id (void)

Variables
static pid_t	child_pid = -1
static pid_t	pidfile_owner_pid = -1
static struct sigaction	child_actions [32]
static int	child_actions_init = 0
static char *	pid_file = NULL
static volatile sig_atomic_t	parachute_shutdown = 0

Macro Definition Documentation

PANIC_SCRIPT_MAX_LEN

#define PANIC_SCRIPT_MAX_LEN   4096

Definition at line 288 of file utils.c.

Referenced by PRINTFLIKE().

Function Documentation

become_daemon()

static int become_daemon ( void  )

static

Definition at line 263 of file utils.c.

References panic.

Referenced by get_and_set_debugs().

{
    int fd;
    if (getppid() != 1) {
       signal(SIGTTOU, SIG_IGN);
       signal(SIGTTIN, SIG_IGN);
       signal(SIGTSTP, SIG_IGN);
       if (fork())
          return 0;
       setsid();
    }

    close(STDIN_FILENO);
    close(STDOUT_FILENO);
    close(STDERR_FILENO);
    fd = open("/dev/null", O_RDWR); /* stdin */
    if (fd == -1)
        panic(errno, "Could not open `/dev/null'");
    dup(fd); /* stdout */
    dup(fd); /* stderr */

    chdir("/");
    return 1;
}

change_user()

static int change_user ( const char *  user )

static

Definition at line 440 of file utils.c.

References error().

Referenced by get_and_set_debugs().

{
    struct passwd *pass;

    if (!user)
        return -1;

    pass = getpwnam(user);
    if (!pass) {
        error(0, "Could not find a user `%s' in system.", user);
        return -1;
    }

    if (-1 == setgid(pass->pw_gid)) {
        error(errno, "Could not change group id from %ld to %ld.", (long) getgid(), (long) pass->pw_gid);
        return -1;
    }

#ifdef HAVE_INITGROUPS
    if (initgroups(user, pass->pw_gid) == -1) {
        error(errno, "Could not set supplementary group ID's.");
    }
#endif
    
    if (-1 == setuid(pass->pw_uid)) {
        error(errno, "Could not change user id from %ld to %ld.", (long) getuid(), (long) pass->pw_uid);
        return -1;
    }

    return 0;
}

connect_denied()

int connect_denied	(	Octstr *	allow_ip,
		Octstr *	ip
	)

Definition at line 833 of file utils.c.

References allow_ip, octstr_imm(), and pattern_list_matches_ip().

Referenced by httpsmsc_receiver().

{
    if (ip == NULL)
    return 1;

    /* If IP not set, allow from Localhost */
    if (allow_ip == NULL) { 
    if (pattern_list_matches_ip(octstr_imm("127.0.0.1"), ip))
        return 0;
    } else {
    if (pattern_list_matches_ip(allow_ip, ip))
        return 0;
    }
    return 1;
}

decode_network_long()

long decode_network_long

(

unsigned char *

data

)

Definition at line 935 of file utils.c.

Referenced by conn_read_withlen(), parse_integer(), read_msg(), and smpp_pdu_read_len().

                                              {
        return (data[0] << 24) | (data[1] << 16) | (data[2] << 8) | data[3];
}

does_prefix_match()

int does_prefix_match	(	Octstr *	prefix,
		Octstr *	number
	)

Definition at line 850 of file utils.c.

References gw_assert(), number, and octstr_get_cstr.

Referenced by check_allowed_translation(), smsbox_req_handle(), and smscconn_usable().

{
    /* XXX modify to use just octstr operations
     */
    char *b, *p, *n;

    gw_assert(prefix != NULL);
    gw_assert(number != NULL);

    p = octstr_get_cstr(prefix);
    n = octstr_get_cstr(number);
    

    while (*p != '\0') {
        b = n;
        for (b = n; *b != '\0'; b++, p++) {
            if (*p == ';' || *p == '\0') {
                return 1;
            }
            if (*p != *b) break;
        }
        if (*p == ';' || *p == '\0') {
            return 1;
        }
        while (*p != '\0' && *p != ';')
            p++;
        while (*p == ';') p++;
    }
    return 0;
}

encode_network_long()

void encode_network_long	(	unsigned char *	data,
		unsigned long	value
	)

Definition at line 940 of file utils.c.

Referenced by append_integer(), conn_write_withlen(), and write_msg().

                                                                   {
        data[0] = (value >> 24) & 0xff;
        data[1] = (value >> 16) & 0xff;
        data[2] = (value >> 8) & 0xff;
        data[3] = value & 0xff;
}

fatal_handler()

static void fatal_handler ( int  sig, siginfo_t *  info, void *  secret  )

static

Definition at line 146 of file utils.c.

References gw_backtrace(), and size.

Referenced by init_fatal_signals().

{
#ifdef HAVE_BACKTRACE
    void *trace[50];
#ifdef REG_EIP
    ucontext_t *uc = (ucontext_t*)secret;
#endif
    size_t size;
#endif    
    struct sigaction act;
    
    act.sa_handler = SIG_DFL;
    sigemptyset(&act.sa_mask);
    act.sa_flags = 0;
    sigaction(sig, &act, NULL);
    
#ifdef HAVE_BACKTRACE
    size = backtrace(trace, sizeof(trace) / sizeof(void*));
#ifdef REG_EIP
    /* overwrite sigaction with caller's address */
    trace[1] = (void *) uc->uc_mcontext.gregs[REG_EIP];
#endif
    gw_backtrace(trace, size, 0);
#endif
    
    raise(sig);
}

get_and_set_debugs()

int get_and_set_debugs	(	int	argc,
		char **	argv,
		int(*)(int index, int argc, char **argv)	find_own
	)

Definition at line 626 of file utils.c.

References become_daemon(), cfg_dump_all(), change_user(), GW_DEBUG, GW_NON_EXCL, info(), init_fatal_signals(), log_close_all(), log_open(), log_set_debug_places(), log_set_output_level(), log_set_syslog(), octstr_destroy(), octstr_get_cstr, panic, parachute_start(), pid_file, remove_pid_file(), version_report_string(), and write_pid_file().

Referenced by main().

{
    int i, ret = -1;
    int debug_lvl = -1;
    int file_lvl = GW_DEBUG;
    char *log_file = NULL;
    char *debug_places = NULL;
    char *panic_script = NULL, *user = NULL;
    int parachute = 0, daemonize = 0;

    for (i=1; i < argc; i++) {
        if (strcmp(argv[i],"-v")==0 || strcmp(argv[i],"--verbosity")==0) {
            if (i+1 < argc) {
                debug_lvl = atoi(argv[i+1]);
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]); 
        } else if (strcmp(argv[i],"-F")==0 || strcmp(argv[i],"--logfile")==0) {
            if (i+1 < argc && *(argv[i+1]) != '-') {
                log_file = argv[i+1];
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]); 
        } else if (strcmp(argv[i],"-V")==0 || strcmp(argv[i],"--fileverbosity")==0) {
            if (i+1 < argc) {
                file_lvl = atoi(argv[i+1]);
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]); 
        } else if (strcmp(argv[i],"-D")==0 || strcmp(argv[i],"--debug")==0) {
            if (i+1 < argc) {
                debug_places = argv[i+1];
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]); 
        } else if (strcmp(argv[i], "-X")==0 || strcmp(argv[i], "--panic-script")==0) {
            if (i+1 < argc) {
                panic_script = argv[i+1];
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]);
        } else if (strcmp(argv[i], "-P")==0 || strcmp(argv[i], "--parachute")==0) {
            parachute = 1;
        } else if (strcmp(argv[i], "-d")==0 || strcmp(argv[i], "--daemonize")==0) {
            daemonize = 1;
        } else if (strcmp(argv[i], "-p")==0 || strcmp(argv[i], "--pid-file")==0) {
            if (i+1 < argc) {
                pid_file = argv[i+1];
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]);
        } else if (strcmp(argv[i], "-u")==0 || strcmp(argv[i], "--user")==0) {
            if (i+1 < argc) {
                user = argv[i+1];
                i++;
            } else
                panic(0, "Missing argument for option %s\n", argv[i]);
        } else if (strcmp(argv[i], "-g")==0 || strcmp(argv[i], "--generate")==0) {
            cfg_dump_all();
            exit(0);
        } else if (strcmp(argv[i], "--version")==0) {
            Octstr *version = version_report_string(basename(argv[0]));
            printf("%s", octstr_get_cstr(version));
            octstr_destroy(version);
            exit(0);
        } else if (strcmp(argv[i],"--")==0) {
            i++;
            break;
        } else if (*argv[i] != '-') {
            break;
        } else {
            if (find_own != NULL) {
            ret = find_own(i, argc, argv);
        }
        if (ret < 0) {
            fprintf(stderr, "Unknown option %s, exiting.\n", argv[i]);
            panic(0, "Option parsing failed");
        } else
            i += ret;   /* advance additional args */
        }
    }

    if (user && -1 == change_user(user))
        panic(0, "Could not change to user `%s'.", user);

    /* deamonize */
    if (daemonize && !become_daemon())
       exit(0);

    if (pid_file) {
        write_pid_file();
        atexit(remove_pid_file);
    }

    if (parachute) {
        /*
         * if we are running as daemon so open syslog
         * in order not to deal with i.e. log rotate.
         */
        if (daemonize) {
            char *ident = strrchr(argv[0], '/');
            if (!ident)
                ident = argv[0];
            else
                ident++;
            log_set_syslog(ident, (debug_lvl > -1 ? debug_lvl : 0));
        }
        parachute_start(argv[0], panic_script);
        /* now we are in child process so close syslog */
        if (daemonize)
            log_close_all();
    }

    if (debug_lvl > -1)
        log_set_output_level(debug_lvl);
    if (debug_places != NULL)
        log_set_debug_places(debug_places);
    if (log_file != NULL)
        log_open(log_file, file_lvl, GW_NON_EXCL);

    info(0, "Debug_lvl = %d, log_file = %s, log_lvl = %d",
         debug_lvl, log_file ? log_file : "<none>", file_lvl);
    if (debug_places != NULL)
        info(0, "Debug places: `%s'", debug_places);


    init_fatal_signals();
    
    return i;
}

get_variable_value()

MultibyteInt get_variable_value	(	Octet *	source,
		int *	len
	)

Definition at line 477 of file utils.c.

Referenced by sema_decode_msg().

{
    MultibyteInt retval = 0;
    
    for(*len=1;; (*len)++, source++) {
    retval = retval * 0x80 + (*source & 0x7F);
    if (*source < 0x80)  /* if the continue-bit (high bit) is not set */
        break;
    }
    return retval;
}

gw_generate_id()

unsigned long long gw_generate_id

(

void

)

Definition at line 1013 of file utils.c.

References gw_rand().

{
    /* create a 64 bit unique Id by putting a 32 bit epoch time value
     * and a 32 bit random value together */
    unsigned long random, timer;
     
    random = gw_rand();
    timer = (unsigned long)time(NULL);
    
    return ((unsigned long long)timer << 32) + random;
}

gw_isdigit()

int gw_isdigit

(

int

c

)

Definition at line 988 of file utils.c.

Referenced by convert_addr_from_pdu(), date_parse_iso(), get_originator_type(), handle_dlr(), handle_pdu(), msg_to_cgwop(), msg_to_emimsg(), msg_to_pdu(), pack_parameter(), packet_check_header(), and packet_check_parameter().

{
    return isdigit(c);
}

gw_isxdigit()

int gw_isxdigit

(

int

c

)

Definition at line 994 of file utils.c.

Referenced by octstr_hex_to_binary(), octstr_is_all_hex(), octstr_symbolize(), packet_check(), and packet_check_parameter().

{
    return isxdigit(c);
}

init_fatal_signals()

void init_fatal_signals

(

void

)

Install fatal signal handler. Usefull to receive backtrace if program crash with SEGFAULT.

Definition at line 527 of file utils.c.

References fatal_handler().

Referenced by get_and_set_debugs(), and parachute_init_signals().

{
    /* install fatal signal handler */
    struct sigaction act;
    /* set segfault handler */
    sigemptyset(&act.sa_mask);
    act.sa_sigaction = fatal_handler;
    act.sa_flags = SA_SIGINFO;
    sigaction(SIGSEGV, &act, NULL);
}

is_allowed_ip()

int is_allowed_ip	(	Octstr *	allow_ip,
		Octstr *	deny_ip,
		Octstr *	ip
	)

Definition at line 815 of file utils.c.

References allow_ip, deny_ip, octstr_len(), and pattern_list_matches_ip().

Referenced by accept_boxc(), authorise_username(), cgw_listener(), check_login(), emi2_listener(), fake_listener(), get_data(), httpadmin_run(), main(), and udp_receiver().

{
    if (ip == NULL)
    return 0;

    if (octstr_len(deny_ip) == 0)
    return 1;

    if (allow_ip != NULL && pattern_list_matches_ip(allow_ip, ip))
    return 1;

    if (pattern_list_matches_ip(deny_ip, ip))
        return 0;

    return 1;
}

is_executable()

static int is_executable ( const char *  filename )

static

Definition at line 234 of file utils.c.

References error(), and filename.

Referenced by parachute_start().

{
    struct stat buf;

    if (stat(filename, &buf)) {
        error(errno, "Error while stat of file `%s'", filename);
        return 0;
    }
    if (!S_ISREG(buf.st_mode) && !S_ISLNK(buf.st_mode)) {
        error(0, "File `%s' is not a regular file.", filename);
        return 0;
    }
    /* others has exec permission */
    if (S_IXOTH & buf.st_mode)
        return 1;
    /* group has exec permission */
    if ((S_IXGRP & buf.st_mode) && buf.st_gid == getgid())
        return 1;
    /* owner has exec permission */
    if ((S_IXUSR & buf.st_mode) && buf.st_uid == getuid())
        return 1;

    return 0;
}

kannel_cfmakeraw()

void kannel_cfmakeraw

(

struct termios *

tio

)

Definition at line 951 of file utils.c.

Referenced by at2_open_device(), at_dial(), and X28_open_data_link().

                                           {
    /* Block until a charactor is available, but it only needs to be one*/
    tio->c_cc[VMIN]    = 1;
    tio->c_cc[VTIME]   = 0;

    /* GNU cfmakeraw sets these flags so we had better too...*/

    /* Control modes */
    /* Mask out character size (CSIZE), then set it to 8 bits (CS8).
     * Enable parity bit generation in both directions (PARENB).
     */
    tio->c_cflag      &= ~(CSIZE|PARENB);
    tio->c_cflag      |= CS8;

    /* Input Flags,*/
    /* Turn off all input flags that interfere with the byte stream:
     * BRKINT - generate SIGINT when receiving BREAK, ICRNL - translate
     * NL to CR, IGNCR - ignore CR, IGNBRK - ignore BREAK,
     * INLCR - translate NL to CR, IXON - use XON/XOFF flow control,
     * ISTRIP - strip off eighth bit.
     */
    tio->c_iflag &= ~(BRKINT|ICRNL|IGNCR|IGNBRK|INLCR|IXON|ISTRIP);

    /* Other flags,*/
    /* Turn off all local flags that interpret the byte stream:
     * ECHO - echo input chars, ECHONL - always echo NL even if ECHO is off,
     * ICANON - enable canonical mode (basically line-oriented mode),
     * IEXTEN - enable implementation-defined input processing,
     * ISIG - generate signals when certain characters are received. */
    tio->c_lflag      &= ~(ECHO|ECHONL|ICANON|IEXTEN|ISIG);

    /* Output flags,*/
    /* Disable implementation defined processing on the output stream*/
    tio->c_oflag      &= ~OPOST;
}

normalize_number()

int normalize_number	(	char *	dial_prefixes,
		Octstr **	number
	)

Definition at line 882 of file utils.c.

References gw_assert(), number, octstr_create_from_data, octstr_destroy(), octstr_get_cstr, octstr_insert_data(), octstr_len(), and start.

Referenced by bb_smscconn_receive(), radius_acct_get_msisdn(), smsc2_rout(), and smscconn_send().

{
    char *t, *p, *official, *start;
    int len, official_len;
    
    if (dial_prefixes == NULL || dial_prefixes[0] == '\0')
        return 0;

    t = official = dial_prefixes;
    official_len = 0;

    gw_assert(number != NULL);
    
    while(1) {

        p = octstr_get_cstr(*number);
        for(start = t, len = 0; ; t++, p++, len++)
    {
            if (*t == ',' || *t == ';' || *t == '\0') {
                if (start != official) {
                    Octstr *nstr;
            long n;
            
            if ( official[0] == '-' ) official_len=0;
            n = official_len;
            if (strlen(official) < (size_t) n)
                n = strlen(official);
                    nstr = octstr_create_from_data(official, n);
                    octstr_insert_data(nstr, official_len,
                                           octstr_get_cstr(*number) + len,
                                           octstr_len(*number) - len);
                    octstr_destroy(*number);
                    *number = nstr;
                }
                return 1;
            }
            if (*p == '\0' || *t != *p)
                break;          /* not matching */
        }
        for(; *t != ',' && *t != ';' && *t != '\0'; t++, len++)
            ;
        if (*t == '\0') break;
        if (start == official) official_len = len;
        if (*t == ';') official = t+1;
        t++;
    }
    return 0;
}

parachute_init_signals()

static void parachute_init_signals ( int  child )

static

Definition at line 195 of file utils.c.

References child_actions, child_actions_init, init_fatal_signals(), panic, and parachute_sig_handler().

Referenced by parachute_start().

{
    struct sigaction sa;

    if (child_actions_init && child) {
        sigaction(SIGTERM, &child_actions[SIGTERM], NULL);
        sigaction(SIGQUIT, &child_actions[SIGQUIT], NULL);
        sigaction(SIGINT,  &child_actions[SIGINT], NULL);
        sigaction(SIGABRT, &child_actions[SIGABRT], NULL);
        sigaction(SIGHUP,  &child_actions[SIGHUP], NULL);
        sigaction(SIGALRM, &child_actions[SIGALRM], NULL);
        sigaction(SIGUSR1, &child_actions[SIGUSR1], NULL);
        sigaction(SIGUSR2, &child_actions[SIGUSR2], NULL);
        sigaction(SIGPIPE, &child_actions[SIGPIPE], NULL);
    }
    else if (!child && !child_actions_init) {
        sa.sa_flags = 0;
        sigemptyset(&sa.sa_mask);
        sa.sa_handler = parachute_sig_handler;
        sigaction(SIGTERM, &sa, &child_actions[SIGTERM]);
        sigaction(SIGQUIT, &sa, &child_actions[SIGQUIT]);
        sigaction(SIGINT,  &sa, &child_actions[SIGINT]);
        sigaction(SIGABRT, &sa, &child_actions[SIGABRT]);
        sigaction(SIGHUP,  &sa, &child_actions[SIGHUP]);
        sigaction(SIGALRM, &sa, &child_actions[SIGALRM]);
        sigaction(SIGUSR1, &sa, &child_actions[SIGUSR1]);
        sigaction(SIGUSR2, &sa, &child_actions[SIGUSR2]);
        sa.sa_handler = SIG_IGN;
        sigaction(SIGPIPE, &sa, &child_actions[SIGPIPE]);
        sigaction(SIGTTOU, &sa, NULL);
        sigaction(SIGTTIN, &sa, NULL);
        sigaction(SIGTSTP, &sa, NULL);
        child_actions_init = 1;
        init_fatal_signals();
    }
    else
        panic(0, "Child process signal handlers not initialized before.");
}

parachute_sig_handler()

static void parachute_sig_handler ( int  signum )

static

Definition at line 175 of file utils.c.

References child_pid, info(), and parachute_shutdown.

Referenced by parachute_init_signals().

{
    info(0, "Signal %d received, forward to child pid (%ld)", signum, (long) child_pid);

    /* we do not handle any signal, just forward these to child process */
    if (child_pid != -1 && getpid() != child_pid)
        kill(child_pid, signum);

    /* if signal received and no child there, terminating */
    switch(signum) {
        case SIGTERM:
        case SIGINT:
        case SIGABRT:
            if (child_pid == -1)
                exit(0);
            else
                parachute_shutdown = 1;
    }
}

parachute_start()

static void parachute_start ( const char *  myname, const char *  panic_script  )

static

Definition at line 315 of file utils.c.

References child_pid, debug(), error(), gwlib_shutdown(), gwthread_sleep(), info(), is_executable(), panic, parachute_init_signals(), and parachute_shutdown.

Referenced by get_and_set_debugs().

                                                                          {
    time_t last_start = 0, last_panic = 0;
    long respawn_count = 0;
    int status;


    if (panic_script && !is_executable(panic_script))
        panic(0, "Panic script `%s' is not executable for us.", panic_script);

    /* setup sighandler */
    parachute_init_signals(0);

    for (;;) {
        if (respawn_count > 0 && difftime(time(NULL), last_start) < 10) {
            error(0, "Child process died too fast, disabling for 30 sec.");
            gwthread_sleep(30.0);
        }
        if (!(child_pid = fork())) { /* child process */
            parachute_init_signals(1); /* reset sighandlers */
        return;
        }
    else if (child_pid < 0) {
        error(errno, "Could not start child process! Will retry in 5 sec.");
        gwthread_sleep(5.0);
            continue;
    }
    else { /* father process */
        time(&last_start);
            info(0, "Child process with PID (%ld) started.", (long) child_pid);
            do {
                if (waitpid(child_pid, &status, 0) == child_pid) {
                    /* check here why child terminated */
                   if (WIFEXITED(status) && WEXITSTATUS(status) == 0) {
                       info(0, "Child process exited gracefully, exit...");
                       gwlib_shutdown();
                       exit(0);
                   }
                   else if (WIFEXITED(status)) {
                       error(0, "Caught child PID (%ld) which died with return code %d",
                           (long) child_pid, WEXITSTATUS(status));
                       child_pid = -1;
                   }
                   else if (WIFSIGNALED(status)) {
                       error(0, "Caught child PID (%ld) which died due to signal %d",
                           (long) child_pid, WTERMSIG(status));
                       child_pid = -1;
                   }
                }
                else if (errno != EINTR) {
                    error(errno, "Error while waiting of child process.");
                }
            } while(child_pid > 0);

            if (parachute_shutdown) {
                /* may only happens if child process crashed while shutdown */
                info(0, "Child process crashed while shutdown. Exiting due to signal...");
                info(0, "Going into gwlib_shutdown...");
                gwlib_shutdown();
                exit(WIFEXITED(status) ? WEXITSTATUS(status) : 0);
            }

            /* check whether it's panic while start */
            if (respawn_count == 0 && difftime(time(NULL), last_start) < 2) {
                info(0, "Child process crashed while starting. Exiting...");
                info(0, "Going into gwlib_shutdown...");
                gwlib_shutdown();
                exit(WIFEXITED(status) ? WEXITSTATUS(status) : 1);
            }

            respawn_count++;
            if (panic_script && myname && difftime(time(NULL), last_panic) > 300) {
                time(&last_panic);
                debug("kannel", 0, "Executing panic script: %s %s %ld", panic_script, myname, respawn_count);
                execute_panic_script(panic_script, "%s %ld", myname, respawn_count);
            }
            /* sleep a while to get e.g. sockets released */
            gwthread_sleep(5.0);
    }
    }
}

pattern_list_matches_ip()

static int pattern_list_matches_ip ( Octstr *  pattern_list, Octstr *  ip  )

static

Definition at line 796 of file utils.c.

References gwlist_destroy(), gwlist_extract_first(), octstr_destroy(), octstr_destroy_item(), octstr_imm(), octstr_split(), and pattern_matches_ip().

Referenced by connect_denied(), and is_allowed_ip().

{
    List *patterns;
    Octstr *pattern;
    int matches;

    patterns = octstr_split(pattern_list, octstr_imm(";"));
    matches = 0;

    while (!matches && (pattern = gwlist_extract_first(patterns)) != NULL) {
    matches = pattern_matches_ip(pattern, ip);
    octstr_destroy(pattern);
    }
    
    gwlist_destroy(patterns, octstr_destroy_item);
    return matches;
}

pattern_matches_ip()

static int pattern_matches_ip ( Octstr *  pattern, Octstr *  ip  )

static

Definition at line 759 of file utils.c.

References octstr_get_char(), and octstr_len().

Referenced by pattern_list_matches_ip().

{
    long i, j;
    long pat_len, ip_len;
    int pat_c, ip_c;
    
    pat_len = octstr_len(pattern);
    ip_len = octstr_len(ip);

    i = 0;
    j = 0;
    while (i < pat_len && j < ip_len) {
    pat_c = octstr_get_char(pattern, i);
    ip_c = octstr_get_char(ip, j);
    if (pat_c == ip_c) {
        /* The characters match, go to the next ones. */
        ++i;
        ++j;
    } else if (pat_c != '*') {
        /* They differ, and the pattern isn't a wildcard one. */
        return 0;
    } else {
        /* We found a wildcard in the pattern. Skip in ip. */
        ++i;
        while (j < ip_len && ip_c != '.') {
        ++j;
        ip_c = octstr_get_char(ip, j);
        }
    }
    }
    
    if (i >= pat_len && j >= ip_len)
        return 1;
    return 0;
}

PRINTFLIKE()

static PRINTFLIKE ( 2  , 3    )

static

Definition at line 290 of file utils.c.

References PANIC_SCRIPT_MAX_LEN.

{
    char *args[3];
    char buf[PANIC_SCRIPT_MAX_LEN + 1];
    va_list ap;

    va_start(ap, format);
    vsnprintf(buf, PANIC_SCRIPT_MAX_LEN, format, ap);
    va_end(ap);

    if (fork())
       return;

    close(STDIN_FILENO);
    close(STDOUT_FILENO);
    close(STDERR_FILENO);

    args[0] = (char*) panic_script;
    args[1] = buf;
    args[2] = NULL;

    execv(args[0], args);
}

remove_pid_file()

static void remove_pid_file ( void  )

static

Definition at line 417 of file utils.c.

References error(), gwlib_init(), gwlib_initialized(), gwlib_shutdown(), log_set_syslog(), pid_file, and pidfile_owner_pid.

Referenced by get_and_set_debugs().

{
    if (!pid_file)
        return;

    /* ensure that only pidfile owner can remove it */
    if (pidfile_owner_pid != getpid())
        return;

    if (-1 == unlink(pid_file)) {
        int initdone = gwlib_initialized();
        /* we are called at exit so gwlib may be shutdown already, init again */
        if (!initdone) {
            gwlib_init();
            log_set_syslog("kannel", 0);
        }
        error(errno, "Could not unlink pid-file `%s'", pid_file);
        if (!initdone)
            gwlib_shutdown();
    }
}

report_versions()

void report_versions

(

const char *

boxname

)

Definition at line 539 of file utils.c.

References debug(), octstr_destroy(), octstr_get_cstr, and version_report_string().

Referenced by main().

{
    Octstr *os;
    
    os = version_report_string(boxname);
    debug("gwlib.gwlib", 0, "%s", octstr_get_cstr(os));
    octstr_destroy(os);
}

reverse_octet()

Octet reverse_octet

(

Octet

source

)

Definition at line 511 of file utils.c.

Referenced by OTAbitmap_create(), and wbmp_create().

{
    Octet   dest;
    dest = (source & 1) <<7;
    dest += (source & 2) <<5;
    dest += (source & 4) <<3;
    dest += (source & 8) <<1;
    dest += (source & 16) >>1;
    dest += (source & 32) >>3;
    dest += (source & 64) >>5;
    dest += (source & 128) >>7;
    
    return dest;
}

roundup_div()

int roundup_div	(	int	a,
		int	b
	)

Definition at line 1001 of file utils.c.

{
    int t;

    t = a / b;
    if (t * b != a)
        t += 1;

    return t;
}

version_report_string()

Octstr* version_report_string

(

const char *

boxname

)

Definition at line 549 of file utils.c.

References get_official_ip(), get_official_name(), octstr_format(), and octstr_get_cstr.

Referenced by bb_print_status(), get_and_set_debugs(), and report_versions().

{
    struct utsname u;

    uname(&u);
    return octstr_format(GW_NAME " %s version `%s'.\nBuild `%s', compiler `%s'.\n"
                         "System %s, release %s, version %s, machine %s.\n"
             "Hostname %s, IP %s.\n"
             "Libxml version %s.\n"
#ifdef HAVE_LIBSSL
             "Using "
#ifdef HAVE_WTLS_OPENSSL
             "WTLS library "
#endif
             "%s.\n"
#endif
#ifdef HAVE_MYSQL
             "Compiled with MySQL %s, using MySQL %s.\n"
#endif
#ifdef HAVE_PGSQL
             "Compiled with PostgreSQL %s.\n"
#endif
#ifdef HAVE_SDB
             "Using LibSDB %s.\n"
#endif
#if defined(HAVE_SQLITE) || defined(HAVE_SQLITE3)
             "Using SQLite %s.\n"
#endif
#ifdef HAVE_ORACLE
#if defined(OCI_MAJOR_VERSION) && defined(OCI_MINOR_VERSION)
             "Using Oracle OCI %d.%d.\n"
#else
             "Using Oracle OCI.\n"
#endif
#endif
#ifdef HAVE_REDIS
             "Using hiredis API %d.%d.%d\n"
#endif
             "Using %s malloc.\n",
             boxname, GW_VERSION,
#ifdef __GNUC__ 
             (__DATE__ " " __TIME__) ,
             __VERSION__,
#else 
             "unknown" , "unknown",
#endif 
             u.sysname, u.release, u.version, u.machine,
             octstr_get_cstr(get_official_name()),
             octstr_get_cstr(get_official_ip()),
             LIBXML_DOTTED_VERSION,
#ifdef HAVE_LIBSSL
             OPENSSL_VERSION_TEXT,
#endif
#ifdef HAVE_MYSQL
             MYSQL_SERVER_VERSION, mysql_get_client_info(),
#endif
#ifdef HAVE_PGSQL
             PG_VERSION,
#endif
#ifdef HAVE_SDB
             LIBSDB_VERSION,
#endif
#if defined(HAVE_SQLITE) || defined(HAVE_SQLITE3)
             SQLITE_VERSION,
#endif
#ifdef HAVE_ORACLE
#if defined(OCI_MAJOR_VERSION) && defined(OCI_MINOR_VERSION)
             OCI_MAJOR_VERSION, OCI_MINOR_VERSION,
#endif
#endif
#ifdef HAVE_REDIS
             HIREDIS_MAJOR, HIREDIS_MINOR, HIREDIS_PATCH,
#endif
             octstr_get_cstr(gwmem_type()));
}

write_pid_file()

static void write_pid_file ( void  )

static

Definition at line 397 of file utils.c.

References file, panic, pid_file, and pidfile_owner_pid.

Referenced by get_and_set_debugs().

{
    int fd;
    FILE *file;

    if (!pid_file)
        return;

    fd = open(pid_file, O_WRONLY|O_NOCTTY|O_TRUNC|O_CREAT|O_EXCL, 0644);
    if (fd == -1)
        panic(errno, "Could not open pid-file `%s'", pid_file);

    file = fdopen(fd, "w");
    if (!file)
        panic(errno, "Could not open file-stream `%s'", pid_file);

    fprintf(file, "%ld\n", (long) (pidfile_owner_pid = getpid()));
    fclose(file);
}

write_variable_value()

int write_variable_value	(	MultibyteInt	value,
		Octet *	dest
	)

Definition at line 490 of file utils.c.

Referenced by sema_encode_msg(), sema_submit_result(), and wbmp_create_stream().

{
    int i, loc = 0;
    Octet revbuffer[20];    /* we write it backwards */
    
    for (;;) {
    revbuffer[loc++] = (value & 0x7F) + 0x80;   
    if (value >= 0x80)
        value = value >> 7;
    else
        break;
    }
    for(i=0; i < loc; i++)      /* reverse the buffer */
    dest[i] = revbuffer[loc-i-1];
    
    dest[loc-1] &= 0x7F;    /* remove trailer-bit from last */

    return loc;
}

Variable Documentation

child_actions

struct sigaction child_actions[32]

static

Definition at line 138 of file utils.c.

Referenced by parachute_init_signals().

child_actions_init

int child_actions_init = 0

static

Definition at line 140 of file utils.c.

Referenced by parachute_init_signals().

child_pid

pid_t child_pid = -1

static

Definition at line 134 of file utils.c.

Referenced by parachute_sig_handler(), and parachute_start().

parachute_shutdown

volatile sig_atomic_t parachute_shutdown = 0

static

Definition at line 143 of file utils.c.

Referenced by parachute_sig_handler(), and parachute_start().

pid_file

char* pid_file = NULL

static

Definition at line 142 of file utils.c.

Referenced by get_and_set_debugs(), remove_pid_file(), and write_pid_file().

pidfile_owner_pid

pid_t pidfile_owner_pid = -1

static

Definition at line 136 of file utils.c.

Referenced by remove_pid_file(), and write_pid_file().