smsc_ois.c File Reference

#include <unistd.h>
#include <ctype.h>
#include <errno.h>
#include <string.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/timeb.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "smsc.h"
#include "smsc_p.h"
#include "gwlib/gwlib.h"
#include "sms.h"

Go to the source code of this file.

Data Structures
struct	ois_listentry

Macros
#define	SAY(d, s)   { if (d<=ois_debug_level) debug("bb.sms.ois",0,s); }
#define	SAY2(d, s, t)   { if (d<=ois_debug_level) debug("bb.sms.ois",0,s,t); }
#define	SAY3(d, s, t, u)   { if (d<=ois_debug_level) debug("bb.sms.ois",0,s,t,u); }
#define	IOTRACE(x, s, l)   SAY3(1,"%s [%s]",x,ois_debug_str(s,l))
#define	BUFLEN   (511) /* sure enough for ois messages */
#define	OIS_OPEN_WAITTIME   (15) /* seconds, waiting for banners */
#define	OIS_MESSAGE_WAITTIME   (30) /* seconds, until closing idle connection */
#define	OIS_WAITTIME   (999999) /* microseconds, waiting for banners at a time */
#define	OIS_NOWAIT   (0) /* microseconds, not waiting */
#define	MAXCOUNTER   (10000) /* ois message id */
#define	EOL   ('\r') /* ois definition for the eol */
#define	OIS_FLAG_DEBUG   (0x000f)
#define	OIS_FLAG_ERROR   (0x0100)
#define	OIS_FLAG_NOBANNER   (0x0200)
#define	OIS_FLAG_MULTIPLE_CALL   (0x0400)
#define	OIS_FLAG_CLOSED   (0x0800)

Typedefs
typedef struct ois_listentry	ois_listentry

Enumerations
enum	dcs_body_type { DCS_GSM_TEXT = 0, DCS_OCTET_DATA = 4 }

Functions
static int	ois_open_listener (SMSCenter *smsc)
static int	ois_open_sender (SMSCenter *smsc)
static int	ois_open_receiver (SMSCenter *smsc)
static void	ois_disconnect_all (SMSCenter *smsc)
static void	ois_disconnect (SMSCenter *smsc)
static int	ois_read_into_buffer (SMSCenter *smsc, long wait_usec)
static int	ois_check_input (SMSCenter *smsc, long wait_usec)
static int	ois_check_incoming (SMSCenter *smsc, long wait_usec)
static void	ois_append_to_list (ois_listentry **head, Msg *msg)
static int	ois_int_to_i4 (char *raw, int nbr)
static int	ois_increment_counter (void)
static int	ois_submit_sm_invoke (SMSCenter *smsc, const Msg *msg)
static int	ois_encode_submit_sm_invoke (char *str, const Msg *msg)
static int	ois_append_msisdn (char *raw, const Msg *msg)
static int	ois_append_sme_reference_number (char *raw)
static int	ois_append_priority (char *raw)
static int	ois_append_originating_address (char *raw)
static int	ois_append_validity_period (char *raw)
static int	ois_append_data_coding_scheme (char *raw, const Msg *msg)
static int	ois_append_status_report_request (char *raw)
static int	ois_append_protocol_id (char *raw)
static int	ois_append_submission_options (char *raw, const Msg *msg)
static int	ois_append_sm_text (char *raw, const Msg *msg)
static int	ois_submit_sm_result (SMSCenter *smsc, const char *buffer)
static int	ois_decode_submit_sm_result (int *code, const char *str)
static int	ois_deliver_sm_invoke (SMSCenter *smsc, const char *buffer)
static int	ois_decode_deliver_sm_invoke (Msg *msg, const char *str)
static int	ois_check_deliver_sm_invoke (const char *str)
static int	ois_adjust_destination_address (Msg *msg, const char *raw)
static int	ois_ignore_smsc_reference_number (const char *raw)
static int	ois_adjust_originating_address (Msg *msg, const char *raw)
static int	ois_adjust_data_coding_scheme (Msg *msg, const char *raw)
static int	ois_ignore_protocol_id (const char *raw)
static int	ois_adjust_additional_information (Msg *msg, const char *raw)
static int	ois_adjust_sm_text (Msg *msg, const char *raw)
static int	ois_ignore_time (const char *raw)
static int	ois_deliver_sm_result (SMSCenter *smsc, int result, const char *str)
static int	ois_encode_deliver_sm_result (char *str, int result)
static int	ois_expand_gsm7 (char *raw8, const char *raw7, int len)
static int	ois_expand_gsm7_to_bits (char *bits, const char *raw7, int len)
static char	ois_expand_gsm7_from_bits (const char *bits, int pos)
static int	ois_convert_to_ia5 (char *str, const char *raw, int len)
static int	ois_convert_from_ia5 (char *raw, const char *str)
static int	ois_convert_to_iso88591 (char *raw, int len)
static int	ois_extract_msg_from_buffer (char *str, SMSCenter *smsc)
static int	ois_extract_line_from_buffer (char *str, SMSCenter *smsc)
static void	ois_swap_buffering (SMSCenter *smsc)
static const char *	ois_debug_str (const char *raw, int len)
SMSCenter *	ois_open (int receiveport, const char *hostname, int port, int debug_level)
int	ois_close (SMSCenter *smsc)
int	ois_reopen (SMSCenter *smsc)
int	ois_pending_smsmessage (SMSCenter *smsc)
int	ois_submit_msg (SMSCenter *smsc, const Msg *msg)
int	ois_receive_msg (SMSCenter *smsc, Msg **msg)
void	ois_delete_queue (SMSCenter *smsc)

Variables
int	ois_debug_level = 0
static int	ois_counter = 0

Macro Definition Documentation

BUFLEN

#define BUFLEN   (511) /* sure enough for ois messages */

Definition at line 147 of file smsc_ois.c.

Referenced by ois_adjust_sm_text(), ois_check_deliver_sm_invoke(), ois_check_input(), ois_debug_str(), ois_decode_deliver_sm_invoke(), ois_decode_submit_sm_result(), ois_deliver_sm_result(), ois_encode_submit_sm_invoke(), ois_expand_gsm7(), ois_extract_msg_from_buffer(), ois_open_sender(), and ois_submit_sm_invoke().

EOL

#define EOL   ('\r') /* ois definition for the eol */

Definition at line 153 of file smsc_ois.c.

Referenced by ois_check_deliver_sm_invoke(), ois_decode_deliver_sm_invoke(), ois_decode_submit_sm_result(), ois_deliver_sm_result(), ois_extract_msg_from_buffer(), and ois_submit_sm_invoke().

IOTRACE

#define IOTRACE	(		x,
			s,
			l
	)		SAY3(1,"%s [%s]",x,ois_debug_str(s,l))

Definition at line 144 of file smsc_ois.c.

Referenced by ois_adjust_sm_text(), ois_append_sm_text(), ois_check_input(), ois_deliver_sm_result(), and ois_submit_sm_invoke().

MAXCOUNTER

#define MAXCOUNTER   (10000) /* ois message id */

Definition at line 152 of file smsc_ois.c.

Referenced by ois_increment_counter().

OIS_FLAG_CLOSED

#define OIS_FLAG_CLOSED   (0x0800)

Definition at line 164 of file smsc_ois.c.

Referenced by ois_read_into_buffer().

OIS_FLAG_DEBUG

#define OIS_FLAG_DEBUG   (0x000f)

Definition at line 160 of file smsc_ois.c.

Referenced by ois_close(), ois_delete_queue(), ois_open(), ois_pending_smsmessage(), ois_receive_msg(), ois_reopen(), and ois_submit_msg().

OIS_FLAG_ERROR

#define OIS_FLAG_ERROR   (0x0100)

Definition at line 161 of file smsc_ois.c.

Referenced by ois_check_incoming(), ois_check_input(), ois_open_listener(), ois_open_receiver(), and ois_receive_msg().

OIS_FLAG_MULTIPLE_CALL

#define OIS_FLAG_MULTIPLE_CALL   (0x0400)

Definition at line 163 of file smsc_ois.c.

Referenced by ois_check_incoming().

OIS_FLAG_NOBANNER

#define OIS_FLAG_NOBANNER   (0x0200)

Definition at line 162 of file smsc_ois.c.

Referenced by ois_open_listener(), and ois_open_sender().

OIS_MESSAGE_WAITTIME

#define OIS_MESSAGE_WAITTIME   (30) /* seconds, until closing idle connection */

Definition at line 149 of file smsc_ois.c.

Referenced by ois_check_input().

OIS_NOWAIT

#define OIS_NOWAIT   (0) /* microseconds, not waiting */

Definition at line 151 of file smsc_ois.c.

Referenced by ois_pending_smsmessage().

