fakesmsc.c File Reference

#include <errno.h>
#include <math.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <sys/time.h>
#include <limits.h>
#include <signal.h>
#include <sys/param.h>
#include "gwlib/gwlib.h"

Go to the source code of this file.

Macros
#define	IN_BUFSIZE   256 /* Buffer size for stdin */
#define	IN_TIMEOUT   1 /* Timeout for stdin */

Functions
static void	signal_handler (int signum)
static void	setup_signal_handlers (void)
static Octstr *	choose_message (Octstr **msgs, int num_msgs)
static double	get_current_time (void)
static int	check_args (int i, int argc, char **argv)
static Octstr *	randomize (Octstr *os)
int	main (int argc, char **argv)

Variables
static char	usage []
static int	port = 10000
static Octstr *	host
static long	max_send = LONG_MAX
static double	interval = 1.0
static int	sigint_received
static int	rnd = 0

Macro Definition Documentation

IN_BUFSIZE

#define IN_BUFSIZE   256 /* Buffer size for stdin */

Definition at line 117 of file fakesmsc.c.

Referenced by main().

IN_TIMEOUT

#define IN_TIMEOUT   1 /* Timeout for stdin */

Definition at line 118 of file fakesmsc.c.

Referenced by main().

Function Documentation

check_args()

static int check_args ( int  i, int  argc, char **  argv  )

static

Definition at line 167 of file fakesmsc.c.

References host, interval, max_send, octstr_create, panic, rnd, and usage.

Referenced by main().

{
    if (strcmp(argv[i], "-r")==0 || strcmp(argv[i], "--port")==0)
        port = atoi(argv[i+1]);
    else if (!strcmp(argv[i], "-H") || !strcmp(argv[i], "--host"))
        host = octstr_create(argv[i+1]);
    else if (strcmp(argv[i], "-m")==0 || strcmp(argv[i], "--messages")==0) {
        max_send = atoi(argv[i+1]);
        if (max_send < 0)
            max_send = LONG_MAX;
    }
    else if (strcmp(argv[i], "-i")==0 || strcmp(argv[i], "--interval")==0)
        interval = atof(argv[i+1]);
    else if (strcmp(argv[i], "-z")==0 || strcmp(argv[i], "--randomize")==0) {
        rnd = atoi(argv[i+1]);
        if (rnd < 0 || rnd > 7)
            rnd = 0;
    }
    else {
        panic(0, "%s", usage);
        return 0;
    }

    return 1;
}

choose_message()

static Octstr* choose_message ( Octstr **  msgs, int  num_msgs  )

static

Definition at line 149 of file fakesmsc.c.

References gw_rand().

Referenced by main().

{
    /* the following doesn't give an even distribution, but who cares */
    return msgs[gw_rand() % num_msgs];
}

get_current_time()

static double get_current_time ( void  )

static

Definition at line 157 of file fakesmsc.c.

Referenced by main().

{
    struct timezone tz;
    struct timeval now;

    gettimeofday(&now, &tz);
    return (double) now.tv_sec + now.tv_usec / 1e6;
}

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 223 of file fakesmsc.c.

References check_args(), choose_message(), conn_destroy(), conn_eof(), conn_error(), conn_open_tcp(), conn_read_line(), conn_wait(), conn_write(), debug(), end_time, get_and_set_debugs(), get_current_time(), gwlib_init(), host, IN_BUFSIZE, IN_TIMEOUT, info(), interval, max_send, msg, num_sent, octstr_append_char(), octstr_create, octstr_destroy(), octstr_get_cstr, panic, randomize(), rnd, server(), setup_signal_handlers(), sigint_received, and start_time.

