wap_push_ppg.h File Reference

#include "wap/wap_events.h"
#include "wap/wap.h"
#include "wap/wap_addr.h"
#include "gwlib/gwlib.h"
#include "wap_ppg_session_machine.def"
#include "wap_ppg_push_machine.def"

Go to the source code of this file.

Data Structures
struct	PPGSessionMachine
struct	PPGPushMachine

Macros
#define	OCTSTR(name)   Octstr *name;
#define	ADDRTUPLE(name)   WAPAddrTuple *name;
#define	INTEGER(name)   long name;
#define	PUSHMACHINES(name)   List *name;
#define	CAPABILITIES(name)   List *name;
#define	MACHINE(fields)   fields
#define	OCTSTR(name)   Octstr *name;
#define	OPTIONAL_OCTSTR(name)   Octstr *name;
#define	INTEGER(name)   long name;
#define	ADDRTUPLE(name)   WAPAddrTuple *name;
#define	HTTPHEADER(name)   List *name;
#define	CAPABILITIES(name)   List *name;
#define	MACHINE(fields)   fields

Typedefs
typedef struct PPGSessionMachine	PPGSessionMachine
typedef struct PPGPushMachine	PPGPushMachine

Enumerations
enum	{   PAP_UNDELIVERABLE, PAP_UNDELIVERABLE1, PAP_UNDELIVERABLE2, PAP_PENDING,   PAP_EXPIRED, PAP_DELIVERED, PAP_DELIVERED1, PAP_DELIVERED2,   PAP_ABORTED, PAP_TIMEOUT, PAP_CANCELLED }
enum	{   PAP_OK = 1000, PAP_ACCEPTED_FOR_PROCESSING = 1001, PAP_BAD_REQUEST = 2000, PAP_FORBIDDEN = 2001,   PAP_ADDRESS_ERROR = 2002, PAP_CAPABILITIES_MISMATCH = 2005, PAP_DUPLICATE_PUSH_ID = 2007, PAP_INTERNAL_SERVER_ERROR = 3000,   PAP_TRANSFORMATION_FAILURE = 3006, PAP_REQUIRED_BEARER_NOT_AVAILABLE = 3010, PAP_SERVICE_FAILURE = 4000, PAP_CLIENT_ABORTED = 5000,   PAP_ABORT_USERPND = 5028 }
enum	{ NOT_LAST, LAST }
enum	{ PAP_FALSE, PAP_TRUE }
enum	{ PAP_MEDIUM, PAP_HIGH, PAP_LOW }
enum	{ PAP_NOT_SPECIFIED = 0, PAP_PREFERCONFIRMED = 1, PAP_UNCONFIRMED = 2, PAP_CONFIRMED = 3 }
enum	{ CONNECTIONLESS_PUSH_CLIPORT = 2948, CONNECTIONLESS_SERVPORT = 9200, CONNECTED_CLIPORT = 9209, CONNECTED_SERVPORT = 9201 }

Functions
void	wap_push_ppg_init (wap_dispatch_func_t *ota_dispatch, wap_dispatch_func_t *appl_dispatch, Cfg *cfg)
void	wap_push_ppg_shutdown (void)
void	wap_push_ppg_dispatch_event (WAPEvent *e)
PPGSessionMachine *	wap_push_ppg_have_push_session_for (WAPAddrTuple *tuple)
PPGSessionMachine *	wap_push_ppg_have_push_session_for_sid (long sid)

Macro Definition Documentation

ADDRTUPLE [1/2]

#define ADDRTUPLE

(

name

)

WAPAddrTuple *name;

Definition at line 189 of file wap_push_ppg.h.

ADDRTUPLE [2/2]

#define ADDRTUPLE

(

name

)

WAPAddrTuple *name;

Definition at line 189 of file wap_push_ppg.h.

CAPABILITIES [1/2]

#define CAPABILITIES

(

name

)

List *name;

Definition at line 191 of file wap_push_ppg.h.

CAPABILITIES [2/2]

#define CAPABILITIES

(

name

)

List *name;

Definition at line 191 of file wap_push_ppg.h.

