drive_wapbox.c File Reference

#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <signal.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include "gwlib/gwlib.h"
#include "gw/msg.h"

Go to the source code of this file.

Data Structures
struct	client_status

Macros
#define	WSP_VERSION   0x10
#define	TIMEOUT   10.0 /* seconds */

Typedefs
typedef struct client_status	Client

Enumerations
enum	wsp_types {   Bad_PDU = -1, Connect_PDU = 0x01, ConnectReply_PDU = 0x02, Redirect_PDU = 0x03,   Reply_PDU = 0x04, Disconnect_PDU = 0x05, Push_PDU = 0x06, ConfirmedPush_PDU = 0x07,   Suspend_PDU = 0x08, Resume_PDU = 0x09, Get_PDU = 0x40, Options_PDU = 0x41,   Head_PDU = 0x42, Delete_PDU = 0x43, Trace_PDU = 0x44, Post_PDU = 0x60,   Put_PDU = 0x61 }
enum	wtp_types { INVOKE = 1, RESULT = 2, ACK = 3 }
enum	WTP_type { TR_Invoke = 1, TR_Result = 2, TR_Ack = 3, TR_Abort = 4 }

Functions
static unsigned long	get_varint (Octstr *pdu, int pos)
static void	http_thread (void *arg)
static int	start_http_thread (void)
static Connection *	start_wapbox (void)
static void	initialize_clients (void)
static void	destroy_clients (void)
static Client *	find_client (unsigned short port)
static void	client_done (Client *client)
static void	increment_tid (Client *client)
static void	set_user_ack (Octstr *pdu)
static Octstr *	wtp_invoke_create (int class)
static Octstr *	wtp_ack_create (void)
static void	add_wsp_connect (Octstr *pdu)
static void	add_wsp_get (Octstr *pdu)
static void	add_wsp_disconnect (Octstr *pdu, long session_id)
static void	set_tid (Octstr *pdu, int tid)
static int	get_tid (Octstr *pdu)
static int	wtp_type (Octstr *pdu)
static Msg *	wdp_create (Octstr *data, Client *client)
static void	send_pdu (Octstr *pdu, Connection *boxc, Client *client)
static void	send_invoke_connect (Connection *boxc, Client *client)
static void	send_invoke_get (Connection *boxc, Client *client)
static void	record_disconnect (Client *client)
static void	send_invoke_disconnect (Connection *boxc, Client *client)
static void	handle_connect_reply (Connection *boxc, Client *client, Octstr *pdu)
static void	handle_get_reply (Connection *boxc, Client *client, Octstr *pdu)
static void	handle_reply (Connection *boxc, Msg *reply)
static void	start_request (Connection *boxc, Client *client)
static long	run_requests (Connection *boxc)
static void	help (void)
int	main (int argc, char **argv)

Variables
static long	max_requests = 1
static long	max_clients = 1
static long	req_per_session = 1
static unsigned short	http_port
static int	wapbox_port = 30188
static Octstr *	http_url = NULL
static int	verbose_debug = 0
static int	user_ack = 0
static long	requests_complete = 0
static volatile sig_atomic_t	dying = 0
static Client *	clients
List *	ready_clients
static long	http_thread_id

Macro Definition Documentation

TIMEOUT

#define TIMEOUT   10.0 /* seconds */

Definition at line 108 of file drive_wapbox.c.

Referenced by main(), and run_requests().

WSP_VERSION

#define WSP_VERSION   0x10

Definition at line 106 of file drive_wapbox.c.

Referenced by add_wsp_connect().

Typedef Documentation

Client

typedef struct client_status Client

Definition at line 150 of file drive_wapbox.c.

Enumeration Type Documentation

wsp_types

enum wsp_types

Enumerator
Bad_PDU
Connect_PDU
ConnectReply_PDU
Redirect_PDU
Reply_PDU
Disconnect_PDU
Push_PDU
ConfirmedPush_PDU
Suspend_PDU
Resume_PDU
Get_PDU
Options_PDU
Head_PDU
Delete_PDU
Trace_PDU
Post_PDU
Put_PDU