{
    Connection *server;
    Octstr *line;
    Octstr **msgs;
    int i;
    int mptr, num_msgs;
    long num_received, num_sent;
    double first_received_at, last_received_at;
    double first_sent_at, last_sent_at;
    double start_time, end_time;
    double delta;
    int interactive, maxfd;
    char *cptr;
    char buffer[IN_BUFSIZE];
    fd_set rset;
    struct timeval alarm;
    FILE *fp;

    gwlib_init();
    setup_signal_handlers();
    host = octstr_create("localhost");
    start_time = get_current_time();

    mptr = get_and_set_debugs(argc, argv, check_args);
    num_msgs = argc - mptr;
        
    interactive = 0;
    msgs = NULL;
    fp = NULL;
    if (num_msgs <= 0) {
        interactive = 1;
        num_msgs = 0;
        info(0, "Entering interactive mode. Type your message on the command line");
        /* set up file pointer to stdin */
        fp = stdin;
        /* initialize set for select */
        FD_ZERO(&rset); 
    } else {
        msgs = gw_malloc(sizeof(Octstr *) * num_msgs);
        for (i = 0; i < num_msgs; i ++) {
            msgs[i] = octstr_create(argv[mptr + i]);
            octstr_append_char(msgs[i], 10); /* End of line */
        }
        info(0, "Host %s Port %d interval %.3f max-messages %ld",
             octstr_get_cstr(host), port, interval, max_send);

        srand((unsigned int) time(NULL));
    }
    info(0, "fakesmsc starting");
    server = conn_open_tcp(host, port, NULL);
    if (server == NULL)
       panic(0, "Failed to open connection");

    num_sent = 0;
    num_received = 0;

    first_received_at = 0;
    first_sent_at = 0;
    last_received_at = 0;
    last_sent_at = 0;

    /* infinitely loop */
    while (1) {
        /* Are we on interactive mode? */ 
        if (interactive == 1) {
            /* Check if we need to clean things up beforehand */
            if ( num_msgs > 0 ) {
                for (i = 0; i < num_msgs; i ++)
                    octstr_destroy(msgs[i]);
                gw_free(msgs);
                num_msgs = 0;
            }

            /* we want either the file pointer or timer */
            FD_SET(fileno(fp), &rset);
            /* get the largest file descriptor */
            maxfd = fileno(fp) + 1;
        
            /* set timer to go off in 3 seconds */
            alarm.tv_sec = IN_TIMEOUT;
            alarm.tv_usec = 0;
        
            if (select(maxfd, &rset, NULL, NULL, &alarm) == -1)
                goto over;
            /* something went off, let's see if it's stdin */
            if (FD_ISSET(fileno(fp), &rset)) { /* stdin is readable */
                cptr = fgets(buffer, IN_BUFSIZE, stdin);
                if (!cptr)
                    goto over;
                if( strlen( cptr ) < 2 )
                    goto rcv;
            } else { /* timer kicked in */
                goto rcv;
            }
            num_msgs = 1;
            msgs = gw_malloc(sizeof(Octstr*));
            msgs[0] = octstr_create(cptr);
        }
        /* if we still have something to send as MO message */
        if (num_sent < max_send) {
            Octstr *os = choose_message(msgs, num_msgs);
            Octstr *msg = rnd > 0 ? randomize(os) : os;
 
            if (conn_write(server, msg) == -1)
                panic(0, "write failed");

            ++num_sent;
            if (num_sent == max_send)
                info(0, "fakesmsc: sent message %ld", num_sent);
            else
                debug("send", 0, "fakesmsc: sent message %ld", num_sent);
      
            if (rnd > 0)
                octstr_destroy(msg);

            last_sent_at = get_current_time();
            if (first_sent_at == 0)    
                first_sent_at = last_sent_at;
        }
rcv:
        do {
            delta = interval * num_sent - (get_current_time() - first_sent_at);
            if (delta < 0)
                delta = 0;
            if (num_sent >= max_send)
                delta = -1;
            conn_wait(server, delta);
            if (conn_error(server) || conn_eof(server) || sigint_received)
                goto over;

            /* read as much as the smsc module provides us */
            while ((line = conn_read_line(server))) {
                last_received_at = get_current_time();
                if (first_received_at == 0)
                    first_received_at = last_received_at;
                ++num_received;
                if (num_received == max_send) {
                    info(0, "Got message %ld: <%s>", num_received,
                           octstr_get_cstr(line));
                } else {
                    debug("receive", 0, "Got message %ld: <%s>", num_received,
                          octstr_get_cstr(line));
                }
                octstr_destroy(line);
            }
        } while (delta > 0 || num_sent >= max_send);
    }

over:
    conn_destroy(server);

    /* destroy the MO messages */
    for (i = 0; i < num_msgs; i ++)
        octstr_destroy(msgs[i]);
    gw_free(msgs);

    end_time = get_current_time();

    info(0, "fakesmsc: %ld messages sent and %ld received", num_sent, num_received);
    info(0, "fakesmsc: total running time %.1f seconds", end_time - start_time);
    delta = last_sent_at - first_sent_at;
    if (delta == 0)
        delta = .01;
    if (num_sent > 1)
        info(0, "fakesmsc: from first to last sent message %.1f s, "
                "%.1f msgs/s", delta, (num_sent - 1) / delta);
    delta = last_received_at - first_received_at;
    if (delta == 0)
        delta = .01;
    if (num_received > 1)
        info(0, "fakesmsc: from first to last received message %.1f s, "
                "%.1f msgs/s", delta, (num_received - 1) / delta);
    info(0, "fakesmsc: terminating");
    
    return 0;
}

randomize()

static Octstr* randomize ( Octstr *  os )

static

Definition at line 194 of file fakesmsc.c.

References gw_rand(), gwlist_destroy(), gwlist_get(), gwlist_len(), msg, octstr_append_char(), octstr_create, octstr_destroy_item(), octstr_format_append(), octstr_split_words(), and rnd.

