emimsg.h File Reference

#include "gwlib/gwlib.h"

Go to the source code of this file.

Data Structures
struct	emimsg

Enumerations
enum	{   E01_ADC, E01_OADC, E01_AC, E01_MT,   E01_AMSG, SZ01 }
enum	{   E50_ADC, E50_OADC, E50_AC, E50_NRQ,   E50_NADC, E50_NT, E50_NPID, E50_LRQ,   E50_LRAD, E50_LPID, E50_DD, E50_DDT,   E50_VP, E50_RPID, E50_SCTS, E50_DST,   E50_RSN, E50_DSCTS, E50_MT, E50_NB,   E50_NMSG =20, E50_AMSG =20, E50_TMSG =20, E50_MMS,   E50_PR, E50_DCS, E50_MCLS, E50_RPI,   E50_CPG, E50_RPLY, E50_OTOA, E50_HPLMN,   E50_XSER, E50_RES4, E50_RES5, SZ50 }
enum	{   E60_OADC, E60_OTON, E60_ONPI, E60_STYP,   E60_PWD, E60_NPWD, E60_VERS, E60_LADC,   E60_LTON, E60_LNPI, E60_OPID, E60_RES1,   SZ60 }

Functions
struct emimsg *	emimsg_create_op (int ot, int trn, Octstr *whoami)
struct emimsg *	emimsg_create_reply (int ot, int trn, int positive, Octstr *whoami)
void	emimsg_destroy (struct emimsg *emimsg)
struct emimsg *	emimsg_duplicate (struct emimsg *emimsg)
struct emimsg *	get_fields (Octstr *message, Octstr *whoami)
int	emimsg_send (Connection *conn, struct emimsg *emimsg, Octstr *whoami)

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
E01_ADC
E01_OADC
E01_AC
E01_MT
E01_AMSG
SZ01

Definition at line 80 of file emimsg.h.

     {
    E01_ADC, E01_OADC, E01_AC, E01_MT, E01_AMSG, SZ01
};

anonymous enum

anonymous enum

Enumerator
E50_ADC
E50_OADC
E50_AC
E50_NRQ
E50_NADC
E50_NT
E50_NPID
E50_LRQ
E50_LRAD
E50_LPID
E50_DD
E50_DDT
E50_VP
E50_RPID
E50_SCTS
E50_DST
E50_RSN
E50_DSCTS
E50_MT
E50_NB
E50_NMSG
E50_AMSG
E50_TMSG
E50_MMS
E50_PR
E50_DCS
E50_MCLS
E50_RPI
E50_CPG
E50_RPLY
E50_OTOA
E50_HPLMN
E50_XSER
E50_RES4
E50_RES5
SZ50

Definition at line 86 of file emimsg.h.

     {
    E50_ADC, E50_OADC, E50_AC, E50_NRQ, E50_NADC, E50_NT, E50_NPID, E50_LRQ,
    E50_LRAD, E50_LPID, E50_DD, E50_DDT, E50_VP, E50_RPID, E50_SCTS, E50_DST,
    E50_RSN, E50_DSCTS, E50_MT, E50_NB, E50_NMSG=20, E50_AMSG=20, E50_TMSG=20,
    E50_MMS, E50_PR, E50_DCS, E50_MCLS, E50_RPI, E50_CPG, E50_RPLY, E50_OTOA,
    E50_HPLMN, E50_XSER, E50_RES4, E50_RES5, SZ50
};

anonymous enum

anonymous enum

Enumerator
E60_OADC
E60_OTON
E60_ONPI
E60_STYP
E60_PWD
E60_NPWD
E60_VERS
E60_LADC
E60_LTON
E60_LNPI
E60_OPID
E60_RES1
SZ60

Definition at line 95 of file emimsg.h.

     {
    E60_OADC, E60_OTON, E60_ONPI, E60_STYP, E60_PWD, E60_NPWD, E60_VERS,
    E60_LADC, E60_LTON, E60_LNPI, E60_OPID, E60_RES1, SZ60
};