Definition at line 80 of file drive_wapbox.c.

               {
        Bad_PDU = -1,
        Connect_PDU = 0x01,
        ConnectReply_PDU = 0x02,
        Redirect_PDU = 0x03,
        Reply_PDU = 0x04,
        Disconnect_PDU = 0x05,
        Push_PDU = 0x06,
        ConfirmedPush_PDU = 0x07,
        Suspend_PDU = 0x08,
        Resume_PDU = 0x09,
        Get_PDU = 0x40,
        Options_PDU = 0x41,
        Head_PDU = 0x42,
        Delete_PDU = 0x43,
        Trace_PDU = 0x44,
        Post_PDU = 0x60,
        Put_PDU = 0x61
};

WTP_type

enum WTP_type

Enumerator
TR_Invoke
TR_Result
TR_Ack
TR_Abort

Definition at line 123 of file drive_wapbox.c.

              {
    TR_Invoke = 1,
    TR_Result = 2,
    TR_Ack = 3,
    TR_Abort = 4
};

wtp_types

enum wtp_types

Enumerator
INVOKE
RESULT
ACK

Definition at line 100 of file drive_wapbox.c.

               {
    INVOKE = 1,
    RESULT = 2,
    ACK = 3
};

Function Documentation

add_wsp_connect()

static void add_wsp_connect ( Octstr *  pdu )

static

Definition at line 316 of file drive_wapbox.c.

References Connect_PDU, octstr_append_data(), and WSP_VERSION.

Referenced by send_invoke_connect().

                                         {
    static unsigned char data[] = { Connect_PDU, WSP_VERSION, 68, 0x00,
    0x03, 0x80, 0x90, 0x00, 0x03, 0x81, 0x90, 0x00,
    0x02, 0x82, 0x30, 0x02, 0x83, 0x01, 0x02, 0x84,
    0x01, 0x28, 0x85, 0x50, 0x58, 0x2d, 0x55, 0x50,
    0x2d, 0x41, 0x47, 0x45, 0x54, 0x00, 0x51, 0x58,
    0x2d, 0x55, 0x50, 0x2d, 0x47, 0x45, 0x54, 0x4e,
    0x4f, 0x54, 0x49, 0x46, 0x59, 0x00, 0x70, 0x58,
    0x2d, 0x55, 0x50, 0x2d, 0x41, 0x50, 0x4f, 0x53,
    0x54, 0x00, 0x09, 0x86, 0x02, 0x78, 0x2d, 0x75,
    0x70, 0x2d, 0x31, 0x00 };
    octstr_append_data(pdu, data, sizeof(data));
}

add_wsp_disconnect()

static void add_wsp_disconnect ( Octstr *  pdu, long  session_id  )

static

Definition at line 346 of file drive_wapbox.c.

References Disconnect_PDU, octstr_append_char(), and octstr_append_uintvar().

Referenced by send_invoke_disconnect().

                                                             {
    octstr_append_char(pdu, Disconnect_PDU);
    octstr_append_uintvar(pdu, session_id);
}

add_wsp_get()

static void add_wsp_get ( Octstr *  pdu )

static

Definition at line 330 of file drive_wapbox.c.

References Get_PDU, http_port, http_url, octstr_append(), octstr_append_char(), octstr_append_uintvar(), octstr_destroy(), octstr_format(), and octstr_len().

Referenced by send_invoke_get().

                                     {
        Octstr *urlbuf;

    octstr_append_char(pdu, Get_PDU);
    if (http_url) {
        octstr_append_uintvar(pdu, octstr_len(http_url));
        octstr_append(pdu, http_url);
    } else {
        urlbuf = octstr_format("http://localhost:%ld/hello.wml",
                       (long) http_port);
        octstr_append_uintvar(pdu, octstr_len(urlbuf));
        octstr_append(pdu, urlbuf);
        octstr_destroy(urlbuf);
    }
}

client_done()

static void client_done ( Client *  client )

static

Definition at line 278 of file drive_wapbox.c.

References client(), gwlist_append(), ready_clients, and requests_complete.