OIS_OPEN_WAITTIME

#define OIS_OPEN_WAITTIME   (15) /* seconds, waiting for banners */

Definition at line 148 of file smsc_ois.c.

Referenced by ois_open_sender().

OIS_WAITTIME

#define OIS_WAITTIME   (999999) /* microseconds, waiting for banners at a time */

Definition at line 150 of file smsc_ois.c.

Referenced by ois_open_sender().

SAY

#define SAY	(		d,
			s
	)		{ if (d<=ois_debug_level) debug("bb.sms.ois",0,s); }

Definition at line 141 of file smsc_ois.c.

Referenced by ois_adjust_additional_information(), ois_adjust_data_coding_scheme(), ois_adjust_destination_address(), ois_adjust_originating_address(), ois_adjust_sm_text(), ois_append_data_coding_scheme(), ois_append_msisdn(), ois_append_originating_address(), ois_append_priority(), ois_append_protocol_id(), ois_append_sm_text(), ois_append_sme_reference_number(), ois_append_status_report_request(), ois_append_submission_options(), ois_append_to_list(), ois_append_validity_period(), ois_check_deliver_sm_invoke(), ois_check_incoming(), ois_check_input(), ois_close(), ois_convert_from_ia5(), ois_decode_deliver_sm_invoke(), ois_decode_submit_sm_result(), ois_delete_queue(), ois_deliver_sm_invoke(), ois_deliver_sm_result(), ois_disconnect_all(), ois_encode_deliver_sm_result(), ois_encode_submit_sm_invoke(), ois_expand_gsm7_to_bits(), ois_ignore_protocol_id(), ois_ignore_smsc_reference_number(), ois_ignore_time(), ois_increment_counter(), ois_int_to_i4(), ois_open(), ois_open_listener(), ois_open_receiver(), ois_open_sender(), ois_pending_smsmessage(), ois_read_into_buffer(), ois_receive_msg(), ois_reopen(), ois_submit_msg(), ois_submit_sm_invoke(), ois_submit_sm_result(), and ois_swap_buffering().

SAY2

#define SAY2	(		d,
			s,
			t
	)		{ if (d<=ois_debug_level) debug("bb.sms.ois",0,s,t); }

Definition at line 142 of file smsc_ois.c.

Referenced by ois_convert_from_ia5(), ois_convert_to_ia5(), ois_convert_to_iso88591(), ois_disconnect(), ois_disconnect_all(), ois_expand_gsm7(), ois_expand_gsm7_from_bits(), ois_extract_line_from_buffer(), ois_extract_msg_from_buffer(), ois_open_listener(), ois_open_receiver(), and ois_open_sender().

SAY3

#define SAY3	(		d,
			s,
			t,
			u
	)		{ if (d<=ois_debug_level) debug("bb.sms.ois",0,s,t,u); }

Definition at line 143 of file smsc_ois.c.

Typedef Documentation

ois_listentry

typedef struct ois_listentry ois_listentry

Enumeration Type Documentation

dcs_body_type

enum dcs_body_type

Enumerator
DCS_GSM_TEXT
DCS_OCTET_DATA

Definition at line 128 of file smsc_ois.c.

                   {
    DCS_GSM_TEXT = 0,
    DCS_OCTET_DATA = 4    /* flag_8bit */
};

Function Documentation

ois_adjust_additional_information()

static int ois_adjust_additional_information ( Msg *  msg, const char *  raw  )

static

Definition at line 1251 of file smsc_ois.c.

References msg, and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    SAY(3, "ois_adjust_additional_information");

    /* we're using this variable temporarily: 
     * ois_adjust_sm_text will set the correct value */
    msg->sms.mclass = raw[0] & 0xff;

    return 1;
}

ois_adjust_data_coding_scheme()

static int ois_adjust_data_coding_scheme ( Msg *  msg, const char *  raw  )

static

Definition at line 1232 of file smsc_ois.c.

References msg, and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    SAY(3, "ois_adjust_data_coding_scheme");

    /* we're using this variable temporarily: 
     * ois_adjust_sm_text will set the correct value */

    msg->sms.coding = (raw[0] & 0xff) + 1;

    return 1;
}

ois_adjust_destination_address()

static int ois_adjust_destination_address ( Msg *  msg, const char *  raw  )

static

Definition at line 1191 of file smsc_ois.c.

References msg, octstr_create_from_data, and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    int len;

    SAY(3, "ois_adjust_destination_address");

    len = raw[0] & 0xff;
    msg->sms.receiver = octstr_create_from_data(&raw[1+2], len-2);

    return 1 + len;
}

ois_adjust_originating_address()

static int ois_adjust_originating_address ( Msg *  msg, const char *  raw  )

static

Definition at line 1220 of file smsc_ois.c.

References msg, octstr_create_from_data, and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    int len;

    SAY(3, "ois_adjust_originating_address");

    len = raw[0] & 0xff;
    msg->sms.sender = octstr_create_from_data(&raw[1+2], len-2);

    return 1 + len;
}

ois_adjust_sm_text()

static int ois_adjust_sm_text ( Msg *  msg, const char *  raw  )

static

Definition at line 1262 of file smsc_ois.c.

References BUFLEN, DC_7BIT, DC_8BIT, IOTRACE, MC_UNDEF, msg, octstr_create, octstr_create_from_data, octstr_get_cstr, octstr_len(), ois_convert_to_iso88591(), ois_expand_gsm7(), and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    int msglen7, msglen8;
    char buffer[BUFLEN+1];

    SAY(3, "ois_adjust_sm_text");

    /* calculate lengths */

    msglen7 = raw[0] & 0xff;
    msglen8 = raw[1] & 0xff;

    /* copy text, note: flag contains temporarily the raw type description */

    switch ((msg->sms.coding - 1) & 0xff) { 
    case 0x00: /* gsm7 */
    ois_expand_gsm7(buffer, &raw[2], msglen7);
    ois_convert_to_iso88591(buffer, msglen7);
    if (msg->sms.mclass & 0x02) { /* XXX mclass temporarily */
        msg->sms.msgdata = octstr_create("");
        msg->sms.udhdata = octstr_create_from_data(buffer, msglen7);
    } else {
        msg->sms.msgdata = octstr_create_from_data(buffer, msglen7);
        msg->sms.udhdata = octstr_create("");
    }
    msg->sms.coding = DC_7BIT;
    break;
    case 0x0f: /* ia5 */
    memcpy(buffer, &raw[2], msglen8);
    ois_convert_to_iso88591(buffer, msglen8);
    if (msg->sms.mclass & 0x02) { /* XXX mclass temporarily */
        msg->sms.msgdata = octstr_create("");
        msg->sms.udhdata = octstr_create_from_data(buffer, msglen8);
    } else {
        msg->sms.msgdata = octstr_create_from_data(buffer, msglen8);
        msg->sms.udhdata = octstr_create("");
    }
    msg->sms.coding = DC_7BIT;
    break;
    default: /* 0xf4, 0xf5, 0xf6, 0xf7; 8bit to disp, mem, sim or term */ 
    if (msg->sms.mclass & 0x02) { /* XXX mclass temporarily */
        msg->sms.msgdata = octstr_create("");
        msg->sms.udhdata = octstr_create_from_data(&raw[2], msglen8);
    } else {
        msg->sms.msgdata = octstr_create_from_data(&raw[2], msglen8);
        msg->sms.udhdata = octstr_create("");
    }
    msg->sms.coding = DC_8BIT;
    break;
    }
    msg->sms.mclass = MC_UNDEF;

    if (octstr_len(msg->sms.udhdata)) {
    IOTRACE("decoded udh", octstr_get_cstr(msg->sms.udhdata),
        octstr_len(msg->sms.udhdata));
    } else {
    IOTRACE("decoded", octstr_get_cstr(msg->sms.msgdata),
        octstr_len(msg->sms.msgdata));
    }

    return 2 + msglen8;
}

ois_append_data_coding_scheme()

static int ois_append_data_coding_scheme ( char *  raw, const Msg *  msg  )

static

Definition at line 944 of file smsc_ois.c.

References DC_8BIT, DCS_OCTET_DATA, msg, and SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_data_coding_scheme");

    /* 0x0f is a special code for ASCII text, the SMSC will convert
     * this to GSM and set the DCS to 0.
     * FIXME: Convert to GSM ourselves and use DCS_GSM_TEXT.
     * FIXME: use fields_to_dcs and try to support DC_UCS2 too ;) */
    raw[0] = (char) (msg->sms.coding == DC_8BIT ? DCS_OCTET_DATA : 0x0f);
    return 1;
}

ois_append_msisdn()

static int ois_append_msisdn ( char *  raw, const Msg *  msg  )

static

Definition at line 894 of file smsc_ois.c.