HTTPHEADER

#define HTTPHEADER

(

name

)

List *name;

Definition at line 190 of file wap_push_ppg.h.

INTEGER [1/2]

#define INTEGER

(

name

)

long name;

Definition at line 188 of file wap_push_ppg.h.

INTEGER [2/2]

#define INTEGER

(

name

)

long name;

Definition at line 188 of file wap_push_ppg.h.

MACHINE [1/2]

#define MACHINE

(

fields

)

fields

Definition at line 192 of file wap_push_ppg.h.

MACHINE [2/2]

#define MACHINE

(

fields

)

fields

Definition at line 192 of file wap_push_ppg.h.

OCTSTR [1/2]

#define OCTSTR

(

name

)

Octstr *name;

Definition at line 186 of file wap_push_ppg.h.

OCTSTR [2/2]

#define OCTSTR

(

name

)

Octstr *name;

Definition at line 186 of file wap_push_ppg.h.

OPTIONAL_OCTSTR

#define OPTIONAL_OCTSTR

(

name

)

Octstr *name;

Definition at line 187 of file wap_push_ppg.h.

PUSHMACHINES

#define PUSHMACHINES

(

name

)

List *name;

Definition at line 179 of file wap_push_ppg.h.

Typedef Documentation

PPGPushMachine

typedef struct PPGPushMachine PPGPushMachine

Definition at line 85 of file wap_push_ppg.h.

PPGSessionMachine

typedef struct PPGSessionMachine PPGSessionMachine

Definition at line 84 of file wap_push_ppg.h.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
PAP_UNDELIVERABLE
PAP_UNDELIVERABLE1
PAP_UNDELIVERABLE2
PAP_PENDING
PAP_EXPIRED
PAP_DELIVERED
PAP_DELIVERED1
PAP_DELIVERED2
PAP_ABORTED
PAP_TIMEOUT
PAP_CANCELLED

Definition at line 93 of file wap_push_ppg.h.

     {
    PAP_UNDELIVERABLE,         /* general message status */
    PAP_UNDELIVERABLE1,        /* transformation failure */
    PAP_UNDELIVERABLE2,        /* no bearer support */
    PAP_PENDING,
    PAP_EXPIRED,
    PAP_DELIVERED,             /* general message status */
    PAP_DELIVERED1,            /* for unconfirmed push, PPG internal */
    PAP_DELIVERED2,            /* for confirmed push, PPG internal  */
    PAP_ABORTED,
    PAP_TIMEOUT,
    PAP_CANCELLED
};

anonymous enum

anonymous enum

Enumerator
PAP_OK
PAP_ACCEPTED_FOR_PROCESSING
PAP_BAD_REQUEST
PAP_FORBIDDEN
PAP_ADDRESS_ERROR
PAP_CAPABILITIES_MISMATCH
PAP_DUPLICATE_PUSH_ID
PAP_INTERNAL_SERVER_ERROR
PAP_TRANSFORMATION_FAILURE
PAP_REQUIRED_BEARER_NOT_AVAILABLE
PAP_SERVICE_FAILURE
PAP_CLIENT_ABORTED
PAP_ABORT_USERPND

Definition at line 111 of file wap_push_ppg.h.

     {
    PAP_OK = 1000,
    PAP_ACCEPTED_FOR_PROCESSING = 1001,
    PAP_BAD_REQUEST = 2000, 
    PAP_FORBIDDEN = 2001,
    PAP_ADDRESS_ERROR = 2002,
    PAP_CAPABILITIES_MISMATCH = 2005,
    PAP_DUPLICATE_PUSH_ID = 2007,
    PAP_INTERNAL_SERVER_ERROR = 3000,
    PAP_TRANSFORMATION_FAILURE = 3006,
    PAP_REQUIRED_BEARER_NOT_AVAILABLE = 3010,
    PAP_SERVICE_FAILURE = 4000,
    PAP_CLIENT_ABORTED = 5000,
    PAP_ABORT_USERPND = 5028
};

anonymous enum

anonymous enum

Enumerator
NOT_LAST
LAST