Referenced by handle_get_reply(), handle_reply(), and send_invoke_disconnect().

                                        {
    requests_complete++;
    gwlist_append(ready_clients, client);
}

destroy_clients()

static void destroy_clients ( void  )

static

Definition at line 265 of file drive_wapbox.c.

References clients, gwlist_destroy(), and ready_clients.

Referenced by main().

                                  {
    gw_free(clients);
    gwlist_destroy(ready_clients, NULL);
}

find_client()

static Client* find_client ( unsigned short  port )

static

Definition at line 270 of file drive_wapbox.c.

References clients, max_clients, and port.

Referenced by handle_reply().

                                                {
    /* It's easy and fast since we assign ports in linear order */
    if (port >= max_clients)
        return NULL;

    return clients + port;
}

get_tid()

static int get_tid ( Octstr *  pdu )

static

Definition at line 363 of file drive_wapbox.c.

References octstr_get_bits().

Referenced by handle_reply().

                                {
    return octstr_get_bits(pdu, 8, 16);
}

get_varint()

static unsigned long get_varint ( Octstr *  pdu, int  pos  )

static

Definition at line 155 of file drive_wapbox.c.

References octstr_get_char().

Referenced by handle_connect_reply().

                                                      {
    int c;
    long result = 0;

    do {
        c = octstr_get_char(pdu, pos++);
        result = (result << 7) | (c & 0x7f);
    } while (c & 0x80);

    return c;
}

handle_connect_reply()

static void handle_connect_reply ( Connection *  boxc, Client *  client, Octstr *  pdu  )

static

Definition at line 461 of file drive_wapbox.c.

References client(), ConnectReply_PDU, error(), get_varint(), gw_assert(), increment_tid(), octstr_destroy(), octstr_dump, octstr_get_char(), send_invoke_get(), send_pdu(), set_tid(), and wtp_ack_create().

Referenced by handle_reply().

                                                                                {
    Octstr *ack;

    gw_assert(client);
    gw_assert(client->wtp_invoked);
    gw_assert(!client->wsp_connected);

    if (octstr_get_char(pdu, 3) != ConnectReply_PDU) {
        error(0, "Unexpected CONNECT reply");
        octstr_dump(pdu, 0);
        return;
    }

    ack = wtp_ack_create();
    set_tid(ack, client->wtp_tid);
    send_pdu(ack, boxc, client);
    octstr_destroy(ack);

    client->wtp_invoked = 0;
    increment_tid(client);
    client->wsp_connected = 1;
    client->wsp_session_id = get_varint(pdu, 4);

    send_invoke_get(boxc, client);
}

handle_get_reply()

static void handle_get_reply ( Connection *  boxc, Client *  client, Octstr *  pdu  )

static

Definition at line 487 of file drive_wapbox.c.

References client(), client_done(), error(), gw_assert(), increment_tid(), octstr_destroy(), octstr_dump, octstr_get_char(), Reply_PDU, req_per_session, send_invoke_disconnect(), send_pdu(), set_tid(), and wtp_ack_create().

Referenced by handle_reply().

                                                                            {
    Octstr *ack;

    gw_assert(client);
    gw_assert(client->wtp_invoked);
    gw_assert(client->wsp_connected);

    if (octstr_get_char(pdu, 3) != Reply_PDU) {
        error(0, "Unexpected GET reply");
        octstr_dump(pdu, 0);
        return;
    }

    ack = wtp_ack_create();
    set_tid(ack, client->wtp_tid);
    send_pdu(ack, boxc, client);
    octstr_destroy(ack);

    client->wtp_invoked = 0;
    increment_tid(client);
    client->pages_fetched++;

    if (client->pages_fetched == req_per_session) {
        send_invoke_disconnect(boxc, client);
    } else {
        client_done(client);
    }
}

handle_reply()

static void handle_reply ( Connection *  boxc, Msg *  reply  )

static

Definition at line 516 of file drive_wapbox.c.

References ACK, client(), client_done(), debug(), error(), find_client(), get_tid(), gw_assert(), handle_connect_reply(), handle_get_reply(), octstr_dump, panic, record_disconnect(), reply(), RESULT, type, verbose_debug, and wtp_type().