References msg, octstr_get_cstr, octstr_len(), and SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    int len;

    SAY(3, "ois_append_msisdn");

    len = octstr_len(msg->sms.receiver);
    raw[0] = (char) len;
    memcpy(&raw[1], octstr_get_cstr(msg->sms.receiver), len);
    return 1 + len;
}

ois_append_originating_address()

static int ois_append_originating_address ( char *  raw )

static

Definition at line 924 of file smsc_ois.c.

References SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_originating_address");

    raw[0] = (char) 2; /* length */
    raw[1] = 'A'; /* A3=address type, actual address is unnecessary */
    raw[2] = '3';

    return 3;
}

ois_append_priority()

static int ois_append_priority ( char *  raw )

static

Definition at line 916 of file smsc_ois.c.

References SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_priority");

    raw[0] = (char) 1; /* 0=high, 1=normal */
    return 1;
}

ois_append_protocol_id()

static int ois_append_protocol_id ( char *  raw )

static

Definition at line 964 of file smsc_ois.c.

References SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_protocol_id");

    raw[0] = (char) 0; /* 0=default */
    return 1;
}

ois_append_sm_text()

static int ois_append_sm_text ( char *  raw, const Msg *  msg  )

static

Definition at line 988 of file smsc_ois.c.

References charset_utf8_to_gsm(), DC_7BIT, DC_UNDEF, IOTRACE, msg, octstr_get_cstr, octstr_len(), and SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    int udhlen7, udhlen8;
    int msglen7, msglen8;
    int len;

    SAY(3, "ois_append_sm_text");

    if (msg->sms.coding == DC_7BIT || msg->sms.coding == DC_UNDEF) {
        charset_utf8_to_gsm(msg->sms.udhdata);
        charset_utf8_to_gsm(msg->sms.msgdata);
    }


    /* calculate lengths */

    udhlen8 = octstr_len(msg->sms.udhdata);
    msglen8 = octstr_len(msg->sms.msgdata);

    udhlen7 = udhlen8;
    msglen7 = msglen8;
    len = udhlen8 + msglen8;

    /* copy text */

    raw[0] = (char) (len);
    raw[1] = (char) (udhlen7 + msglen7);
    memcpy(&raw[2], octstr_get_cstr(msg->sms.udhdata), udhlen8);
    memcpy(&raw[2+udhlen8], octstr_get_cstr(msg->sms.msgdata), msglen8);

    IOTRACE("encoding", &raw[2], len);

    return 2 + len;
}

ois_append_sme_reference_number()

static int ois_append_sme_reference_number ( char *  raw )

static

Definition at line 906 of file smsc_ois.c.

References ois_counter, ois_int_to_i4(), and SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_sme_reference_number");

    /* 1=key, 2=not key (OIS 4.5) */
    /* or 1=reject duplicates, 2=allow duplicates (OIS 5.0) */
    raw[0] = (char) 2;
    return 1 + ois_int_to_i4(&raw[1], ois_counter);
}

ois_append_status_report_request()

static int ois_append_status_report_request ( char *  raw )

static

Definition at line 956 of file smsc_ois.c.

References SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_status_report_request");

    raw[0] = (char) 0x00; /* bit field, bit 0=abandoned, bit 2=delivered */
    return 1;
}

ois_append_submission_options()

static int ois_append_submission_options ( char *  raw, const Msg *  msg  )

static

Definition at line 972 of file smsc_ois.c.

References DC_8BIT, msg, octstr_len(), and SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_submission_options");

    /* bit field, bit 0=reply path, bit 1=udh, bits 3-4=dcs interpretation */
    raw[0] = (char) 0x00;
    if (octstr_len(msg->sms.udhdata)) {
    raw[0] |= (char) 0x02;
    }
    if (msg->sms.coding == DC_8BIT) { /* XXX and UCS-2? */
    raw[0] |= (char) 0x10;
    }
    return 1;
}

ois_append_to_list()

static void ois_append_to_list ( ois_listentry **  head, Msg *  msg  )

static

Definition at line 764 of file smsc_ois.c.

References msg, ois_listentry::msg, ois_listentry::next, and SAY.

Referenced by ois_deliver_sm_invoke().

{
    ois_listentry *item;
    ois_listentry *tail;

    SAY(2, "ois_append_to_list");

    item = gw_malloc(sizeof(ois_listentry));
    item->next = NULL;
    item->msg = msg;

    if (*head == NULL) {
    *head = item;
    } else { /* not so bright algorithm, but ok with relatively short lists */
    for (tail = *head; tail->next != NULL; tail = tail->next) ;
    tail->next = item;
    }
    return;
}

ois_append_validity_period()

static int ois_append_validity_period ( char *  raw )

static

Definition at line 935 of file smsc_ois.c.

References SAY.

Referenced by ois_encode_submit_sm_invoke().

{
    SAY(3, "ois_append_validity_period");

    raw[0] = (char) 2; /* 0=none, 1=absolute, 2=relative */
    raw[1] = (char) 1; /* relative, (v+1)*5 minutes, v<144 */
    return 2;
}

ois_check_deliver_sm_invoke()

static int ois_check_deliver_sm_invoke ( const char *  str )

static

Definition at line 1153 of file smsc_ois.c.

References BUFLEN, EOL, error(), and SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    int buflen;
    char buffer[BUFLEN+1];
    int count;

    SAY(3, "ois_check_deliver_sm_invoke");

    /* check the (initial) header and trailer */

    buflen = strlen(str) - 1;
    if (buflen < 7 || str[0] != 'M' || (str[1] & 0x50) != 0x50
    || str[buflen] != EOL) {
    goto error;
    }

    count = str[1] & 0x0f;
    while (--count >= 0)
    {
    /* check the additional header */

    sprintf(buffer, "%c%c%c%.4s",
        EOL,
        'M',                      /* deliver sm invoke */
        (char)(0x60|count),       /* ia5 encoding, additional part */
        &str[2]);
    if (strstr(str, buffer) == NULL) {
        goto error;
    }
    }

    return 0;
    
 error:
    return -1;
}

ois_check_incoming()

static int ois_check_incoming ( SMSCenter *  smsc, long  wait_usec  )

static

Definition at line 721 of file smsc_ois.c.

References debug(), error(), OIS_FLAG_ERROR, OIS_FLAG_MULTIPLE_CALL, SMSCenter::ois_flags, SMSCenter::ois_listening_socket, ois_open_receiver(), SAY, and SMSCenter::socket.

Referenced by ois_pending_smsmessage().

{
    fd_set read_fd;
    struct timeval tv;
    int ret;

    SAY(8, "ois_check_incoming");

    tv.tv_sec = 0;
    tv.tv_usec = wait_usec;

    FD_ZERO(&read_fd);
    FD_SET(smsc->ois_listening_socket, &read_fd);
    ret = select(smsc->ois_listening_socket + 1, &read_fd, NULL, NULL, &tv);
    if (ret == -1) {
    if (errno == EINTR || errno == EAGAIN) {
        return 0;
    } else {
        error(errno, "ois_check_incoming: select failed");
        smsc->ois_flags |= OIS_FLAG_ERROR;
        return -1;
    }
    } else if (ret == 0) {
    return 0;
    }

    /* if we end up here, someone is trying to connect */

    if (smsc->socket != -1) {
    if ((smsc->ois_flags & OIS_FLAG_MULTIPLE_CALL) == 0) {
        /* if you see lots of these, maybe we should accept */
        /* multiple incoming connections at a time... */
        debug("bb.sms.ois", 0, "letting an incoming call to wait until the old one disconnects");
        smsc->ois_flags |= OIS_FLAG_MULTIPLE_CALL;
    }
    return 0;
    }

    smsc->ois_flags &= ~OIS_FLAG_MULTIPLE_CALL;
    return ois_open_receiver(smsc);
}

ois_check_input()

static int ois_check_input ( SMSCenter *  smsc, long  wait_usec  )

static

Definition at line 644 of file smsc_ois.c.

References BUFLEN, debug(), error(), IOTRACE, SMSCenter::ois_ack_debt, SMSCenter::ois_alive, ois_debug_str(), ois_deliver_sm_invoke(), ois_deliver_sm_result(), ois_disconnect(), ois_extract_msg_from_buffer(), OIS_FLAG_ERROR, SMSCenter::ois_flags, OIS_MESSAGE_WAITTIME, ois_read_into_buffer(), SMSCenter::ois_received_mo, ois_submit_sm_result(), SAY, SMSCenter::socket, and warning().

Referenced by ois_pending_smsmessage().