Function Documentation

emimsg_create_op()

struct emimsg* emimsg_create_op	(	int	ot,
		int	trn,
		Octstr *	whoami
	)

Definition at line 166 of file emimsg.c.

References emimsg_create_withlen(), field_count_op(), emimsg::or, emimsg::ot, and emimsg::trn.

Referenced by get_fields(), make_emi31(), make_emi60(), and msg_to_emimsg().

{
    int len;
    struct emimsg *ret;

    len = field_count_op(ot, whoami);
    if (len < 0)
    return NULL;
    ret = emimsg_create_withlen(len);
    ret->ot = ot;
    ret->or = 'O';
    ret->trn = trn;
    return ret;
}

emimsg_create_reply()

struct emimsg* emimsg_create_reply	(	int	ot,
		int	trn,
		int	positive,
		Octstr *	whoami
	)

Definition at line 199 of file emimsg.c.

References emimsg_create_reply_s(), emimsg::fields, octstr_create, emimsg::ot, and emimsg::trn.

Referenced by handle_operation().

{
    struct emimsg *ret;

    ret = emimsg_create_reply_s(ot, trn, positive, whoami);
    if (ret) {
    if (positive)
        ret->fields[0] = octstr_create("A");
    else
        ret->fields[0] = octstr_create("N");
    }
    return ret;
}

emimsg_destroy()

void emimsg_destroy

(

struct emimsg *

emimsg

)

Definition at line 215 of file emimsg.c.

References emimsg::fields, emimsg::num_fields, and octstr_destroy().

Referenced by emi2_do_send(), emi2_handle_smscreq(), emi2_keepalive_handling(), emi2_receiver(), get_fields(), handle_operation(), open_send_connection(), and wait_for_ack().

{
    int len;

    len = emimsg->num_fields;
    while (--len >= 0) {
        octstr_destroy(emimsg->fields[len]);  /* octstr_destroy(NULL) is ok */
        emimsg->fields[len] = NULL;
    }
    gw_free(emimsg->fields);
    gw_free(emimsg);
}

emimsg_duplicate()

struct emimsg* emimsg_duplicate

(

struct emimsg *

emimsg

)

Definition at line 229 of file emimsg.c.

References emimsg::fields, emimsg::num_fields, octstr_duplicate, emimsg::or, emimsg::ot, and emimsg::trn.

{
    int len;
    struct emimsg *ret;

    len = emimsg->num_fields;
    if (len < 0)
        return NULL;
    ret = gw_malloc(sizeof(struct emimsg));
    ret->fields = gw_malloc(len * sizeof(Octstr *));
    ret->num_fields = len;
    while (--len >= 0)
        ret->fields[len] = octstr_duplicate(emimsg->fields[len]);
    ret->ot = emimsg->ot;
    ret->or = emimsg->or;
    ret->trn = emimsg->trn;

    return ret;
}

emimsg_send()

int emimsg_send	(	Connection *	conn,
		struct emimsg *	emimsg,
		Octstr *	whoami
	)

Definition at line 368 of file emimsg.c.

References conn_write(), debug(), emimsg_tostring(), error(), octstr_destroy(), octstr_get_cstr, and emimsg::ot.

Referenced by emi2_emimsg_send().

{
    Octstr *string;

    string = emimsg_tostring(emimsg);
    if (!string) {
    error(0, "EMI2[%s]: emimsg_send: conversion to string failed",
          octstr_get_cstr(whoami));
    return -1;
    }
    if (emimsg->ot == 60)
    debug("smsc.emi2", 0, "EMI2[%s]: Sending operation type 60, message with "
          "password not shown in log file.", octstr_get_cstr(whoami));
    else
    debug("smsc.emi2", 0, "EMI2[%s]: emi2 sending packet: <%s>",
          octstr_get_cstr(whoami), octstr_get_cstr(string));
    if (conn_write(conn, string) == -1) {
    octstr_destroy(string);
    error(0, "EMI2[%s]: emimsg_send: write failed",
          octstr_get_cstr(whoami));
    return -1;
    }
    octstr_destroy(string);
    return 1;
}