Referenced by run_requests().

                                                       {
    Client *client;
    Octstr *wtp;
    int type;
    int dumped = 0;

    gw_assert(reply != NULL);
    gw_assert(reply->type == wdp_datagram);

    client = find_client(reply->wdp_datagram.destination_port);
    if (client == NULL)
        panic(0, "got packet for nonexisting client %ld",
            (long) reply->wdp_datagram.destination_port);

    wtp = reply->wdp_datagram.user_data;
    type = wtp_type(wtp);

    if (verbose_debug) {
        debug("test", 0, "Received:");
        octstr_dump(wtp, 0);
        dumped = 1;
    }

    if (client->wtp_invoked == 0) {
        error(0, "Got packet for client that wasn't waiting");
        if (!dumped) {
            octstr_dump(wtp, 0);
            dumped = 1;
        }
        return;
    }

    /* Server should invert the MSB of the tid in its replies */
    if (get_tid(wtp) != (client->wtp_tid ^ 0x8000)) {
        error(0, "Got packet with wrong tid %d, expected %d.",
            get_tid(wtp), client->wtp_tid ^ 0x8000);
        if (!dumped) {
            octstr_dump(wtp, 0);
            dumped = 1;
        }
        return;
    }

    /* We're going to be stupid here, and assume that replies that
     * look vaguely like what we expect are actually what we wanted. */
    if (client->wsp_connected == 0 && type == RESULT) {
        handle_connect_reply(boxc, client, wtp);
    } else if (client->wsp_connected == 1 && type == RESULT) {
        handle_get_reply(boxc, client, wtp);
    } else if (client->wsp_connected == 2 && type == ACK) {
        record_disconnect(client);
        client_done(client);
    } else {
        error(0, "Got unexpected packet");
        if (!dumped) {
            octstr_dump(wtp, 0);
            dumped = 1;
        }
    }
}

help()

static void help ( void  )

static

Definition at line 633 of file drive_wapbox.c.

References info().

Referenced by main().

                       {
    info(0, "Usage: drive_wapbox [options...]\n");
    info(0, "  -r requests  Stop after this many; default 1.");
    info(0, "  -c clients   # of concurrent clients; default 1.");
    info(0, "  -w wapport   Port wapbox should connect to; default 30188");
    info(0, "  -u url       Use this url instead of internal http server");
    info(0, "  -g requests  Number of requests per WSP session; default 1");
    info(0, "  -U           Set the User ack flag on all WTP transactions");
}

http_thread()

static void http_thread ( void *  arg )

static

Definition at line 167 of file drive_wapbox.c.

References client(), dying, gwlist_append(), gwlist_create, http_accept_request(), http_destroy_cgiargs(), http_destroy_headers(), HTTP_OK, http_send_reply(), octstr_create, octstr_destroy(), port, and url.

Referenced by start_http_thread().

                                   {
    HTTPClient *client;
    Octstr *ip;
    Octstr *url;
    List *headers;
    Octstr *body;
    List *cgivars;
    Octstr *reply_body = octstr_create(
        "<?xml version=\"1.0\"?>\n"
        "<!DOCTYPE wml PUBLIC \"-//WAPFORUM//DTD WML 1.1//EN\"\n"
        " \"http://www.wapforum.org/DTD/wml_1.1.xml\">\n"
        "<wml>\n"
        "<card id=\"main\" title=\"Hello, world\" newcontext=\"true\">\n"
        "        <p>Hello, world.</p>\n"
        "</card></wml>\n");
    List *reply_headers = gwlist_create();
    int port;

        port = *(int *) arg;
    gw_free(arg);

    gwlist_append(reply_headers,
        octstr_create("Content-Type: text/vnd.wap.wml"));

    for (;!dying;) {
        client = http_accept_request(port, &ip, &url, &headers, 
                                     &body, &cgivars);
        if (client == NULL)
            break;
        http_send_reply(client, HTTP_OK, reply_headers, reply_body);
        http_destroy_headers(headers);
        octstr_destroy(ip);
        octstr_destroy(url);
        octstr_destroy(body);
        http_destroy_cgiargs(cgivars);
    }

    octstr_destroy(reply_body);
        http_destroy_headers(reply_headers);
}