{
    char buffer[BUFLEN+1];
    time_t now;
    int ret;

    SAY(8, "ois_check_input");

    ret = ois_read_into_buffer(smsc, wait_usec);
    if (ret < 0) {
    goto error;
    }

    ret = ois_extract_msg_from_buffer(buffer, smsc);
    if (ret > 0) {
    IOTRACE("received", buffer, ret);
    switch (buffer[0]) {
    case 's':
        ret = ois_submit_sm_result(smsc, buffer);
        if (ret > 0) {
        warning(0, "ois_check_input: submit sm result signals (%d)...", ret);
        } else if (ret < 0) {
        error(0, "ois_check_input: invalid submit sm result");
        goto error;
        }
        --smsc->ois_ack_debt;
        time(&smsc->ois_alive);
        break;
    case 'M':
        ret = ois_deliver_sm_invoke(smsc, buffer);
        if (ret >= 0) {
        ret = ois_deliver_sm_result(smsc, ret, buffer);
        if (ret < 0) {
            goto error;
        }
        } else {
        error(0, "ois_check_input: invalid deliver sm invoke");
        goto error;
        }
        time(&smsc->ois_alive);
        break;
    default:
        warning(0, "ois_check_input: unexpected message [%s]...",
            ois_debug_str(buffer, ret));
        break;
    }
    } else {
    if (smsc->socket != -1) {
        time(&now);
        if ((now - smsc->ois_alive) > OIS_MESSAGE_WAITTIME) {
        debug("bb.sms.ois", 0, "closing an idle connection");
        SAY(4, "ois_check_input: ois_disconnect");
        ois_disconnect(smsc);
        }
    }
    }

    if (ret < 0) {
    error(0, "ois_check_input: malformatted message [%s]",
          ois_debug_str(buffer, -ret));
    goto error;
    }

    if (smsc->ois_received_mo != NULL ||
    (smsc->ois_flags & OIS_FLAG_ERROR) != 0) {
    SAY(2, "ois_check_input has something");
    return 1; /* at least one message in the queue or an error pending */
    } else {
    return 0; /* no messages this time */
    }

 error:
    smsc->ois_flags |= OIS_FLAG_ERROR;
    return 1;
}

ois_close()

int ois_close

(

SMSCenter *

smsc

)

Definition at line 263 of file smsc_ois.c.

References SMSCenter::buflen, ois_debug_level, ois_disconnect_all(), OIS_FLAG_DEBUG, SMSCenter::ois_flags, ois_swap_buffering(), SAY, SMSC_TYPE_OIS, smscenter_remove_from_buffer(), SMSCenter::type, and warning().

Referenced by ois_open_listener(), ois_reopen(), and smsc_close().

{
    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(2, "ois_close");

    if (smsc->type != SMSC_TYPE_OIS) {
    warning(0, "ois_close: closing a not-ois connection...");
    }

    ois_swap_buffering(smsc);
    smscenter_remove_from_buffer(smsc, smsc->buflen);
    ois_swap_buffering(smsc);
    smscenter_remove_from_buffer(smsc, smsc->buflen);
    SAY(4, "ois_close: ois_disconnect_all");
    ois_disconnect_all(smsc);

    return 0;
}

ois_convert_from_ia5()

static int ois_convert_from_ia5 ( char *  raw, const char *  str  )

static

Definition at line 1483 of file smsc_ois.c.

References ois_debug_str(), SAY, and SAY2.

Referenced by ois_decode_deliver_sm_invoke(), and ois_decode_submit_sm_result().

{
    int j;
    int i;
    int ch;

    SAY(3, "ois_convert_from_ia5");

    for (j = i = 0; ; ++i) {
    ch = str[i] & 0xff;
    if (ch < 0x20 || 0x7f <= ch) {
        break;
    } else if (ch == 0x5c) {
        ch = str[++i] & 0xff;
        if (ch == 0x5c || ch == 0x5e || ch == 0x60 || ch == 0x7e) {
        raw[j++] = (char) ch;
        } else {
        break;
        }
    } else if (ch == 0x5e) {
        ch = str[++i] & 0xff;
        if (0x40 <= ch && ch < 0x60) {
        raw[j++] = (char) ch - 0x40;
        } else if (ch == 0x7e) {
        raw[j++] = (char) 0x7f;
        } else {
        break;
        }
    } else if (ch == 0x60) {
        ch = str[++i] & 0xff;
        if (0x20 <= ch && ch < 0x7f) {
        raw[j++] = (char) ch + 0x80;
        } else {
        break;
        }
    } else if (ch == 0x7e) {
        ch = str[++i] & 0xff;
        if (0x40 <= ch && ch < 0x60) {
        raw[j++] = (char) ch + 0x40;
        } else if (ch == 0x7e) {
        raw[j++] = (char) 0xff;
        } else {
        break;
        }
    } else { /* 0x20 <= ch && ch < 0x7f */
        raw[j++] = (char) ch;
    }
    }

    SAY2(5, "ois_convert_from_ia5 gave [%s]", ois_debug_str(raw, j));
    return j;
}

ois_convert_to_ia5()

static int ois_convert_to_ia5 ( char *  str, const char *  raw, int  len  )

static

Definition at line 1444 of file smsc_ois.c.

References ois_debug_str(), and SAY2.

Referenced by ois_encode_deliver_sm_result(), and ois_encode_submit_sm_invoke().

{
    int j;
    int i;
    int ch;

    SAY2(3, "ois_convert_to_ia5 len=%d", len);

    for (j = i = 0; i < len; ++i) {
    ch = raw[i] & 0xff;
    if (ch == 0x5c || ch == 0x5e || ch == 0x60 || ch == 0x7e) {
        str[j++] = (char) 0x5c;
        str[j++] = (char) ch;
    } else if (0x20 <= ch && ch < 0x7f) {
        str[j++] = (char) ch;
    } else if (0x00 <= ch && ch < 0x20) {
        str[j++] = (char) 0x5e;
        str[j++] = (char) ch + 0x40;
    } else if (0xa0 <= ch && ch < 0xff) {
        str[j++] = (char) 0x60;
        str[j++] = (char) ch - 0x80;
    } else if (0x80 <= ch && ch < 0xa0) {
        str[j++] = (char) 0x7e;
        str[j++] = (char) ch - 0x40;
    } else if (ch == 0x7f) {
        str[j++] = (char) 0x5e;
        str[j++] = (char) 0x7e;
    } else { /* ch == 0xff */
        str[j++] = (char) 0x7e;
        str[j++] = (char) 0x7e;
    }
    }

    str[j] = '\0';
    SAY2(5, "ois_convert_to_ia5 gave [%s]", ois_debug_str(str, j));
    return j;
}

ois_convert_to_iso88591()

static int ois_convert_to_iso88591 ( char *  raw, int  len  )

static

Definition at line 1537 of file smsc_ois.c.

References ois_debug_str(), and SAY2.

Referenced by ois_adjust_sm_text().

{
    /* a best effort 1-to-1 conversion according to ois appendix a */

    static const char gsm_to_iso88591[] = {
    '@', 0xa3,'$', 0xa5,0xe8,0xe9,0xf9,0xec, /* 0x00 - 0x07 */
    0xf2,0xc7,'\n',0xd8,0xf8,'\r',0xc5,0xe5, /* 0x08 - 0x0f */
    'D', ' ', 'F', 'G', 'L', 'W', 'P', 'Y',  /* 0x10 - 0x17, poor! */
    'Y', 'S', 'X', ' ', 0xc6,0xe6,'b', 0xc9, /* 0x18 - 0x1f, poor! */
    ' ', '!', '"', '#', 0xa4, '%', '&', '\'',/* 0x20 - 0x27 */
    '(', ')', '*', '+', ',', '-', '.', '/',  /* 0x28 - 0x2f */
    '0', '1', '2', '3', '4', '5', '6', '7',  /* 0x30 - 0x37 */
    '8', '9', ':', ';', '<', '=', '>', '?',  /* 0x38 - 0x3f */
    0xa1,'A', 'B', 'C', 'D', 'E', 'F', 'G',  /* 0x40 - 0x47 */
    'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O',  /* 0x48 - 0x4f */
    'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W',  /* 0x50 - 0x57 */
    'X', 'Y', 'Z', 0xc4,0xd6,0xd1,0xdc,0xa7, /* 0x58 - 0x5f */
    0xbf,'a', 'b', 'c', 'd', 'e', 'f', 'g',  /* 0x60 - 0x67 */
    'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o',  /* 0x68 - 0x6f */
    'p', 'q', 'r', 's', 't', 'u', 'v', 'w',  /* 0x70 - 0x77 */
    'x', 'y', 'z', 0xe4,0xf6,0xf1,0xfc,0xe0  /* 0x78 - 0x7f */
    };

    int i;

    SAY2(3, "ois_convert_to_iso88591 len=%d", len);

    for (i = 0; i < len; ++i) {
    raw[i] = gsm_to_iso88591[raw[i] & 0x7f];
    }

    SAY2(5, "ois_convert_to_iso88591 gave [%s]", ois_debug_str(raw, i));
    return i;
}