Referenced by main().

{
    Octstr *msg = octstr_create("");
    List *words = octstr_split_words(os);
    int i;

    /* randomize source and receiver number */
    octstr_format_append(msg, "%S", gwlist_get(words, 0));
    if (rnd & 0x1) 
        octstr_format_append(msg, "%d", gw_rand());

    octstr_format_append(msg, " %S", gwlist_get(words, 1));
    if (rnd & 0x2) 
        octstr_format_append(msg, "%d", gw_rand());

    for (i = 2; i < gwlist_len(words); i++) 
        octstr_format_append(msg, " %S", gwlist_get(words, i));

    if (rnd & 0x4)
        octstr_format_append(msg, " %d", gw_rand());

    octstr_append_char(msg, 10); /* End of line */

    gwlist_destroy(words, octstr_destroy_item);

    return msg;
}

setup_signal_handlers()

static void setup_signal_handlers ( void  )

static

Definition at line 137 of file fakesmsc.c.

References signal_handler().

Referenced by main().

{
    struct sigaction act;

    act.sa_handler = signal_handler;
    sigemptyset(&act.sa_mask);
    act.sa_flags = 0;
    sigaction(SIGINT, &act, NULL);
}

signal_handler()

static void signal_handler ( int  signum )

static

Definition at line 128 of file fakesmsc.c.

References panic, and sigint_received.

Referenced by setup_signal_handlers().

{
    if (signum == SIGINT)
        sigint_received = 1;
    else
        panic(0, "Caught signal with no handler?!");
}

Variable Documentation

host

Octstr* host

static

Definition at line 122 of file fakesmsc.c.

Referenced by build_request(), check_args(), conn_open_tcp(), conn_open_tcp_nb(), conn_open_tcp_nb_with_port(), conn_open_tcp_with_port(), conn_pool_get(), conn_pool_key(), connect_to_bearerbox(), connect_to_bearerbox_real(), get_connection(), main(), proxy_used_for_host(), smpp_create(), smsc_cgw_create(), smsc_emi2_create(), smsc_open(), and smsc_smpp_create().

interval

double interval = 1.0

static

Definition at line 124 of file fakesmsc.c.

Referenced by check_args(), and main().

max_send

long max_send = LONG_MAX

static

Definition at line 123 of file fakesmsc.c.

Referenced by check_args(), and main().

port

int port = 10000

static

Definition at line 121 of file fakesmsc.c.

Referenced by accept_thread(), cimd_open(), client_create(), find_client(), get_connection(), handle_internal_event(), http_close_port(), http_open_port_if(), http_thread(), http_use_proxy(), main(), ois_open(), pack_server_address(), smppboxc_run(), smsc_open(), smsc_smpp_create(), sqlboxc_run(), start_http_thread(), update_session_data(), wap_addr_create(), and wapboxc_run().

rnd

int rnd = 0

static

Definition at line 126 of file fakesmsc.c.

Referenced by check_args(), main(), and randomize().

sigint_received

int sigint_received

static

Definition at line 125 of file fakesmsc.c.

Referenced by main(), and signal_handler().

usage

char usage[]

static

Initial value:

= "\n\
Usage: fakesmsc [-H host] [-r port] [-i interval] [-m max] [-z <type>] <msg> ... \n\
\n\
* 'host' and 'port' define bearerbox connection (default localhost:10000),\n\
* 'interval' is time in seconds (floats allowed) between generated messages,\n\
* 'max' is the total number sent (-1, default, means unlimited),\n\
* <type> bitmask of which elements to add randomized numbers for MO messages,\n\
*        1: src no, 2: recv no, 4: last text element,\n\
*        where the given static elements in <msg> are used as constant prefixes,\n\
* <msg> is message to send, if several are given, they are sent randomly.\n\
\n\
msg format: \"sender receiver type(text|data|ucs2|udh-data|udh-text|route|dlr-mask) [udhdata|route|dlrmask] msgdata\"\n\
\n\
Type \"text\" means plaintext msgdata, \"data\" url-encoded, \"udh\" url-encoded udh+msg,\n\
\"utf8\" utf-8 url-encoded msgdata, \"ucs2\" unicode url-encoded msgdata \n\
and \"route\" means smsbox-id routed plaintext msgdata\n\
Examples: \n\
\n\
fakesmsc -m 1 \"123 345 udh %04udh%3f message+data+here\"\n\
fakesmsc -m 1 \"123 345 route smsbox1 message+data+here\"\n\
fakesmsc -i 0.01 -m 1000 \"123 345 text nop\" \"1 2 text another message here\"\n\
fakesmsc -z 7 -m 1000 \"123<rand> 345<rand> text nop <rand>\"\n\
\n\
Server replies are shown in the same message format.\n"

Definition at line 77 of file fakesmsc.c.

Referenced by check_args().