increment_tid()

static void increment_tid ( Client *  client )

static

Definition at line 283 of file drive_wapbox.c.

References client().

Referenced by handle_connect_reply(), handle_get_reply(), and record_disconnect().

                                          {
    if (client->wtp_tid == 0x7fff) 
        client->wtp_tid = 0;
    else
        client->wtp_tid++;
}

initialize_clients()

static void initialize_clients ( void  )

static

Definition at line 248 of file drive_wapbox.c.

References clients, gwlist_append(), gwlist_create, max_clients, client_status::pages_fetched, client_status::port, ready_clients, client_status::wsp_connected, client_status::wsp_session_id, client_status::wtp_invoked, and client_status::wtp_tid.

Referenced by main().

                                     {
    long i;

    ready_clients = gwlist_create();

    clients = gw_malloc(max_clients * sizeof(*clients));
    for (i = 0; i < max_clients; i++) {
        clients[i].wtp_invoked = 0;
        clients[i].wtp_tid = 0;
        clients[i].wsp_connected = 0;
        clients[i].wsp_session_id = -1;
        clients[i].pages_fetched = 0;
        clients[i].port = i;
        gwlist_append(ready_clients, &clients[i]);
    }
}

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 643 of file drive_wapbox.c.

References conn_destroy(), destroy_clients(), dying, error(), getopt(), gwlib_init(), gwlib_shutdown(), gwthread_join(), help(), http_close_all_ports(), http_port, http_thread_id, http_url, info(), initialize_clients(), log_set_output_level(), max_clients, max_requests, octstr_create, octstr_destroy(), optarg, panic, req_per_session, run_requests(), start, start_http_thread(), start_wapbox(), TIMEOUT, user_ack, verbose_debug, and wapbox_port.

                                {
    int opt;
    struct timeval start, end;
    Connection *boxc;
    long completed;
    double run_time;

    gwlib_init();

    while ((opt = getopt(argc, argv, "hv:r:c:w:du:Ug:")) != EOF) {
        switch (opt) {
        case 'v':
            log_set_output_level(atoi(optarg));
            break;

        case 'r':
            max_requests = atol(optarg);
            break;

        case 'c':
            max_clients = atol(optarg);
            break;

        case 'w':
            wapbox_port = atoi(optarg);
            break;

        case 'u':
            http_url = octstr_create(optarg);
            break;

        case 'U':
            user_ack = 1;
            break;

        case 'h':
            help();
            exit(0);

        case 'd':
            verbose_debug = 1;
            break;

        case 'g':
            req_per_session = atoi(optarg);
            break;

        case '?':
        default:
            error(0, "Invalid option %c", opt);
            help();
            panic(0, "Stopping.");
        }
    }

    if (!http_url)
        http_port = start_http_thread();
    boxc = start_wapbox();

    initialize_clients();

    if (gettimeofday(&start, NULL) < 0)
        panic(errno, "gettimeofday failed");
    completed = run_requests(boxc);
    if (gettimeofday(&end, NULL) < 0)
        panic(errno, "gettimeofday failed");

    conn_destroy(boxc);

    run_time = end.tv_sec - start.tv_sec;
    run_time += (double) (end.tv_usec - start.tv_usec) / 1000000.0;

    /* We must have timed out.  Don't count the waiting time. */
    if (completed < max_requests)
        run_time -= TIMEOUT;

    info(0, "%ld request%s in %0.1f seconds, %0.1f requests/s.",
        completed, completed != 1 ? "s" : "",
        run_time, max_requests / run_time);

    dying = 1;
    http_close_all_ports();
    if (!http_url)
        gwthread_join(http_thread_id);

    destroy_clients();
    octstr_destroy(http_url);
    
    gwlib_shutdown();

    return 0;
}

record_disconnect()

static void record_disconnect ( Client *  client )

static