ois_debug_str()

static const char * ois_debug_str ( const char *  raw, int  len  )

static

Definition at line 1709 of file smsc_ois.c.

References BUFLEN.

Referenced by ois_check_input(), ois_convert_from_ia5(), ois_convert_to_ia5(), ois_convert_to_iso88591(), ois_expand_gsm7(), and ois_open_sender().

{
    static const char hex[] = "0123456789abcdef";
    static char str[4*(BUFLEN+1)+1];
    int pos;
    int ch;
    int i;

    pos = 0;
    for (i = 0; i < len; ++i) {
    ch = raw[i] & 0xff;
    if (0x20 <= ch && ch < 0x7f && ch != 0x5c) {
        str[pos++] = (char) ch;
    } else {
        str[pos++] = '\\';
        str[pos++] = 'x';
        str[pos++] = hex[ch/16];
        str[pos++] = hex[ch%16];
    }
    }
    str[pos] = '\0';
    return str;
}

ois_decode_deliver_sm_invoke()

static int ois_decode_deliver_sm_invoke ( Msg *  msg, const char *  str  )

static

Definition at line 1099 of file smsc_ois.c.

References BUFLEN, EOL, error(), msg, ois_adjust_additional_information(), ois_adjust_data_coding_scheme(), ois_adjust_destination_address(), ois_adjust_originating_address(), ois_adjust_sm_text(), ois_check_deliver_sm_invoke(), ois_convert_from_ia5(), ois_ignore_protocol_id(), ois_ignore_smsc_reference_number(), ois_ignore_time(), and SAY.

Referenced by ois_deliver_sm_invoke().

{
    char body[BUFLEN+1];
    char raw[BUFLEN];
    int len;
    int i;
    int pos;
    int ret;

    SAY(3, "ois_decode_deliver_sm_invoke");

    ret = ois_check_deliver_sm_invoke(str);
    if (ret < 0) {
    goto error;
    }

    /* extract body */

    len = strlen(str);
    for (pos = 0, i = 6; i < len; ++i) {
    if (str[i] != EOL) {
        body[pos++] = str[i];
    } else {
        i += 6;
    }
    }
    body[pos] = '\0';
    memset(raw, '\0', sizeof(raw));
    len = ois_convert_from_ia5(raw, body);

    /* adjust msg values */

    pos = 0;
    pos += ois_adjust_destination_address(msg, &raw[pos]);
    pos += ois_ignore_smsc_reference_number(&raw[pos]);
    pos += ois_adjust_originating_address(msg, &raw[pos]);
    pos += ois_adjust_data_coding_scheme(msg, &raw[pos]);
    pos += ois_ignore_protocol_id(&raw[pos]);
    pos += ois_adjust_additional_information(msg, &raw[pos]);
    pos += ois_adjust_sm_text(msg, &raw[pos]);
    pos += ois_ignore_time(&raw[pos]); /* accept time */
    pos += ois_ignore_time(&raw[pos]); /* invoke time */
    if (pos != len) {
    error(0, "ois_decode_deliver_sm_invoke: message parsing error (%d!=%d)",
          pos, len);
    goto error;
    }
    return 0;

 error:
    return -1;
}

ois_decode_submit_sm_result()

static int ois_decode_submit_sm_result ( int *  code, const char *  str  )

static

Definition at line 1043 of file smsc_ois.c.

References BUFLEN, code, EOL, error(), ois_convert_from_ia5(), and SAY.

Referenced by ois_submit_sm_result().

{
    int buflen;
    char raw[BUFLEN];
    int len;

    SAY(3, "ois_decode_submit_sm_result");

    buflen = strlen(str) - 1;
    if (buflen < 7 || str[0] != 's' || str[1] != 0x50 || str[buflen] != EOL) {
    goto error;
    }

    len = ois_convert_from_ia5(raw, &str[6]);
    if (len <= 0) {
    goto error;
    }

    *code = raw[0];
    *code &= 0xff;

    /* there is smsc reference number and accept time, but we ignore them */

    return 0;

 error:
    return -1;
}

ois_delete_queue()

void ois_delete_queue

(

SMSCenter *

smsc

)

Definition at line 423 of file smsc_ois.c.

References msg, ois_debug_level, OIS_FLAG_DEBUG, SMSCenter::ois_flags, ois_receive_msg(), and SAY.

Referenced by smscenter_destruct().

{
    Msg *msg;

    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(2, "ois_delete_queue");

    while (ois_receive_msg(smsc, &msg) > 0) {
    gw_free(msg);
    }
    return;
}

ois_deliver_sm_invoke()

static int ois_deliver_sm_invoke ( SMSCenter *  smsc, const char *  buffer  )

static

Definition at line 1073 of file smsc_ois.c.

References error(), mo, msg, msg_create, msg_destroy(), ois_append_to_list(), ois_decode_deliver_sm_invoke(), SMSCenter::ois_received_mo, and SAY.

Referenced by ois_check_input().

{
    Msg *msg;
    int ret;
    ois_listentry **mo;
    
    SAY(2, "ois_deliver_sm_invoke");

    msg = msg_create(sms);

    ret = ois_decode_deliver_sm_invoke(msg, buffer);
    if (ret < 0) {
    goto error;
    }

    mo = (ois_listentry **)&smsc->ois_received_mo;
    ois_append_to_list(mo, msg);

    return 0;
    
 error:
    msg_destroy(msg);
    return -1;
}

ois_deliver_sm_result()

static int ois_deliver_sm_result ( SMSCenter *  smsc, int  result, const char *  str  )

static

Definition at line 1339 of file smsc_ois.c.

References BUFLEN, EOL, error(), IOTRACE, ois_encode_deliver_sm_result(), SAY, SMSCenter::socket, and write_to_socket().

Referenced by ois_check_input().

{
    char body[BUFLEN+1];
    char buffer[BUFLEN+1];
    int ret;

    SAY(2, "ois_deliver_sm_result");

    /* construct a message */

    ois_encode_deliver_sm_result(body, result);

    /* first and only part */

    sprintf(buffer, "%c%c%.4s%.121s%c",
        'm',                              /* deliver sm result */
        (char)(0x50),                     /* ia5 encoding, the only part */
        &str[2],
        &body[0],
        EOL);

    IOTRACE("sending", buffer, strlen(buffer));
    ret = write_to_socket(smsc->socket, buffer);
    if (ret < 0) {
    goto error;
    }

    return 0;

 error:
    return -1;
}

ois_disconnect()

static void ois_disconnect ( SMSCenter *  smsc )

static

Definition at line 595 of file smsc_ois.c.

References SAY2, SMSCenter::socket, and warning().

Referenced by ois_check_input(), ois_disconnect_all(), ois_open_sender(), ois_read_into_buffer(), and ois_submit_msg().

{
    SAY2(2, "ois_disconnect fd=%d", smsc->socket);

    if (smsc->socket != -1) {
    if (close(smsc->socket) == -1) {
        warning(errno, "ois_disconnect: close failed...");
    }
    smsc->socket = -1;
    }
    return;
}

ois_disconnect_all()

static void ois_disconnect_all ( SMSCenter *  smsc )

static

Definition at line 574 of file smsc_ois.c.

References ois_disconnect(), SMSCenter::ois_listening_socket, ois_swap_buffering(), SAY, SAY2, and warning().

Referenced by ois_close().

{
    SAY2(2, "ois_disconnect_all fd=%d", smsc->ois_listening_socket);

    ois_swap_buffering(smsc);
    SAY(4, "ois_disconnect_all: ois_disconnect");
    ois_disconnect(smsc); /* smsc->socket */
    ois_swap_buffering(smsc);
    SAY(4, "ois_disconnect_all: ois_disconnect");
    ois_disconnect(smsc); /* smsc->socket */

    if (smsc->ois_listening_socket != -1) {
    if (close(smsc->ois_listening_socket) == -1) {
        warning(errno, "ois_disconnect_all: close failed...");
    }
    smsc->ois_listening_socket = -1;
    }
    return;
}

ois_encode_deliver_sm_result()

static int ois_encode_deliver_sm_result ( char *  str, int  result  )

static

Definition at line 1373 of file smsc_ois.c.

References ois_convert_to_ia5(), and SAY.

Referenced by ois_deliver_sm_result().

{
    char raw[4];

    SAY(3, "ois_encode_deliver_sm_result");

    /* construct the deliver sm result body content */

    raw[0] = (char) result;

    return ois_convert_to_ia5(str, raw, 1);
}

ois_encode_submit_sm_invoke()

