msg.c File Reference

#include <errno.h>
#include <stdlib.h>
#include <sys/types.h>
#include <netinet/in.h>
#include "msg.h"
#include "gwlib/gwlib.h"
#include "msg-decl.h"

Go to the source code of this file.

Macros
#define	INTEGER(name)   p->name = MSG_PARAM_UNDEFINED;
#define	OCTSTR(name)   p->name = NULL;
#define	UUID(name)   uuid_generate(p->name);
#define	VOID(name)   p->name = NULL;
#define	MSG(type, stmt)   { struct type *p = &msg->type; stmt }
#define	INTEGER(name)   p->name = q->name;
#define	OCTSTR(name)
#define	UUID(name)   uuid_copy(p->name, q->name);
#define	VOID(name)   p->name = q->name;
#define	MSG(type, stmt)
#define	INTEGER(name)   p->name = 0;
#define	OCTSTR(name)   octstr_destroy(p->name);
#define	UUID(name)   uuid_clear(p->name);
#define	VOID(name)
#define	MSG(type, stmt)   { struct type *p = &msg->type; stmt }
#define	INTEGER(name)   debug("gw.msg", 0, "%*s %s.%s: %ld", level, "", t, #name, (long) p->name);
#define	OCTSTR(name)
#define	UUID(name)
#define	VOID(name)   debug("gw.msg", 0, "%*s %s.%s: %p", level, "", t, #name, p->name);
#define	MSG(tt, stmt)
#define	INTEGER(name)   append_integer(os, p->name);
#define	OCTSTR(name)   append_string(os, p->name);
#define	UUID(name)   append_uuid(os, p->name);
#define	VOID(name)
#define	MSG(type, stmt)   case type: { struct type *p = &msg->type; stmt } break;
#define	INTEGER(name)   if (parse_integer(&(p->name), os, &off) == -1) goto error;
#define	OCTSTR(name)   if (parse_string(&(p->name), os, &off) == -1) goto error;
#define	UUID(name)   if (parse_uuid(p->name, os, &off) == -1) goto error;
#define	VOID(name)
#define	MSG(type, stmt)   case type: { struct type *p = &(msg->type); stmt } break;
#define	MSG(t, stmt)   case t: return #t;

Functions
static void	append_integer (Octstr *os, long i)
static void	append_string (Octstr *os, Octstr *field)
static void	append_uuid (Octstr *os, uuid_t id)
static int	parse_integer (long *i, Octstr *packed, int *off)
static int	parse_string (Octstr **os, Octstr *packed, int *off)
static int	parse_uuid (uuid_t id, Octstr *packed, int *off)
static char *	type_as_str (Msg *msg)
Msg *	msg_create_real (enum msg_type type, const char *file, long line, const char *func)
Msg *	msg_duplicate (Msg *msg)
void	msg_destroy (Msg *msg)
void	msg_destroy_item (void *msg)
void	msg_dump (Msg *msg, int level)
enum msg_type	msg_type (Msg *msg)
Octstr *	msg_pack (Msg *msg)
Msg *	msg_unpack_real (Octstr *os, const char *file, long line, const char *func)
Msg *	msg_unpack_wrapper (Octstr *os)

Macro Definition Documentation

INTEGER [1/6]

#define INTEGER

(

name

)

p->name = MSG_PARAM_UNDEFINED;

INTEGER [2/6]

#define INTEGER

(

name

)

p->name = q->name;

INTEGER [3/6]

#define INTEGER

(

name

)

p->name = 0;

INTEGER [4/6]

#define INTEGER

(

name

)

debug("gw.msg", 0, "%*s %s.%s: %ld", level, "", t, #name, (long) p->name);

INTEGER [5/6]

#define INTEGER

(

name

)

append_integer(os, p->name);

INTEGER [6/6]

#define INTEGER

(

name

)

if (parse_integer(&(p->name), os, &off) == -1) goto error;

MSG [1/7]

#define MSG	(		type,
			stmt
	)		{ struct type *p = &msg->type; stmt }

MSG [2/7]

#define MSG	(		type,
			stmt
	)

Value:

{ \
    struct type *p = &new->type; \
    struct type *q = &msg->type; \
    stmt }

MSG [3/7]

#define MSG	(		type,
			stmt
	)		{ struct type *p = &msg->type; stmt }

MSG [4/7]

#define MSG	(		tt,
			stmt
	)

Value:

if (tt == msg->type) \
        { char *t = #tt; struct tt *p = &msg->tt; stmt }

MSG [5/7]

#define MSG	(		type,
			stmt
	)		case type: { struct type *p = &msg->type; stmt } break;

MSG [6/7]

#define MSG	(		type,
			stmt
	)		case type: { struct type *p = &(msg->type); stmt } break;