Definition at line 435 of file drive_wapbox.c.

References client(), and increment_tid().

Referenced by handle_reply(), and send_invoke_disconnect().

                                              {
    client->wsp_connected = 0;
    client->wsp_session_id = -1;
    client->pages_fetched = 0;
    increment_tid(client);
}

run_requests()

static long run_requests ( Connection *  boxc )

static

Definition at line 589 of file drive_wapbox.c.

References client(), conn_eof(), conn_read_withlen(), conn_wait(), gwlist_extract_first(), handle_reply(), info(), max_requests, msg, msg_destroy(), msg_unpack, octstr_destroy(), octstr_dump, panic, ready_clients, requests_complete, start_request(), and TIMEOUT.

Referenced by main().

                                           {
    int requests_sent;
    Octstr *data;
    Msg *msg;
    int ret;

    requests_sent = 0;
    requests_complete = 0;

    while (requests_complete < max_requests) {
        data = conn_read_withlen(boxc);
        if (!data) {
            Client *client;

            if (requests_sent < max_requests
                && (client = gwlist_extract_first(ready_clients))) {
                start_request(boxc, client);
                requests_sent++;
            }
            ret = conn_wait(boxc, TIMEOUT);
            if (ret < 0 || conn_eof(boxc))
                panic(0, "Wapbox dead.");
            if (ret == 1)
                break; /* Timed out. */
        } else {
            msg = msg_unpack(data);
            if (!msg) {
                octstr_dump(data, 0);
                panic(0, "Received bad data from wapbox.");
            }
            if (msg->type == wdp_datagram)
                handle_reply(boxc, msg);
            msg_destroy(msg);
        }
        octstr_destroy(data);
    }

    if (requests_complete < max_requests)
        info(0, "Timeout.  %ld requests unsatisfied.",
            max_requests - requests_complete);

    return requests_complete;
}

send_invoke_connect()

static void send_invoke_connect ( Connection *  boxc, Client *  client  )

static

Definition at line 401 of file drive_wapbox.c.

References add_wsp_connect(), client(), gw_assert(), octstr_destroy(), send_pdu(), set_tid(), and wtp_invoke_create().

Referenced by start_request().

                                                                  {
    Octstr *pdu;
    
    gw_assert(client != NULL);
    gw_assert(client->wtp_invoked == 0);
    gw_assert(client->wsp_connected == 0);

    pdu = wtp_invoke_create(2);
    set_tid(pdu, client->wtp_tid);
    add_wsp_connect(pdu);

    send_pdu(pdu, boxc, client);
    octstr_destroy(pdu);

    client->wtp_invoked = 1;
}

send_invoke_disconnect()

static void send_invoke_disconnect ( Connection *  boxc, Client *  client  )

static

Definition at line 442 of file drive_wapbox.c.

References add_wsp_disconnect(), client(), client_done(), gw_assert(), octstr_destroy(), record_disconnect(), send_pdu(), set_tid(), and wtp_invoke_create().

Referenced by handle_get_reply().

                                                                     {
    Octstr *pdu;

    gw_assert(client != NULL);
    gw_assert(client->wtp_invoked == 0);
    gw_assert(client->wsp_connected == 1);

    /* Kannel can't handle it as class 1 yet, so send class 0 */
    pdu = wtp_invoke_create(0);
    set_tid(pdu, client->wtp_tid);
    add_wsp_disconnect(pdu, client->wsp_session_id);

    send_pdu(pdu, boxc, client);
    octstr_destroy(pdu);

    record_disconnect(client);
    client_done(client);
}

send_invoke_get()

static void send_invoke_get ( Connection *  boxc, Client *  client  )

static

Definition at line 418 of file drive_wapbox.c.

References add_wsp_get(), client(), gw_assert(), octstr_destroy(), send_pdu(), set_tid(), and wtp_invoke_create().

Referenced by handle_connect_reply(), and start_request().

                                                              {
    Octstr *pdu;

    gw_assert(client != NULL);
    gw_assert(client->wtp_invoked == 0);
    gw_assert(client->wsp_connected == 1);

    pdu = wtp_invoke_create(2);
    set_tid(pdu, client->wtp_tid);
    add_wsp_get(pdu);

    send_pdu(pdu, boxc, client);
    octstr_destroy(pdu);

    client->wtp_invoked = 1;
}