get_fields()

struct emimsg* get_fields	(	Octstr *	message,
		Octstr *	whoami
	)

Definition at line 290 of file emimsg.c.

References calculate_checksum(), debug(), emi_strerror(), emimsg_create_op(), emimsg_create_reply_s(), emimsg_destroy(), error(), emimsg::fields, emimsg::num_fields, octstr_copy, octstr_get_char(), octstr_get_cstr, octstr_len(), octstr_parse_long(), octstr_search_char(), emimsg::or, emimsg::ot, emimsg::trn, and warning().

Referenced by emi2_handle_smscreq(), emi2_receiver(), main(), and wait_for_ack().

{
    long trn, len, ot, checksum; /* because of Octstr_parse_long... */
    char or, posit;
    long fieldno, pos, pos2;
    struct emimsg *result = NULL;

    debug("smsc.emi2", 0, "EMI2[%s]: emi2 parsing packet: <%s>",
      octstr_get_cstr(whoami), octstr_get_cstr(message));
    if (octstr_get_char(message, 0) != 2 ||
    octstr_get_char(message, octstr_len(message) - 1) != 3)
    goto error;
    if (octstr_parse_long(&trn, message, 1, 10) != 3)
    goto error;
    if (octstr_parse_long(&len, message, 4, 10) != 9)
    goto error;
    if (octstr_len(message) != len + 2)     /* +2 for start/end markers */
    goto error;
    if ( (or = octstr_get_char(message, 10)) != 'O' && or != 'R')
    goto error;
    if (octstr_parse_long(&ot, message, 12, 10) != 14)
    goto error;
    if (or == 'O')
    result = emimsg_create_op(ot, trn, whoami);
    else {
    posit = octstr_get_char(message, 15);
    if (posit == 'A')
        result = emimsg_create_reply_s(ot, trn, 1, whoami);
    else if (posit == 'N')
        result = emimsg_create_reply_s(ot, trn, 0, whoami);
    else
        goto error;
    }
    if (result == NULL)
    goto error;
    pos2 = 14;
    for (fieldno = 0; fieldno < result->num_fields; fieldno++) {
    pos = pos2 + 1;
    if ( (pos2 = octstr_search_char(message, '/', pos)) == -1)
        goto error;
    if (pos2 > pos)
        result->fields[fieldno] = octstr_copy(message, pos, pos2 - pos);
    }
    if (octstr_search_char(message, '/', pos2 + 1) != -1) {
    int extrafields = 0;

    pos = pos2;
    while ((pos = octstr_search_char(message, '/', pos + 1)) != -1) {
        extrafields++;
        pos2 = pos;
    }
    /* The extra fields are ignored */
    warning(0, "get_fields: EMI message of type %d/%c has %d more fields "
        "than expected.", result->ot, result->or, extrafields);
    }
    if (octstr_parse_long(&checksum, message, pos2 + 1, 16) !=
    octstr_len(message) - 1 || checksum != calculate_checksum(message))
    goto error;
    if (result->or == 'R' && octstr_get_char(result->fields[0], 0) == 'N') {
    long errcode;
    if (!result->fields[1] ||
        octstr_parse_long(&errcode, result->fields[1], 0, 10) != 2)
        goto error;
    error(0, "EMI2[%s]: Got negative ack. op:%d, trn:%d, error:%ld (%s), message:%s",
          octstr_get_cstr(whoami),
          result->ot, result->trn, errcode, emi_strerror(errcode),
          result->fields[2] ? octstr_get_cstr(result->fields[2]) : "");
    }
    return result;
error:
    error(0, "EMI2[%s]: Invalid EMI packet: %s", octstr_get_cstr(whoami),
      octstr_get_cstr(message));
    if (result)
    emimsg_destroy(result);
    return NULL;
}