static int ois_encode_submit_sm_invoke ( char *  str, const Msg *  msg  )

static

Definition at line 868 of file smsc_ois.c.

References BUFLEN, msg, ois_append_data_coding_scheme(), ois_append_msisdn(), ois_append_originating_address(), ois_append_priority(), ois_append_protocol_id(), ois_append_sm_text(), ois_append_sme_reference_number(), ois_append_status_report_request(), ois_append_submission_options(), ois_append_validity_period(), ois_convert_to_ia5(), and SAY.

Referenced by ois_submit_sm_invoke().

{
    char raw[BUFLEN];
    int pos;
    int ret;

    SAY(3, "ois_encode_submit_sm_invoke");

    /* construct the submit sm invoke body content */

    pos = 0;
    pos += ois_append_msisdn(&raw[pos], msg);
    pos += ois_append_sme_reference_number(&raw[pos]);
    pos += ois_append_priority(&raw[pos]);
    pos += ois_append_originating_address(&raw[pos]);
    pos += ois_append_validity_period(&raw[pos]);
    pos += ois_append_data_coding_scheme(&raw[pos], msg);
    pos += ois_append_status_report_request(&raw[pos]);
    pos += ois_append_protocol_id(&raw[pos]);
    pos += ois_append_submission_options(&raw[pos], msg);
    pos += ois_append_sm_text(&raw[pos], msg);

    ret = ois_convert_to_ia5(str, raw, pos);
    return ret;
}

ois_expand_gsm7()

static int ois_expand_gsm7 ( char *  raw8, const char *  raw7, int  len  )

static

Definition at line 1387 of file smsc_ois.c.

References BUFLEN, ois_debug_str(), ois_expand_gsm7_from_bits(), ois_expand_gsm7_to_bits(), and SAY2.

Referenced by ois_adjust_sm_text().

{
    int i;
    char bits[8*(BUFLEN+1)];

    SAY2(3, "ois_expand_gsm7 len=%d", len);

    /* yeah, there are also better algorithms, but... */
    /* well, at least this is fairly portable and ok for small messages... */

    ois_expand_gsm7_to_bits(bits, raw7, len);
    for (i = 0; i < len; ++i) {
    raw8[i] = ois_expand_gsm7_from_bits(bits, i);
    }

    SAY2(5, "ois_expand_gsm7 gave [%s]", ois_debug_str(raw8, i));
    return i;
}

ois_expand_gsm7_from_bits()

static char ois_expand_gsm7_from_bits ( const char *  bits, int  pos  )

static

Definition at line 1426 of file smsc_ois.c.

References SAY2.

Referenced by ois_expand_gsm7().

{
    int i;
    char ch;

    SAY2(8, "ois_expand_gsm7_from_bits pos=%d", pos);

    pos *= 7; /* septet position in bits */
    ch = '\0';
    for (i = 6; i >= 0; --i) {
    ch <<= 1;
    ch |= bits[pos+i];
    }

    return ch;
}

ois_expand_gsm7_to_bits()

static int ois_expand_gsm7_to_bits ( char *  bits, const char *  raw7, int  len  )

static

Definition at line 1406 of file smsc_ois.c.

References SAY.

Referenced by ois_expand_gsm7().

{
    int i, j, k;
    char ch;

    SAY(3, "ois_expand_gsm7_to_bits");

    len *= 7; /* number of bits in the gms 7-bit msg */

    for (j = i = 0; j < len; ++i) {
    ch = raw7[i];
    for (k = 0; k < 8; ++k) {
        bits[j++] = (char) (ch & 0x01);
        ch >>= 1;
    }
    }

    return j;
}

ois_extract_line_from_buffer()

static int ois_extract_line_from_buffer ( char *  str, SMSCenter *  smsc  )

static

Definition at line 1641 of file smsc_ois.c.

References SMSCenter::buffer, SMSCenter::buflen, SAY2, and smscenter_remove_from_buffer().

Referenced by ois_open_sender().

{
    int len;

    SAY2(3, "ois_extract_line_from_buffer buflen=%ld", (long)smsc->buflen);

    str[0] = '\0';

    for (len = 0; (size_t) len < smsc->buflen && smsc->buffer[len] != '\n'; 
         ++len) ;

    if ((size_t) len >= smsc->buflen) {
    return 0;
    } else {
    ++len;
    }

    /* the buffer contains a line */

    memcpy(str, smsc->buffer, len);
    str[len] = '\0';
    smscenter_remove_from_buffer(smsc, len); /* just the line */

    return len;
}

ois_extract_msg_from_buffer()

static int ois_extract_msg_from_buffer ( char *  str, SMSCenter *  smsc  )

static

Definition at line 1577 of file smsc_ois.c.

References SMSCenter::buffer, BUFLEN, SMSCenter::buflen, EOL, error(), SAY2, and smscenter_remove_from_buffer().

Referenced by ois_check_input().

{
    int len;
    int count;

    SAY2(8, "ois_extract_msg_from_buffer buflen=%ld", (long)smsc->buflen);

    str[0] = '\0';

    if (smsc->buflen < 7) {             /* 7 = 6 + 1 */
    return 0;              /* we don't have a message yet */
    }

    if (strchr("SRDATECQLMPOVsrdatecqlmpov", smsc->buffer[0]) == NULL
    || (smsc->buffer[1] & 0xf0) != 0x50) {

    goto error;
    }

    /* a valid message type, find the end of the message */

    count = smsc->buffer[1] & 0x0f;
    for (len = 0; (size_t) len < smsc->buflen; ++len) {
    if (smsc->buffer[len] == EOL) {
        if (--count < 0) {
        ++len;
        break;
        }
    }
    }

    if (count >= 0) {          /* we don't have all the pieces */
    if (len < BUFLEN) {
        return 0;          /* ...but maybe later */
    }
    goto error;
    }

    /* the buffer contains a promising message candidate */

    memcpy(str, smsc->buffer, len);
    str[len] = '\0';
    smscenter_remove_from_buffer(smsc, len); /* just the message */

    return len;

 error:
    for (len = 0; (size_t) len < smsc->buflen && smsc->buffer[len] != EOL; 
         ++len) ;
    if (len > BUFLEN) len = BUFLEN;

    memcpy(str, smsc->buffer, len);
    str[len] = '\0';
    smscenter_remove_from_buffer(smsc, smsc->buflen); /* everything */

    return -len;
}

ois_ignore_protocol_id()

static int ois_ignore_protocol_id ( const char *  raw )

static

Definition at line 1244 of file smsc_ois.c.

References SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    SAY(3, "ois_ignore_protocol_id");

    return 1;
}

ois_ignore_smsc_reference_number()

static int ois_ignore_smsc_reference_number ( const char *  raw )

static

Definition at line 1203 of file smsc_ois.c.

References SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    int value;

    SAY(3, "ois_ignore_smsc_reference_number");

    value = raw[3] & 0xff;
    value <<= 8;
    value |= raw[2] & 0xff;
    value <<= 8;
    value |= raw[1] & 0xff;
    value <<= 8;
    value |= raw[0] & 0xff;

    return 4;
}

ois_ignore_time()

static int ois_ignore_time ( const char *  raw )

static

Definition at line 1326 of file smsc_ois.c.

References SAY.

Referenced by ois_decode_deliver_sm_invoke().

{
    char str[15];

    SAY(3, "ois_ignore_time");

    strncpy(str, raw, 14); str[14] = '\0';

    return 14;
}

ois_increment_counter()

static int ois_increment_counter ( void  )

static

Definition at line 799 of file smsc_ois.c.

References MAXCOUNTER, ois_counter, and SAY.

Referenced by ois_submit_sm_invoke().

{
    SAY(3, "ois_increment_counter");

    ois_counter = (ois_counter+1) % MAXCOUNTER;
    return ois_counter;
}

ois_int_to_i4()

static int ois_int_to_i4 ( char *  raw, int  nbr  )

static

Definition at line 786 of file smsc_ois.c.

References SAY.

Referenced by ois_append_sme_reference_number().

{
    int pos;

    SAY(3, "ois_int_to_i4");

    for (pos = 0; pos < 4; ++pos) {
    raw[pos] = (char)(nbr % 0x100);
    nbr /= 0x100;
    }
    return 4;
}

ois_open()

SMSCenter* ois_open	(	int	receiveport,
		const char *	hostname,
		int	port,
		int	debug_level
	)

Definition at line 222 of file smsc_ois.c.

References error(), SMSCenter::hostname, hostname, SMSCenter::name, ois_debug_level, OIS_FLAG_DEBUG, SMSCenter::ois_flags, ois_open_listener(), port, SMSCenter::port, SMSCenter::receive_port, SAY, SMSC_TYPE_OIS, smscenter_construct(), smscenter_destruct(), and SMSCenter::type.