send_pdu()

static void send_pdu ( Octstr *  pdu, Connection *  boxc, Client *  client  )

static

Definition at line 384 of file drive_wapbox.c.

References client(), conn_write_withlen(), debug(), msg, msg_destroy(), msg_pack(), octstr_destroy(), octstr_dump, verbose_debug, and wdp_create().

Referenced by handle_connect_reply(), handle_get_reply(), send_invoke_connect(), send_invoke_disconnect(), and send_invoke_get().

                                                                    {
    Msg *msg;
    Octstr *data;

    if (verbose_debug) {
        debug("test", 0, "Sending:");
        octstr_dump(pdu, 0);
    }

    msg = wdp_create(pdu, client);
    data = msg_pack(msg);
    conn_write_withlen(boxc, data);

    octstr_destroy(data);
    msg_destroy(msg);
}

set_tid()

static void set_tid ( Octstr *  pdu, int  tid  )

static

Definition at line 351 of file drive_wapbox.c.

References octstr_get_char(), and octstr_set_char().

Referenced by handle_connect_reply(), handle_get_reply(), send_invoke_connect(), send_invoke_disconnect(), and send_invoke_get().

                                          {
    int c;

    /* Tid wraps at 15 bits. */
    tid &= 0x7fff;

    c = octstr_get_char(pdu, 1);
    c = (tid >> 8) | (c & 0x80);
    octstr_set_char(pdu, 1, c);
    octstr_set_char(pdu, 2, tid & 0xff);
}

set_user_ack()

static void set_user_ack ( Octstr *  pdu )

static

Definition at line 291 of file drive_wapbox.c.

References octstr_set_bits().

Referenced by wtp_invoke_create().

                                      {
    octstr_set_bits(pdu, 3 * 8 + 3, 1, 1);
}

start_http_thread()

static int start_http_thread ( void  )

static

Definition at line 211 of file drive_wapbox.c.

References gwthread_create, http_open_port(), http_thread(), http_thread_id, panic, port, and ssl.

Referenced by main().

                                   {
    unsigned short port;
    int *port_copy;
    int ssl = 0;   /* indicate if SSL-enabled server should be used */

    for (port = 40000; port < 41000; port += 13) {
        if (http_open_port(port, ssl) != -1)
            break;
    }
    if (port == 41000)
        panic(0, "No ports available for http server");

        port_copy = gw_malloc(sizeof(*port_copy));
    *port_copy = port;
    http_thread_id = gwthread_create(http_thread, port_copy);
    if (http_thread_id == -1) 
        panic(0, "Cannot start http thread");
    return port;
}

start_request()

static void start_request ( Connection *  boxc, Client *  client  )

static

Definition at line 577 of file drive_wapbox.c.

References client(), gw_assert(), send_invoke_connect(), and send_invoke_get().

Referenced by run_requests().

                                                            {
    gw_assert(client != NULL);
    gw_assert(client->wsp_connected != 2);
    gw_assert(client->wtp_invoked == 0);

    if (client->wsp_connected == 0) {
        send_invoke_connect(boxc, client); 
    } else {
        send_invoke_get(boxc, client);
    }
}

start_wapbox()

static Connection* start_wapbox ( void  )

static

Definition at line 231 of file drive_wapbox.c.

References conn_wrap_fd(), make_server_socket(), panic, and wapbox_port.

Referenced by main().

                                      {
    int wap_socket;
    int wapbox;

    wap_socket = make_server_socket(wapbox_port, NULL);
    if (wap_socket < 0)
        panic(0, "Couldn't make wapbox port\n");

    wapbox = accept(wap_socket, NULL, NULL);
    if (wapbox < 0)
        panic(errno, "Wapbox could not connect\n");

    close(wap_socket);

    return conn_wrap_fd(wapbox, 0);
}

wdp_create()