Definition at line 130 of file wap_push_ppg.h.

     {
    NOT_LAST,
    LAST
};

anonymous enum

anonymous enum

Enumerator
PAP_FALSE
PAP_TRUE

Definition at line 141 of file wap_push_ppg.h.

     {
    PAP_FALSE,
    PAP_TRUE
};

anonymous enum

anonymous enum

Enumerator
PAP_MEDIUM
PAP_HIGH
PAP_LOW

Definition at line 149 of file wap_push_ppg.h.

     {
    PAP_MEDIUM,
    PAP_HIGH,
    PAP_LOW
};

anonymous enum

anonymous enum

Enumerator
PAP_NOT_SPECIFIED
PAP_PREFERCONFIRMED
PAP_UNCONFIRMED
PAP_CONFIRMED

Definition at line 158 of file wap_push_ppg.h.

     {
    PAP_NOT_SPECIFIED = 0,
    PAP_PREFERCONFIRMED = 1,
    PAP_UNCONFIRMED = 2,
    PAP_CONFIRMED = 3
};

anonymous enum

anonymous enum

Enumerator
CONNECTIONLESS_PUSH_CLIPORT
CONNECTIONLESS_SERVPORT
CONNECTED_CLIPORT
CONNECTED_SERVPORT

Definition at line 168 of file wap_push_ppg.h.

     {
    CONNECTIONLESS_PUSH_CLIPORT = 2948,
    CONNECTIONLESS_SERVPORT = 9200,
    CONNECTED_CLIPORT = 9209,
    CONNECTED_SERVPORT = 9201
};

Function Documentation

wap_push_ppg_dispatch_event()

void wap_push_ppg_dispatch_event

(

WAPEvent *

e

)

Definition at line 476 of file wap_push_ppg.c.

References gw_assert(), gwlist_produce(), ppg_queue, run_status, and running.

Referenced by confirm_push(), indicate_push_abort(), indicate_push_connection(), indicate_push_disconnect(), indicate_push_resume(), indicate_push_suspend(), and main().

{
    gw_assert(run_status == running);
    gwlist_produce(ppg_queue, e);
}

wap_push_ppg_have_push_session_for()

PPGSessionMachine* wap_push_ppg_have_push_session_for

(

WAPAddrTuple *

tuple

)

Definition at line 488 of file wap_push_ppg.c.

References WAPAddr::address, gw_assert(), gwlist_search(), ppg_machines, WAPAddrTuple::remote, and session_has_addr().

Referenced by handle_internal_event(), and main_thread().

{
    PPGSessionMachine *sm;

    gw_assert(tuple);
    sm = gwlist_search(ppg_machines, tuple->remote->address, session_has_addr);

    return sm;
}

wap_push_ppg_have_push_session_for_sid()

PPGSessionMachine* wap_push_ppg_have_push_session_for_sid

(

long

sid

)

Definition at line 503 of file wap_push_ppg.c.

References gw_assert(), gwlist_search(), ppg_machines, and session_has_sid().

Referenced by handle_internal_event(), and main_thread().

{
    PPGSessionMachine *sm;

    gw_assert(sid >= 0);
    sm = gwlist_search(ppg_machines, &sid, session_has_sid);

    return sm;
}

wap_push_ppg_init()

void wap_push_ppg_init	(	wap_dispatch_func_t *	ota_dispatch,
		wap_dispatch_func_t *	appl_dispatch,
		Cfg *	cfg
	)

Definition at line 397 of file wap_push_ppg.c.

References cfg, counter_create(), dict_create(), dispatch_to_appl, dispatch_to_ota, gw_assert(), gwlist_add_producer(), gwlist_create, gwthread_create, http_clients, http_open_port(), http_read_thread(), limbo, NO_HTTPS_PORT, number_of_pushes, ota_read_thread(), pap_queue, pap_request_thread(), ppg_machines, ppg_port, ppg_queue, ppg_unit_pushes, push_id_counter, read_ppg_config(), run_status, running, TYPE_HTTP, TYPE_HTTPS, urls, user_configuration, and USER_CONFIGURATION_NOT_ADDED.