Referenced by smsc_open().

{
    SMSCenter *smsc;
    int ret;

    ois_debug_level = debug_level & OIS_FLAG_DEBUG;
    SAY(2, "ois_open");

    /* create a SMSCenter structure */

    smsc = smscenter_construct();
    if (smsc == NULL) {
    goto error;
    }

    smsc->type = SMSC_TYPE_OIS;
    smsc->receive_port = receiveport;
    smsc->hostname = gw_strdup(hostname);
    smsc->port = port;
    smsc->ois_flags = ois_debug_level;

    ret = ois_open_listener(smsc);
    if (ret < 0) {
    goto error;
    }
    sprintf(smsc->name, "OIS:TCP/X.25-Translator:localhost:%d:TCP:%.512s:%d",
        smsc->receive_port, smsc->hostname, smsc->port);

    return smsc;

 error:
    error(0, "ois_open: could not open");
    smscenter_destruct(smsc);
    return NULL;
}

ois_open_listener()

static int ois_open_listener ( SMSCenter *  smsc )

static

Definition at line 448 of file smsc_ois.c.

References error(), make_server_socket(), SMSCenter::ois_alive, SMSCenter::ois_alive2, ois_close(), OIS_FLAG_ERROR, OIS_FLAG_NOBANNER, SMSCenter::ois_flags, SMSCenter::ois_listening_socket, SMSCenter::receive_port, SAY, SAY2, and socket_set_blocking().

Referenced by ois_open(), and ois_reopen().

{
    SAY(2, "ois_open_listener");

    smsc->ois_listening_socket = make_server_socket(smsc->receive_port, 
            NULL);
    /* XXX add interface_name if required */
    if (smsc->ois_listening_socket < 0) {
    goto error;
    }
    if (socket_set_blocking(smsc->ois_listening_socket, 0) < 0) {
    ois_close(smsc);
    goto error;
    }
    smsc->ois_flags &= ~OIS_FLAG_ERROR;
    smsc->ois_flags &= ~OIS_FLAG_NOBANNER;
    smsc->ois_alive2 = time(&smsc->ois_alive);

    SAY2(2, "ois_open_listener fd=%d", smsc->ois_listening_socket);
    return 0;

 error:
    error(0, "ois_open_listener: failed to open listening socket");
    return -1;
}

ois_open_receiver()

static int ois_open_receiver ( SMSCenter *  smsc )

static

Definition at line 539 of file smsc_ois.c.

References debug(), error(), gw_netaddr_to_octstr(), octstr_destroy(), octstr_get_cstr, SMSCenter::ois_alive, OIS_FLAG_ERROR, SMSCenter::ois_flags, SMSCenter::ois_listening_socket, SAY, SAY2, and SMSCenter::socket.

Referenced by ois_check_incoming().

{
    struct sockaddr_in addr;
    int addrlen;
    Octstr *os;

    SAY(2, "ois_open_receiver");

    /* the listening socket should be non-blocking... */

    addrlen = sizeof(addr);
    smsc->socket = accept(smsc->ois_listening_socket,
              (struct sockaddr *)&addr, (socklen_t *)&addrlen);
    if (smsc->socket == -1) {
    if (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK)
        /* || errno == ECONNABORTED || errno == EPROTO) -Kalle 6.7 */
    {
        return 0;
    } else {
        error(errno, "ois_open_receiver: accept failed");
        smsc->ois_flags |= OIS_FLAG_ERROR;
        return -1;
    }
    }

    SAY2(2, "ois_open_receiver fd=%d", smsc->socket);
    os = gw_netaddr_to_octstr(AF_INET, &addr.sin_addr);
    debug("bb.sms.ois", 0, "connection from host %s port %hu",
      octstr_get_cstr(os), ntohs(addr.sin_port));
    octstr_destroy(os);
    time(&smsc->ois_alive);
    return 0;
}

ois_open_sender()

static int ois_open_sender ( SMSCenter *  smsc )

static

Definition at line 475 of file smsc_ois.c.

References SMSCenter::buffer, BUFLEN, SMSCenter::buflen, debug(), error(), SMSCenter::hostname, SMSCenter::ois_ack_debt, SMSCenter::ois_alive, ois_debug_str(), ois_disconnect(), ois_extract_line_from_buffer(), OIS_FLAG_NOBANNER, SMSCenter::ois_flags, OIS_OPEN_WAITTIME, ois_read_into_buffer(), OIS_WAITTIME, SMSCenter::port, SAY, SAY2, SMSCenter::socket, and tcpip_connect_to_server().

Referenced by ois_submit_msg().

{
    int ret;
    char buffer[BUFLEN+1];
    time_t now;
    time_t beginning;
    
    SAY(2, "ois_open_sender");
    debug("bb.sms.ois", 0, "connecting to host %s port %d",
      smsc->hostname, smsc->port);

    time(&beginning);
    smsc->socket = tcpip_connect_to_server(smsc->hostname, smsc->port,
            NULL);
    /* XXX add interface_name if required */
    if (smsc->socket < 0) {
    return -1;
    } else {
    smsc->buflen = 0;
    time(&smsc->ois_alive);
    smsc->ois_ack_debt = 0;
    }

    SAY2(2, "ois_open_sender fd=%d", smsc->socket);
    if (smsc->ois_flags & OIS_FLAG_NOBANNER) {
    return 0;
    }

    buffer[0] = '\0';
    for (time(&now); (now - beginning) < OIS_OPEN_WAITTIME; time(&now)) {
    ret = ois_read_into_buffer(smsc, OIS_WAITTIME);
    if (ret < 0) {
        goto error;
    }

    if (smsc->buflen == 0) {
        /* assume that the router is in the quiet mode */
        /* there will be no banners */
        smsc->ois_flags |= OIS_FLAG_NOBANNER;
        debug("bb.sms.ois", 0, "assuming that %s:%d is in the quiet mode",
          smsc->hostname, smsc->port);
        return 0;
    }
    ret = ois_extract_line_from_buffer(buffer, smsc);
    if (ret > 0) {
        if (strncmp(buffer, "Trying", 6) == 0 &&
        strstr(buffer, "...Open\r\n") != NULL) {
        time(&smsc->ois_alive);
        return 0;
        } else {
        break;
        }
    }
    }

 error:
    SAY(4, "ois_open_sender: ois_disconnect in error");
    ois_disconnect(smsc);
    error(0, "ois_open_sender: failed to connect [%s%s]",
      buffer, ois_debug_str(smsc->buffer, smsc->buflen));
    return -1;
}

ois_pending_smsmessage()

int ois_pending_smsmessage

(

SMSCenter *

smsc

)

Definition at line 318 of file smsc_ois.c.

References SMSCenter::ois_ack_debt, ois_check_incoming(), ois_check_input(), ois_debug_level, OIS_FLAG_DEBUG, SMSCenter::ois_flags, OIS_NOWAIT, SMSCenter::ois_socket, ois_swap_buffering(), SAY, SMSCenter::socket, and warning().

Referenced by smscenter_pending_smsmessage().

{
    int ret;

    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(8, "ois_pending_smsmessage");

    ret = ois_check_incoming(smsc, OIS_NOWAIT);
    if (ret == 0 && smsc->socket != -1) {
    ret = ois_check_input(smsc, OIS_NOWAIT);
    }
    if (ret == 0 && smsc->ois_socket != -1) {
    ois_swap_buffering(smsc);
    ret = ois_check_input(smsc, OIS_NOWAIT);
    ois_swap_buffering(smsc);
    if (smsc->ois_socket == -1 && smsc->ois_ack_debt != 0) {
        warning(0, "ois_pending_smsmessage: missing %d ack(s)...",
            smsc->ois_ack_debt);
    }
    }
    return ret;
}

ois_read_into_buffer()

static int ois_read_into_buffer ( SMSCenter *  smsc, long  wait_usec  )

static

Definition at line 609 of file smsc_ois.c.

References SMSCenter::buflen, debug(), SMSCenter::ois_alive, ois_disconnect(), OIS_FLAG_CLOSED, SMSCenter::ois_flags, read_available(), SAY, smscenter_read_into_buffer(), and SMSCenter::socket.

Referenced by ois_check_input(), and ois_open_sender().