MSG [7/7]

#define MSG	(		t,
			stmt
	)		case t: return #t;

OCTSTR [1/6]

#define OCTSTR

(

name

)

p->name = NULL;

OCTSTR [2/6]

#define OCTSTR

(

name

)

Value:

if (q->name == NULL) p->name = NULL; \
    else p->name = octstr_duplicate(q->name);

OCTSTR [3/6]

#define OCTSTR

(

name

)

octstr_destroy(p->name);

OCTSTR [4/6]

#define OCTSTR

(

name

)

Value:

debug("gw.msg", 0, "%*s %s.%s:", level, "", t, #name); \
    octstr_dump(p->name, level + 1);

OCTSTR [5/6]

#define OCTSTR

(

name

)

append_string(os, p->name);

OCTSTR [6/6]

#define OCTSTR

(

name

)

if (parse_string(&(p->name), os, &off) == -1) goto error;

UUID [1/6]

#define UUID

(

name

)

uuid_generate(p->name);

UUID [2/6]

#define UUID

(

name

)

uuid_copy(p->name, q->name);

UUID [3/6]

#define UUID

(

name

)

uuid_clear(p->name);

UUID [4/6]

#define UUID

(

name

)

Value:

uuid_unparse(p->name, buf); \
    debug("gw.msg", 0 , "%*s %s.%s: %s", level, "", t, #name, buf);

UUID [5/6]

#define UUID

(

name

)

append_uuid(os, p->name);

UUID [6/6]

#define UUID

(

name

)

if (parse_uuid(p->name, os, &off) == -1) goto error;

VOID [1/6]

#define VOID

(

name

)

p->name = NULL;

VOID [2/6]

#define VOID

(

name

)

p->name = q->name;

VOID [3/6]

#define VOID

(

name

)

VOID [4/6]

#define VOID

(

name

)

debug("gw.msg", 0, "%*s %s.%s: %p", level, "", t, #name, p->name);

VOID [5/6]

#define VOID

(

name

)

VOID [6/6]

#define VOID

(

name

)

Function Documentation

append_integer()

static void append_integer ( Octstr *  os, long  i  )

static

Definition at line 267 of file msg.c.

References encode_network_long(), and octstr_append_data().

Referenced by append_string(), append_uuid(), and msg_pack().

{
    unsigned char buf[4];

    encode_network_long(buf, i);
    octstr_append_data(os, (char *)buf, 4);
}

append_string()

static void append_string ( Octstr *  os, Octstr *  field  )

static

Definition at line 275 of file msg.c.

References append_integer(), octstr_insert(), and octstr_len().

{
    if (field == NULL)
        append_integer(os, -1);
    else {
        append_integer(os, octstr_len(field));
        octstr_insert(os, field, octstr_len(os));
    }
}

append_uuid()

static void append_uuid ( Octstr *  os, uuid_t  id  )

static

Definition at line 285 of file msg.c.

References append_integer(), octstr_append_cstr(), UUID_STR_LEN, and uuid_unparse().

{
    char buf[UUID_STR_LEN + 1];

    uuid_unparse(id, buf);
    append_integer(os, UUID_STR_LEN);
    octstr_append_cstr(os, buf);
}

msg_create_real()

Msg* msg_create_real	(	enum msg_type	type,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 93 of file msg.c.

References file, msg, and type.

Referenced by msg_unpack_real().

{
    Msg *msg;

    msg = gw_malloc_trace(sizeof(Msg), file, line, func);

    msg->type = type;
#define INTEGER(name) p->name = MSG_PARAM_UNDEFINED;
#define OCTSTR(name) p->name = NULL;
#define UUID(name) uuid_generate(p->name);
#define VOID(name) p->name = NULL;
#define MSG(type, stmt) { struct type *p = &msg->type; stmt }
#include "msg-decl.h"

    return msg;
}

msg_destroy()

void msg_destroy

(

Msg *

msg

)

Definition at line 132 of file msg.c.

References msg.

Referenced by bb_remove_message(), bb_smscconn_receive(), bb_smscconn_receive_internal(), bb_smscconn_send_failed(), bb_smscconn_sent(), bearerbox_to_smpp(), bearerbox_to_smsbox(), bearerbox_to_sql(), boxc_receiver(), boxc_sender(), boxc_sent_pop(), catenate_msg(), cimd2_accept_message(), concat_handling_check_and_handle(), concat_handling_clear_old_parts(), data_sm_to_msg(), deliver_sms_to_queue(), deliver_to_bearerbox_real(), destroy_concatMsg(), dispatch_datagram(), dispatch_into_queue(), dlr_spool_add(), dlr_spool_get(), emi_receive_msg(), empty_msg_lists(), generic_receive_sms(), handle_pdu(), handle_split(), http_queue_thread(), identify_to_bearerbox(), main(), main_connection_loop(), msg_destroy_item(), msg_to_bb(), msg_to_pdu(), msg_unpack_real(), obey_request_thread(), ois_deliver_sm_invoke(), oisd_accept_message(), pdu_to_msg(), read_messages_from_bearerbox(), retry_consumer_thread(), run_batch(), run_requests(), send_message(), send_pdu(), smpp_msg_destroy(), sms_receive(), sms_router(), sms_split(), smsbox_req_handle(), smsbox_req_sendota(), smsbox_sendota_post(), smsbox_thread(), smsbox_to_bearerbox(), smsc2_rout(), sql_list(), sql_single(), status_cb(), store_file_load(), store_file_save_ack(), store_spool_save_ack(), store_to_dict(), timer_consumer_thread(), udp_sender(), url_result_thread(), wdp_to_wapboxes(), wrapper_sender(), and write_to_bearerbox_real().

{
    if (msg == NULL)
        return;

#define INTEGER(name) p->name = 0;
#define OCTSTR(name) octstr_destroy(p->name);
#define UUID(name) uuid_clear(p->name);
#define VOID(name)
#define MSG(type, stmt) { struct type *p = &msg->type; stmt }
#include "msg-decl.h"

    gw_free(msg);
}

msg_destroy_item()

void msg_destroy_item

(

void *

msg

)

Definition at line 147 of file msg.c.

References msg, and msg_destroy().

Referenced by boxc_create(), cimd2_destroy(), empty_msg_lists(), handle_pdu(), msg_to_pdu(), oisd_destroy(), run_batch(), smasi_destroy(), smpp_destroy(), smscconn_send(), sql_list(), and store_file_init().

{
    msg_destroy(msg);
}

msg_dump()

void msg_dump	(	Msg *	msg,
		int	level
	)

Definition at line 152 of file msg.c.

References debug(), msg, type_as_str(), and UUID_STR_LEN.

Referenced by bearerbox_to_smpp(), boxc_sent_pop(), concat_handling_check_and_handle(), dump(), handle_pdu(), main(), obey_request_thread(), print_msg(), read_messages_from_bearerbox(), send_message(), and store_file_load().

{
    char buf[UUID_STR_LEN + 1];

    debug("gw.msg", 0, "%*sMsg object at %p:", level, "", (void *) msg);
    debug("gw.msg", 0, "%*s type: %s", level, "", type_as_str(msg));
#define INTEGER(name) \
    debug("gw.msg", 0, "%*s %s.%s: %ld", level, "", t, #name, (long) p->name);
#define OCTSTR(name) \
    debug("gw.msg", 0, "%*s %s.%s:", level, "", t, #name); \
    octstr_dump(p->name, level + 1);
#define UUID(name) \
    uuid_unparse(p->name, buf); \
    debug("gw.msg", 0 , "%*s %s.%s: %s", level, "", t, #name, buf);
#define VOID(name) \
     debug("gw.msg", 0, "%*s %s.%s: %p", level, "", t, #name, p->name);
#define MSG(tt, stmt) \
    if (tt == msg->type) \
        { char *t = #tt; struct tt *p = &msg->tt; stmt }
#include "msg-decl.h"
    debug("gw.msg", 0, "Msg object ends.");
}

msg_duplicate()

Msg* msg_duplicate

(

Msg *

msg

)

Definition at line 111 of file msg.c.

References msg, and msg_create.

Referenced by add_msg_cb(), at2_add_msg_cb(), bb_smscconn_receive_internal(), bearerbox_to_smsbox(), boxc_sent_push(), catenate_msg(), cgw_add_msg_cb(), cimd2_add_msg_cb(), concat_handling_check_and_handle(), concat_handling_clear_old_parts(), generic_receive_sms(), handle_pdu(), httpsmsc_send(), main(), main_connection_loop(), msg_cb(), oisd_add_msg_cb(), run_batch(), send_message(), send_msg_cb(), sms_split(), smsbox_to_bearerbox(), smsc2_rout(), smscconn_send(), soap_add_msg_cb(), store_to_dict(), wrapper_add_msg(), and wrapper_sender().

{
    Msg *new;

    new = msg_create(msg->type);

#define INTEGER(name) p->name = q->name;
#define OCTSTR(name) \
    if (q->name == NULL) p->name = NULL; \
    else p->name = octstr_duplicate(q->name);
#define UUID(name) uuid_copy(p->name, q->name);
#define VOID(name) p->name = q->name;
#define MSG(type, stmt) { \
    struct type *p = &new->type; \
    struct type *q = &msg->type; \
    stmt }
#include "msg-decl.h"

    return new;
}

msg_pack()

Octstr* msg_pack

(

Msg *

msg

)

Definition at line 181 of file msg.c.

References append_integer(), msg, octstr_create, and panic.

Referenced by deliver_to_bearerbox_real(), init_bearerbox(), init_smppbox(), main(), send_msg(), send_pdu(), smsbox_thread(), and write_to_bearerbox_real().

{
    Octstr *os;

    os = octstr_create("");
    append_integer(os, msg->type);

#define INTEGER(name) append_integer(os, p->name);
#define OCTSTR(name) append_string(os, p->name);
#define UUID(name) append_uuid(os, p->name);
#define VOID(name)
#define MSG(type, stmt) \
    case type: { struct type *p = &msg->type; stmt } break;

    switch (msg->type) {
#include "msg-decl.h"
    default:
        panic(0, "Internal error: unknown message type: %d",
              msg->type);
    }

    return os;
}

msg_type()

enum msg_type msg_type

(

Msg *

msg

)

Definition at line 176 of file msg.c.

References msg.

{
    return msg->type;
}

msg_unpack_real()

Msg* msg_unpack_real	(	Octstr *	os,
		const char *	file,
		long	line,
		const char *	func
	)

Definition at line 206 of file msg.c.

References error(), file, msg, msg_create_real(), msg_destroy(), and parse_integer().

{
    Msg *msg;
    int off;
    long i;

    msg = msg_create_real(0, file, line, func);
    if (msg == NULL)
        goto error;

    off = 0;

    if (parse_integer(&i, os, &off) == -1)
        goto error;
    msg->type = i;

#define INTEGER(name) \
    if (parse_integer(&(p->name), os, &off) == -1) goto error;
#define OCTSTR(name) \
    if (parse_string(&(p->name), os, &off) == -1) goto error;
#define UUID(name) \
    if (parse_uuid(p->name, os, &off) == -1) goto error;
#define VOID(name)
#define MSG(type, stmt) \
    case type: { struct type *p = &(msg->type); stmt } break;

    switch (msg->type) {
#include "msg-decl.h"
    default:
        error(0, "Internal error: unknown message type: %d",
              msg->type);
        msg->type = 0;
        msg_destroy(msg);
        return NULL;
    }

    return msg;

error:
    if (msg != NULL) msg_destroy(msg);
    error(0, "Msg packet was invalid.");
    return NULL;
}

msg_unpack_wrapper()

Msg* msg_unpack_wrapper ( Octstr *  os )

inline

Definition at line 256 of file msg.c.

References msg_unpack.

Referenced by init_bearerbox(), init_smppbox(), and main().

{
    return msg_unpack(os);
}

parse_integer()

static int parse_integer ( long *  i, Octstr *  packed, int *  off  )

static

Definition at line 294 of file msg.c.

References decode_network_long(), error(), gw_assert(), octstr_get_many_chars(), and octstr_len().

Referenced by msg_unpack_real(), and parse_string().

{
    unsigned char buf[4];

    gw_assert(*off >= 0);
    if (*off + 4 > octstr_len(packed)) {
        error(0, "Packet too short while unpacking Msg.");
        return -1;
    }

    octstr_get_many_chars((char *)buf, packed, *off, 4);
    *i = decode_network_long(buf);
    *off += 4;
    return 0;
}

parse_string()

static int parse_string ( Octstr **  os, Octstr *  packed, int *  off  )

static

Definition at line 311 of file msg.c.

References octstr_copy, and parse_integer().

Referenced by parse_uuid().

{
    long len;

    if (parse_integer(&len, packed, off) == -1)
        return -1;

    if (len == -1) {
        *os = NULL;
        return 0;
    }

    /* XXX check that len is ok */

    *os = octstr_copy(packed, *off, len);
    if (*os == NULL)
        return -1;
    *off += len;

    return 0;
}

parse_uuid()

static int parse_uuid ( uuid_t  id, Octstr *  packed, int *  off  )

static

Definition at line 334 of file msg.c.

References octstr_destroy(), octstr_get_cstr, parse_string(), and uuid_parse().

{
   Octstr *tmp = NULL;

   if (parse_string(&tmp, packed, off) == -1) {
       octstr_destroy(tmp);
       return -1;
   }

   if (uuid_parse(octstr_get_cstr(tmp), id) == -1) {
       octstr_destroy(tmp);
       return -1;
   }

   octstr_destroy(tmp);

   return 0;
}

type_as_str()

static char * type_as_str ( Msg *  msg )

static

Definition at line 353 of file msg.c.

References msg.

Referenced by msg_dump().

{
    switch (msg->type) {
#define MSG(t, stmt) case t: return #t;
#include "msg-decl.h"
    default:
        return "unknown type";
    }
}