static Msg* wdp_create ( Octstr *  data, Client *  client  )

static

Definition at line 371 of file drive_wapbox.c.

References client(), msg, msg_create, octstr_create, and octstr_duplicate.

Referenced by send_pdu().

                                                     {
    Msg *msg;

    msg = msg_create(wdp_datagram);
    msg->wdp_datagram.source_address = octstr_create("127.0.0.1");
    msg->wdp_datagram.source_port = client->port;
    msg->wdp_datagram.destination_address = octstr_create("127.0.0.1");
    msg->wdp_datagram.destination_port = 9201;
    msg->wdp_datagram.user_data = octstr_duplicate(data);

    return msg;
}

wtp_ack_create()

static Octstr* wtp_ack_create ( void  )

static

Definition at line 311 of file drive_wapbox.c.

References octstr_create_from_data.

Referenced by handle_connect_reply(), and handle_get_reply().

                                    {
    static unsigned char data[] = { 0x18, 0x00, 0x00 };
    return octstr_create_from_data(data, sizeof(data));
}

wtp_invoke_create()

static Octstr* wtp_invoke_create ( int  class )

static

Definition at line 295 of file drive_wapbox.c.

References gw_assert(), octstr_create_from_data, octstr_set_char(), set_user_ack(), and user_ack.

Referenced by send_invoke_connect(), send_invoke_disconnect(), and send_invoke_get().

                                            {
    Octstr *pdu;
    /* data describes a TR-Invoke PDU, with GTR=1 and TTR=1 (segmentation
     * not supported), and Transaction class 0 (which we replace below) */
    static unsigned char data[] = { 0x0e, 0x00, 0x00, 0x00 };
    gw_assert(class >= 0);
    gw_assert(class <= 2);
    pdu = octstr_create_from_data(data, sizeof(data));
    octstr_set_char(pdu, 3, class);

    if (user_ack)
        set_user_ack(pdu);

    return pdu;
}

wtp_type()

static int wtp_type ( Octstr *  pdu )

static

Definition at line 367 of file drive_wapbox.c.

References octstr_get_bits().

Referenced by handle_reply().

                                 {
    return octstr_get_bits(pdu, 1, 4);
}

Variable Documentation

clients

Client* clients

static

Definition at line 152 of file drive_wapbox.c.

Referenced by destroy_clients(), find_client(), and initialize_clients().

dying

volatile sig_atomic_t dying = 0

static

Definition at line 121 of file drive_wapbox.c.

Referenced by http_thread(), and main().

http_port

unsigned short http_port

static

Definition at line 113 of file drive_wapbox.c.

Referenced by add_wsp_get(), and main().

http_thread_id

long http_thread_id

static

Definition at line 209 of file drive_wapbox.c.

Referenced by main(), and start_http_thread().

http_url

Octstr* http_url = NULL

static

Definition at line 115 of file drive_wapbox.c.

Referenced by add_wsp_get(), and main().

max_clients

long max_clients = 1

static

Definition at line 111 of file drive_wapbox.c.

Referenced by find_client(), initialize_clients(), and main().

max_requests

long max_requests = 1

static

Definition at line 110 of file drive_wapbox.c.

Referenced by main(), and run_requests().

ready_clients

List* ready_clients

Definition at line 153 of file drive_wapbox.c.

Referenced by client_done(), destroy_clients(), initialize_clients(), and run_requests().

req_per_session

long req_per_session = 1

static

Definition at line 112 of file drive_wapbox.c.

Referenced by handle_get_reply(), and main().

requests_complete

long requests_complete = 0

static

Definition at line 120 of file drive_wapbox.c.

Referenced by client_done(), and run_requests().

user_ack

int user_ack = 0

static

Definition at line 118 of file drive_wapbox.c.

Referenced by main(), and wtp_invoke_create().

verbose_debug

int verbose_debug = 0

static

Definition at line 117 of file drive_wapbox.c.

Referenced by handle_reply(), main(), and send_pdu().

wapbox_port

int wapbox_port = 30188

static

Definition at line 114 of file drive_wapbox.c.

Referenced by main(), and start_wapbox().