{
    int ret;

    SAY(8, "ois_read_into_buffer");

    if (smsc->socket == -1) {
    if ((smsc->ois_flags & OIS_FLAG_CLOSED) == 0) {
        debug("bb.sms.ois", 0, "attempting to read from a closed socket");
        smsc->ois_flags |= OIS_FLAG_CLOSED;
    }
    return 0;
    } else {
    smsc->ois_flags &= ~OIS_FLAG_CLOSED;
    }

    ret = read_available(smsc->socket, wait_usec);
    if (ret > 0) {
    time(&smsc->ois_alive);
    ret = smscenter_read_into_buffer(smsc);
    if (ret > 0 || (ret == 0 && smsc->buflen > 0)) {
        SAY(2, "ois_read_into_buffer got something");
    } else if (ret == 0) {
        if (smsc->buflen > 0) {
        SAY(2, "ois_read_into_buffer has something");
        ret = 1;
        }
        SAY(4, "ois_read_into_buffer: ois_disconnect");
        ois_disconnect(smsc);
    }
    }
    return ret;
}

ois_receive_msg()

int ois_receive_msg	(	SMSCenter *	smsc,
		Msg **	msg
	)

Definition at line 396 of file smsc_ois.c.

References msg, ois_listentry::msg, ois_listentry::next, ois_debug_level, OIS_FLAG_DEBUG, OIS_FLAG_ERROR, SMSCenter::ois_flags, SMSCenter::ois_received_mo, and SAY.

Referenced by ois_delete_queue(), and smscenter_receive_msg().

{
    ois_listentry *item;

    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(2, "ois_receive_msg");

    item = smsc->ois_received_mo;
    if (item == NULL) { /* no mo messages */
    if ((smsc->ois_flags & OIS_FLAG_ERROR) == 0) {
        return 0;   /* should actually not happen */
    } else {
        return -1;  /* error pending, reopen? */
    }
    } else {            /* we have a message waiting */
    smsc->ois_received_mo = item->next;
    *msg = item->msg;
    gw_free(item);
    return 1;       /* got the message */
    }
}

ois_reopen()

int ois_reopen

(

SMSCenter *

smsc

)

Definition at line 287 of file smsc_ois.c.

References error(), ois_close(), ois_debug_level, OIS_FLAG_DEBUG, SMSCenter::ois_flags, ois_open_listener(), SAY, SMSC_TYPE_OIS, and SMSCenter::type.

Referenced by smsc_reopen().

{
    int ret;

    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(2, "ois_reopen");

    ois_close(smsc);

    if (smsc->type == SMSC_TYPE_OIS) {
    ret = ois_open_listener(smsc);
    if (ret < 0) {
        goto error;
    }
    } else {
    error(0, "ois_reopen: wrong smsc type");
    goto error;
    }
    return 0;

 error:
    error(0, "ois_reopen: could not open");
    return -1;
}

ois_submit_msg()

int ois_submit_msg	(	SMSCenter *	smsc,
		const Msg *	msg
	)

Definition at line 346 of file smsc_ois.c.

References error(), msg, SMSCenter::ois_ack_debt, SMSCenter::ois_alive, ois_debug_level, ois_disconnect(), OIS_FLAG_DEBUG, SMSCenter::ois_flags, ois_open_sender(), ois_submit_sm_invoke(), ois_swap_buffering(), SAY, SMSCenter::socket, and warning().

Referenced by smscenter_submit_msg().

{
    int ret;

    ois_debug_level = smsc->ois_flags & OIS_FLAG_DEBUG;
    SAY(2, "ois_submit_msg");
    ois_swap_buffering(smsc);

    if (msg_type((Msg *)msg) != sms) {
    error(0, "ois_submit_msg: can not handle message types other than smart_msg");
    goto error;
    }

    if (smsc->socket == -1) {
    ret = ois_open_sender(smsc);
    if (ret < 0) {
        goto error;
    }
    }

    ret = ois_submit_sm_invoke(smsc, msg);
    if (ret < 0) {
    goto error_close;
    }

    ++smsc->ois_ack_debt;
    time(&smsc->ois_alive);
    ret = 0;
    goto out;

 error_close:
    if (smsc->ois_ack_debt != 0) {
    warning(0, "ois_submit_msg: missing %d ack(s)...",
        smsc->ois_ack_debt);
    }
    SAY(4, "ois_submit_msg: ois_disconnect in error_close");
    ois_disconnect(smsc);
 error:
    SAY(2, "ois_submit_msg error");
    ret = -1;
 out:
    ois_swap_buffering(smsc);
    return ret;
}

ois_submit_sm_invoke()

static int ois_submit_sm_invoke ( SMSCenter *  smsc, const Msg *  msg  )

static

Definition at line 808 of file smsc_ois.c.

References BUFLEN, EOL, error(), IOTRACE, msg, ois_counter, ois_encode_submit_sm_invoke(), ois_increment_counter(), SAY, SMSCenter::socket, and write_to_socket().

Referenced by ois_submit_msg().

{
    char body[BUFLEN+1];
    char buffer[BUFLEN+1];
    int len;
    int count;
    int i;
    int ret;

    SAY(2, "ois_submit_sm_invoke");

    /* construct a message */

    ois_increment_counter();                  /* once per invoke */
    len = ois_encode_submit_sm_invoke(body, msg);

    /* the x.25 gear should be capable to fragment large messages, but... */
    /* let's just use an explicit 128 byte blocks */

    count = (len-1) / 121;                    /* 121 = 128 - 6 - 1 */

    /* first part */

    sprintf(buffer, "%c%c%04d%.121s%c",
        'S',                              /* submit sm invoke */
        (char)(0x50|count),               /* ia5 encoding, first part */
        ois_counter,
        &body[0],
        EOL);
    IOTRACE("sending", buffer, strlen(buffer));
    ret = write_to_socket(smsc->socket, buffer);
    if (ret < 0) {
    goto error;
    }

    /* additional parts */

    for (i = 1; i <= count; ++i) {
    sprintf(buffer, "%c%c%04d%.121s%c",
        'S',                          /* submit sm invoke */
        (char)(0x60|(count-i)),       /* ia5, additional part */
        ois_counter,
        &body[i*121],
        EOL);
    IOTRACE("sending", buffer, strlen(buffer));
    ret = write_to_socket(smsc->socket, buffer);
    if (ret < 0) {
        goto error;
    }
    }

    SAY(2, "ois_submit_sm_invoke ok");
    return 0;

 error:
    SAY(2, "ois_submit_sm_invoke error");
    return -1;
}

ois_submit_sm_result()

static int ois_submit_sm_result ( SMSCenter *  smsc, const char *  buffer  )

static

Definition at line 1024 of file smsc_ois.c.

References error(), ois_decode_submit_sm_result(), and SAY.

Referenced by ois_check_input().

{
    int status;
    int ret;

    SAY(2, "ois_submit_sm_result");

    ret = ois_decode_submit_sm_result(&status, buffer);
    if (ret < 0) {
    goto error;
    }

    return status;

 error:
    return -1;
}

ois_swap_buffering()

static void ois_swap_buffering ( SMSCenter *  smsc )

static

Definition at line 1668 of file smsc_ois.c.

References SMSCenter::buffer, SMSCenter::buflen, SMSCenter::bufsize, SMSCenter::ois_alive, SMSCenter::ois_alive2, SMSCenter::ois_buffer, SMSCenter::ois_buflen, SMSCenter::ois_bufsize, SMSCenter::ois_socket, SAY, and SMSCenter::socket.

Referenced by ois_close(), ois_disconnect_all(), ois_pending_smsmessage(), and ois_submit_msg().

{
    time_t alive;
    int socket;
    char *buffer;
    size_t bufsize;
    size_t buflen;

    SAY(8, "ois_swap_buffering");

    if (smsc->ois_bufsize == 0) {
    smsc->ois_buflen = 0;
    smsc->ois_bufsize = smsc->bufsize;
    smsc->ois_buffer = gw_malloc(smsc->ois_bufsize);
    memset(smsc->ois_buffer, 0, smsc->ois_bufsize);
    }

    alive = smsc->ois_alive;
    smsc->ois_alive = smsc->ois_alive2;
    smsc->ois_alive2 = alive;

    socket = smsc->socket;
    smsc->socket = smsc->ois_socket;
    smsc->ois_socket = socket;

    buffer = smsc->buffer;
    smsc->buffer = smsc->ois_buffer;
    smsc->ois_buffer = buffer;

    buflen = smsc->buflen;
    smsc->buflen = smsc->ois_buflen;
    smsc->ois_buflen = buflen;

    bufsize = smsc->bufsize;
    smsc->bufsize = smsc->ois_bufsize;
    smsc->ois_bufsize = bufsize;

    return;
}

Variable Documentation

ois_counter

int ois_counter = 0

static

Definition at line 166 of file smsc_ois.c.

Referenced by ois_append_sme_reference_number(), ois_increment_counter(), and ois_submit_sm_invoke().

ois_debug_level

int ois_debug_level = 0

Definition at line 136 of file smsc_ois.c.

Referenced by ois_close(), ois_delete_queue(), ois_open(), ois_pending_smsmessage(), ois_receive_msg(), ois_reopen(), and ois_submit_msg().