Referenced by main().

{
    user_configuration = read_ppg_config(cfg);
    if (user_configuration != USER_CONFIGURATION_NOT_ADDED) {
        ppg_queue = gwlist_create();
        gwlist_add_producer(ppg_queue);
        pap_queue = gwlist_create();
        gwlist_add_producer(pap_queue);
        push_id_counter = counter_create();
        ppg_machines = gwlist_create();
        ppg_unit_pushes = gwlist_create();

        dispatch_to_ota = ota_dispatch;
        dispatch_to_appl = appl_dispatch;

        http_open_port(ppg_port, TYPE_HTTP);
#ifdef HAVE_LIBSSL
        if (ppg_ssl_port != NO_HTTPS_PORT)
            http_open_port(ppg_ssl_port, TYPE_HTTPS);
#endif
        http_clients = dict_create(number_of_pushes, NULL);
        urls = dict_create(number_of_pushes, NULL);

        gw_assert(run_status == limbo);
        run_status = running;
        gwthread_create(ota_read_thread, NULL);
        gwthread_create(http_read_thread, NULL);
#ifdef HAVE_LIBSSL
        if (ppg_ssl_port != NO_HTTPS_PORT) 
            gwthread_create(https_read_thread, NULL);
#endif
        gwthread_create(pap_request_thread, NULL);
    }
}

wap_push_ppg_shutdown()

void wap_push_ppg_shutdown

(

void

)

Definition at line 433 of file wap_push_ppg.c.

References counter_destroy(), debug(), dict_destroy(), global_sender, gw_assert(), gwlist_destroy(), gwlist_len(), gwlist_remove_producer(), gwthread_join_every(), http_clients, http_close_all_ports(), http_read_thread(), NO_HTTPS_PORT, octstr_destroy(), ota_read_thread(), pap_event_destroy_item(), pap_queue, pap_request_thread(), ppg_allow_ip, ppg_default_smsc, ppg_deny_ip, ppg_dlr_url, ppg_machines, ppg_queue, ppg_smsbox_id, ppg_unit_pushes, ppg_url, push_id_counter, push_machine_destroy(), run_status, running, service_name, session_machine_destroy(), terminating, urls, user_configuration, USER_CONFIGURATION_NOT_ADDED, wap_event_destroy_item(), and wap_push_ppg_pushuser_list_destroy().

Referenced by main().

{
     if (user_configuration != USER_CONFIGURATION_NOT_ADDED) {
         gw_assert(run_status == running);
         run_status = terminating;
         gwlist_remove_producer(ppg_queue);
         gwlist_remove_producer(pap_queue);
         octstr_destroy(ppg_url);
         ppg_url = NULL;
         http_close_all_ports();
         dict_destroy(http_clients);
         dict_destroy(urls);
         wap_push_ppg_pushuser_list_destroy();
         octstr_destroy(ppg_deny_ip);
         octstr_destroy(ppg_allow_ip);
         octstr_destroy(global_sender);
         octstr_destroy(service_name);
         octstr_destroy(ppg_default_smsc);
         octstr_destroy(ppg_dlr_url);
         octstr_destroy(ppg_smsbox_id);

         gwthread_join_every(http_read_thread);
#ifdef HAVE_LIBSSL
         if (ppg_ssl_port != NO_HTTPS_PORT)
            gwthread_join_every(https_read_thread);
#endif
         gwthread_join_every(ota_read_thread);
         gwthread_join_every(pap_request_thread);

         gwlist_destroy(ppg_queue, wap_event_destroy_item);
         gwlist_destroy(pap_queue, pap_event_destroy_item);
         counter_destroy(push_id_counter);
     
         debug("wap.push.ppg", 0, "PPG: %ld push session machines left.",
               gwlist_len(ppg_machines));
         gwlist_destroy(ppg_machines, session_machine_destroy);

         debug("wap_push_ppg", 0, "PPG: %ld unit pushes left", 
               gwlist_len(ppg_unit_pushes));
         gwlist_destroy(ppg_unit_pushes, push_machine_destroy);
     }
}