smsc_smpp.c File Reference

#include "gwlib/gwlib.h"
#include "msg.h"
#include "smsc_p.h"
#include "smpp_pdu.h"
#include "smscconn_p.h"
#include "bb_smscconn_cb.h"
#include "sms.h"
#include "dlr.h"
#include "bearerbox.h"

Include dependency graph for smsc_smpp.c:

Go to the source code of this file.

Data Structures
struct	SMPP
struct	smpp_msg
struct	io_arg
Defines
#define	SMPP_DEFAULT_CHARSET   "UTF-8"
#define	DEBUG   1
#define	dump_pdu(msg, id, pdu)
#define	SMPP_ENQUIRE_LINK_INTERVAL   30.0
#define	SMPP_MAX_PENDING_SUBMITS   10
#define	SMPP_DEFAULT_VERSION   0x34
#define	SMPP_DEFAULT_PRIORITY   0
#define	SMPP_THROTTLING_SLEEP_TIME   15
#define	SMPP_DEFAULT_CONNECTION_TIMEOUT   10 * SMPP_ENQUIRE_LINK_INTERVAL
#define	SMPP_DEFAULT_WAITACK   60
#define	SMPP_DEFAULT_SHUTDOWN_TIMEOUT   30
#define	SMPP_WAITACK_RECONNECT   0x00
#define	SMPP_WAITACK_REQUEUE   0x01
#define	SMPP_WAITACK_NEVER_EXPIRE   0x02
Functions
smpp_msg *	smpp_msg_create (Msg *msg)
void	smpp_msg_destroy (struct smpp_msg *msg, int destroy_msg)
SMPP *	smpp_create (SMSCConn *conn, Octstr *host, int transmit_port, int receive_port, Octstr *system_type, Octstr *username, Octstr *password, Octstr *address_range, int source_addr_ton, int source_addr_npi, int dest_addr_ton, int dest_addr_npi, int enquire_link_interval, int max_pending_submits, int version, int priority, int validity, Octstr *my_number, int smpp_msg_id_type, int autodetect_addr, Octstr *alt_charset, Octstr *alt_addr_charset, Octstr *service_type, long connection_timeout, long wait_ack, int wait_ack_action)
void	smpp_destroy (SMPP *smpp)
int	read_pdu (SMPP *smpp, Connection *conn, long *len, SMPP_PDU **pdu)
long	convert_addr_from_pdu (Octstr *id, Octstr *addr, long ton, long npi, Octstr *alt_addr_charset)
Msg *	pdu_to_msg (SMPP *smpp, SMPP_PDU *pdu, long *reason)
Msg *	data_sm_to_msg (SMPP *smpp, SMPP_PDU *pdu, long *reason)
long	smpp_status_to_smscconn_failure_reason (long status)
SMPP_PDU *	msg_to_pdu (SMPP *smpp, Msg *msg)
void	send_enquire_link (SMPP *smpp, Connection *conn, long *last_sent)
void	send_unbind (SMPP *smpp, Connection *conn)
int	send_pdu (Connection *conn, Octstr *id, SMPP_PDU *pdu)
void	send_messages (SMPP *smpp, Connection *conn, long *pending_submits)
Connection *	open_transmitter (SMPP *smpp)
Connection *	open_transceiver (SMPP *smpp)
Connection *	open_receiver (SMPP *smpp)
Msg *	handle_dlr (SMPP *smpp, Octstr *destination_addr, Octstr *short_message, Octstr *message_payload, Octstr *receipted_message_id, long message_state)
long	smscconn_failure_reason_to_smpp_status (long reason)
void	handle_pdu (SMPP *smpp, Connection *conn, SMPP_PDU *pdu, long *pending_submits)
io_arg *	io_arg_create (SMPP *smpp, int transmitter)
int	do_queue_cleanup (SMPP *smpp, long *pending_submits, int action)
void	io_thread (void *arg)
long	queued_cb (SMSCConn *conn)
int	send_msg_cb (SMSCConn *conn, Msg *msg)
int	shutdown_cb (SMSCConn *conn, int finish_sending)
int	smsc_smpp_create (SMSCConn *conn, CfgGroup *grp)

---

Define Documentation

#define DEBUG   1

Definition at line 90 of file smsc_smpp.c.

#define dump_pdu (  msg, id, pdu   )

Value: do { \ debug("bb.sms.smpp", 0, "SMPP[%s]: %s", \ octstr_get_cstr(id), msg); \ smpp_pdu_dump(pdu); \ } while(0) This version does dump. Definition at line 96 of file smsc_smpp.c. Referenced by io_thread(), send_enquire_link(), send_logoff(), send_pdu(), send_unbind(), and smasi_thread().

#define SMPP_DEFAULT_CHARSET   "UTF-8"

Definition at line 82 of file smsc_smpp.c. Referenced by convert_addr_from_pdu(), data_sm_to_msg(), msg_to_pdu(), and pdu_to_msg().

#define SMPP_DEFAULT_CONNECTION_TIMEOUT   10 * SMPP_ENQUIRE_LINK_INTERVAL

Definition at line 114 of file smsc_smpp.c.

#define SMPP_DEFAULT_PRIORITY   0

Definition at line 112 of file smsc_smpp.c.

#define SMPP_DEFAULT_SHUTDOWN_TIMEOUT   30

Definition at line 116 of file smsc_smpp.c. Referenced by io_thread().

#define SMPP_DEFAULT_VERSION   0x34

Definition at line 111 of file smsc_smpp.c.

#define SMPP_DEFAULT_WAITACK   60

Definition at line 115 of file smsc_smpp.c.

#define SMPP_ENQUIRE_LINK_INTERVAL   30.0

Definition at line 109 of file smsc_smpp.c.

#define SMPP_MAX_PENDING_SUBMITS   10

Definition at line 110 of file smsc_smpp.c.

#define SMPP_THROTTLING_SLEEP_TIME   15

Definition at line 113 of file smsc_smpp.c.

#define SMPP_WAITACK_NEVER_EXPIRE   0x02

Definition at line 124 of file smsc_smpp.c.

#define SMPP_WAITACK_RECONNECT   0x00

Definition at line 122 of file smsc_smpp.c. Referenced by do_queue_cleanup().

#define SMPP_WAITACK_REQUEUE   0x01

Definition at line 123 of file smsc_smpp.c. Referenced by do_queue_cleanup().

---

Function Documentation

long convert_addr_from_pdu (  Octstr *  id, Octstr *  addr, long  ton, long  npi, Octstr *  alt_addr_charset )  [static]

Definition at line 338 of file smsc_smpp.c. References charset_convert(), charset_gsm_to_utf8(), error(), GSM_ADDR_TON_ALPHANUMERIC, GSM_ADDR_TON_INTERNATIONAL, gw_isdigit(), octstr_check_range(), octstr_delete(), octstr_get_char(), octstr_get_cstr, octstr_imm(), octstr_insert_char(), octstr_len(), octstr_search(), octstr_str_case_compare(), reason, SMPP_DEFAULT_CHARSET, and warning(). Referenced by data_sm_to_msg(), and pdu_to_msg(). { long reason = SMPP_ESME_ROK; if (addr == NULL) return reason; switch(ton) { case GSM_ADDR_TON_INTERNATIONAL: /* * Checks to perform: * 1) assume international number has at least 7 chars * 2) the whole source addr consist of digits, exception '+' in front */ if (octstr_len(addr) < 7) { /* We consider this as a "non-hard" condition, since there "may" * be international numbers routable that are < 7 digits. Think * of 2 digit country code + 3 digit emergency code. */ warning(0, "SMPP[%s]: Mallformed addr `%s', generally expected at least 7 digits. ", octstr_get_cstr(id), octstr_get_cstr(addr)); } else if (octstr_get_char(addr, 0) == '+' && !octstr_check_range(addr, 1, 256, gw_isdigit)) { error(0, "SMPP[%s]: Mallformed addr `%s', expected all digits. ", octstr_get_cstr(id), octstr_get_cstr(addr)); reason = SMPP_ESME_RINVSRCADR; goto error; } else if (octstr_get_char(addr, 0) != '+' && !octstr_check_range(addr, 0, 256, gw_isdigit)) { error(0, "SMPP[%s]: Mallformed addr `%s', expected all digits. ", octstr_get_cstr(id), octstr_get_cstr(addr)); reason = SMPP_ESME_RINVSRCADR; goto error; } /* check if we received leading '00', then remove it*/ if (octstr_search(addr, octstr_imm("00"), 0) == 0) octstr_delete(addr, 0, 2); /* international, insert '+' if not already here */ if (octstr_get_char(addr, 0) != '+') octstr_insert_char(addr, 0, '+'); break; case GSM_ADDR_TON_ALPHANUMERIC: if (octstr_len(addr) > 11) { /* alphanum sender, max. allowed length is 11 (according to GSM specs) */ error(0, "SMPP[%s]: Mallformed addr `%s', alphanum length greater 11 chars. ", octstr_get_cstr(id), octstr_get_cstr(addr)); reason = SMPP_ESME_RINVSRCADR; goto error; } if (alt_addr_charset) { if (octstr_str_case_compare(alt_addr_charset, "gsm") == 0) charset_gsm_to_utf8(addr); else if (charset_convert(addr, octstr_get_cstr(alt_addr_charset), SMPP_DEFAULT_CHARSET) != 0) error(0, "Failed to convert address from charset <%s> to <%s>, leave as is.", octstr_get_cstr(alt_addr_charset), SMPP_DEFAULT_CHARSET); } break; default: /* otherwise don't touch addr, user should handle it */ break; } error: return reason; }

Here is the call graph for this function:

Msg* data_sm_to_msg (  SMPP *  smpp, SMPP_PDU *  pdu, long *  reason )  [static]

Definition at line 576 of file smsc_smpp.c. References SMPP::alt_addr_charset, SMPP::alt_charset, charset_convert(), charset_gsm_to_utf8(), SMPP::conn, convert_addr_from_pdu(), data_sm, DC_7BIT, DC_UNDEF, dcs_to_fields(), debug(), error(), gw_assert, smscconn::id, msg_create, msg_destroy(), octstr_copy, octstr_delete(), octstr_get_char(), octstr_get_cstr, octstr_len(), pdu, reason, SMPP_DEFAULT_CHARSET, sms, SMPP_PDU::type, and SMPP_PDU::u. Referenced by handle_pdu(). { Msg *msg; int ton, npi; gw_assert(pdu->type == data_sm); msg = msg_create(sms); gw_assert(msg != NULL); *reason = SMPP_ESME_ROK; /* * Reset source addr to have a prefixed '+' in case we have an * intl. TON to allow backend boxes (ie. smsbox) to distinguish * between national and international numbers. */ ton = pdu->u.data_sm.source_addr_ton; npi = pdu->u.data_sm.source_addr_npi; /* check source addr */ if ((*reason = convert_addr_from_pdu(smpp->conn->id, pdu->u.data_sm.source_addr, ton, npi, smpp->alt_addr_charset)) != SMPP_ESME_ROK) goto error; msg->sms.sender = pdu->u.data_sm.source_addr; pdu->u.data_sm.source_addr = NULL; /* * Follows SMPP spec. v3.4. issue 1.2 * it's not allowed to have destination_addr NULL */ if (pdu->u.data_sm.destination_addr == NULL) { error(0, "SMPP[%s]: Mallformed destination_addr `%s', may not be empty. " "Discarding MO message.", octstr_get_cstr(smpp->conn->id), octstr_get_cstr(pdu->u.data_sm.destination_addr)); *reason = SMPP_ESME_RINVDSTADR; goto error; } /* Same reset of destination number as for source */ ton = pdu->u.data_sm.dest_addr_ton; npi = pdu->u.data_sm.dest_addr_npi; /* check destination addr */ if ((*reason = convert_addr_from_pdu(smpp->conn->id, pdu->u.data_sm.destination_addr, ton, npi, smpp->alt_addr_charset)) != SMPP_ESME_ROK) goto error; msg->sms.receiver = pdu->u.data_sm.destination_addr; pdu->u.data_sm.destination_addr = NULL; /* SMSCs use service_type for billing information */ msg->sms.binfo = pdu->u.data_sm.service_type; pdu->u.data_sm.service_type = NULL; if (pdu->u.data_sm.esm_class & ESM_CLASS_SUBMIT_RPI) msg->sms.rpi = 1; msg->sms.msgdata = pdu->u.data_sm.message_payload; pdu->u.data_sm.message_payload = NULL; /* * Encode udh if udhi set * for reference see GSM03.40, section 9.2.3.24 */ if (pdu->u.data_sm.esm_class & ESM_CLASS_SUBMIT_UDH_INDICATOR) { int udhl; udhl = octstr_get_char(msg->sms.msgdata, 0) + 1; debug("bb.sms.smpp",0,"SMPP[%s]: UDH length read as %d", octstr_get_cstr(smpp->conn->id), udhl); if (udhl > octstr_len(msg->sms.msgdata)) { error(0, "SMPP[%s]: Mallformed UDH length indicator 0x%03x while message length " "0x%03lx. Discarding MO message.", octstr_get_cstr(smpp->conn->id), udhl, octstr_len(msg->sms.msgdata)); *reason = SMPP_ESME_RINVESMCLASS; goto error; } msg->sms.udhdata = octstr_copy(msg->sms.msgdata, 0, udhl); octstr_delete(msg->sms.msgdata, 0, udhl); } dcs_to_fields(&msg, pdu->u.data_sm.data_coding); /* handle default data coding */ switch (pdu->u.data_sm.data_coding) { case 0x00: /* default SMSC alphabet */ /* * try to convert from something interesting if specified so * unless it was specified binary, ie. UDH indicator was detected */ if (smpp->alt_charset && msg->sms.coding != DC_8BIT) { if (charset_convert(msg->sms.msgdata, octstr_get_cstr(smpp->alt_charset), SMPP_DEFAULT_CHARSET) != 0) error(0, "Failed to convert msgdata from charset <%s> to <%s>, will leave as is.", octstr_get_cstr(smpp->alt_charset), SMPP_DEFAULT_CHARSET); msg->sms.coding = DC_7BIT; } else { /* assume GSM 03.38 7-bit alphabet */ charset_gsm_to_utf8(msg->sms.msgdata); msg->sms.coding = DC_7BIT; } break; case 0x01: /* ASCII or IA5 - not sure if I need to do anything */ case 0x03: /* ISO-8859-1 - do nothing */ msg->sms.coding = DC_7BIT; break; case 0x02: /* 8 bit binary - do nothing */ case 0x04: /* 8 bit binary - do nothing */ msg->sms.coding = DC_8BIT; break; case 0x05: /* JIS - what do I do with that ? */ break; case 0x06: /* Cyrllic - iso-8859-5, I'll convert to unicode */ if (charset_convert(msg->sms.msgdata, "ISO-8859-5", "UTF-8") != 0) error(0, "Failed to convert msgdata from cyrllic to UTF-8, will leave as is"); msg->sms.coding = DC_7BIT; break; case 0x07: /* Hebrew iso-8859-8, I'll convert to unicode */ if (charset_convert(msg->sms.msgdata, "ISO-8859-8", "UTF-8") != 0) error(0, "Failed to convert msgdata from hebrew to UTF-8, will leave as is"); msg->sms.coding = DC_7BIT; break; case 0x08: /* unicode UCS-2, yey */ msg->sms.coding = DC_UCS2; break; /* * don't much care about the others, * you implement them if you feel like it */ default: /* * some of smsc send with dcs from GSM 03.38 , but these are reserved in smpp spec. * So we just look decoded values from dcs_to_fields and if none there make our assumptions. * if we have an UDH indicator, we assume DC_8BIT. */ if (msg->sms.coding == DC_UNDEF && pdu->u.data_sm.esm_class & ESM_CLASS_SUBMIT_UDH_INDICATOR) msg->sms.coding = DC_8BIT; else if (msg->sms.coding == DC_7BIT || msg->sms.coding == DC_UNDEF) { /* assume GSM 7Bit , reencode */ msg->sms.coding = DC_7BIT; charset_gsm_to_utf8(msg->sms.msgdata); } } return msg; error: msg_destroy(msg); return NULL; }

Here is the call graph for this function:

int do_queue_cleanup (  SMPP *  smpp, long *  pending_submits, int  action )  [static]

Definition at line 1665 of file smsc_smpp.c. References action, bb_smscconn_send_failed(), SMPP::conn, dict_get(), dict_keys(), dict_remove(), error(), gwlist_destroy(), gwlist_extract_first(), smscconn::id, smpp_msg::msg, octstr_destroy(), octstr_destroy_item(), octstr_get_cstr, SMPP::sent_msgs, smpp_msg::sent_time, smpp_msg_destroy(), SMPP_WAITACK_RECONNECT, SMPP_WAITACK_REQUEUE, SMSCCONN_FAILED_TEMPORARILY, SMPP::wait_ack, and warning(). Referenced by io_thread(). { List *keys; Octstr *key; struct smpp_msg *smpp_msg; time_t now = time(NULL); if (*pending_submits <= 0) return 0; /* check if action set to wait ack for ever */ if (action == SMPP_WAITACK_NEVER_EXPIRE) return 0; keys = dict_keys(smpp->sent_msgs); if (keys == NULL) return 0; while ((key = gwlist_extract_first(keys)) != NULL) { smpp_msg = dict_get(smpp->sent_msgs, key); if (smpp_msg != NULL && difftime(now, smpp_msg->sent_time) > smpp->wait_ack) { switch(action) { case SMPP_WAITACK_RECONNECT: /* reconnect */ /* found at least one not acked msg */ warning(0, "SMPP[%s]: Not ACKED message found, reconnecting.", octstr_get_cstr(smpp->conn->id)); octstr_destroy(key); gwlist_destroy(keys, octstr_destroy_item); return 1; /* io_thread will reconnect */ case SMPP_WAITACK_REQUEUE: /* requeue */ smpp_msg = dict_remove(smpp->sent_msgs, key); if (smpp_msg != NULL) { warning(0, "SMPP[%s]: Not ACKED message found, will retransmit." " SENT<%ld>sec. ago, SEQ<%s>, DST<%s>", octstr_get_cstr(smpp->conn->id), (long)difftime(now, smpp_msg->sent_time) , octstr_get_cstr(key), octstr_get_cstr(smpp_msg->msg->sms.receiver)); bb_smscconn_send_failed(smpp->conn, smpp_msg->msg, SMSCCONN_FAILED_TEMPORARILY,NULL); smpp_msg_destroy(smpp_msg, 0); (*pending_submits)--; } break; default: error(0, "SMPP[%s] Unknown clenup action defined %xd.", octstr_get_cstr(smpp->conn->id), action); octstr_destroy(key); gwlist_destroy(keys, octstr_destroy_item); return 0; } } octstr_destroy(key); } gwlist_destroy(keys, octstr_destroy_item); return 0; }

Here is the call graph for this function:

Msg* handle_dlr (  SMPP *  smpp, Octstr *  destination_addr, Octstr *  short_message, Octstr *  message_payload, Octstr *  receipted_message_id, long  message_state )  [static]

Definition at line 1145 of file smsc_smpp.c. References SMPP::conn, debug(), dlr_find(), error(), gw_isdigit(), smscconn::id, octstr_check_range(), octstr_compare(), octstr_copy, octstr_create, octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_imm(), octstr_len(), octstr_search(), octstr_search_char(), octstr_strip_blanks(), SMPP::smpp_msg_id_type, SMPP::version, and warning(). Referenced by handle_pdu(). { Msg *dlrmsg = NULL; Octstr *respstr = NULL, *msgid = NULL, *tmp; int dlrstat = -1; /* first check for SMPP v3.4 and above */ if (smpp->version > 0x33 && receipted_message_id) { msgid = octstr_duplicate(receipted_message_id); switch(message_state) { case 1: /* ENROUTE */ case 6: /* ACCEPTED */ dlrstat = DLR_BUFFERED; break; case 2: /* DELIVERED */ dlrstat = DLR_SUCCESS; break; case 3: /* EXPIRED */ case 4: /* DELETED */ case 5: /* UNDELIVERABLE */ case 7: /* UNKNOWN */ case 8: /* REJECTED */ dlrstat = DLR_FAIL; break; default: warning(0, "SMPP[%s]: Got DLR with unknown 'message_state' (%ld).", octstr_get_cstr(smpp->conn->id), message_state); dlrstat = DLR_FAIL; break; } } /* check for SMPP v.3.4. and message_payload */ if (smpp->version > 0x33 && octstr_len(short_message) == 0) respstr = message_payload; else respstr = short_message; /* still no msgid ? */ if (!msgid && respstr) { long curr = 0, vpos = 0; Octstr *stat = NULL; char id_cstr[65], stat_cstr[16], sub_d_cstr[13], done_d_cstr[13]; int sub, dlrvrd, ret; /* get server message id */ /* first try sscanf way if thus failed then old way */ ret = sscanf(octstr_get_cstr(respstr), "id:%64[^s] sub:%d dlvrd:%d submit date:%12[0-9] done date:%12[0-9] stat:%10[^t^e]", id_cstr, &sub, &dlrvrd, sub_d_cstr, done_d_cstr, stat_cstr); if (ret == 6) { msgid = octstr_create(id_cstr); octstr_strip_blanks(msgid); stat = octstr_create(stat_cstr); octstr_strip_blanks(stat); } else { debug("bb.sms.smpp", 0, "SMPP[%s]: Couldnot parse DLR string sscanf way," "fallback to old way. Please report!", octstr_get_cstr(smpp->conn->id)); if ((curr = octstr_search(respstr, octstr_imm("id:"), 0)) != -1) { vpos = octstr_search_char(respstr, ' ', curr); if ((vpos-curr >0) && (vpos != -1)) msgid = octstr_copy(respstr, curr+3, vpos-curr-3); } else { msgid = NULL; } /* get err & status code */ if ((curr = octstr_search(respstr, octstr_imm("stat:"), 0)) != -1) { vpos = octstr_search_char(respstr, ' ', curr); if ((vpos-curr >0) && (vpos != -1)) stat = octstr_copy(respstr, curr+5, vpos-curr-5); } else { stat = NULL; } } /* * we get the following status: * DELIVRD, ACCEPTD, EXPIRED, DELETED, UNDELIV, UNKNOWN, REJECTD * * Note: some buggy SMSC's send us immediately delivery notifications although * we doesn't requested these. */ if (stat != NULL && octstr_compare(stat, octstr_imm("DELIVRD")) == 0) dlrstat = DLR_SUCCESS; else if (stat != NULL && (octstr_compare(stat, octstr_imm("ACCEPTD")) == 0 || octstr_compare(stat, octstr_imm("ACKED")) == 0 || octstr_compare(stat, octstr_imm("BUFFRED")) == 0 || octstr_compare(stat, octstr_imm("BUFFERD")) == 0 || octstr_compare(stat, octstr_imm("ENROUTE")) == 0)) dlrstat = DLR_BUFFERED; else dlrstat = DLR_FAIL; if (stat != NULL) octstr_destroy(stat); } if (msgid != NULL) { /* * Obey which SMPP msg_id type this SMSC is using, where we * have the following semantics for the variable smpp_msg_id: * * bit 1: type for submit_sm_resp, bit 2: type for deliver_sm * * if bit is set value is hex otherwise dec * * 0x00 deliver_sm dec, submit_sm_resp dec * 0x01 deliver_sm dec, submit_sm_resp hex * 0x02 deliver_sm hex, submit_sm_resp dec * 0x03 deliver_sm hex, submit_sm_resp hex * * Default behaviour is SMPP spec compliant, which means * msg_ids should be C strings and hence non modified. */ if (smpp->smpp_msg_id_type == -1) { /* the default, C string */ tmp = octstr_duplicate(msgid); } else { if ((smpp->smpp_msg_id_type & 0x02) || (!octstr_check_range(msgid, 0, octstr_len(msgid), gw_isdigit))) { tmp = octstr_format("%lu", strtoll(octstr_get_cstr(msgid), NULL, 16)); } else { tmp = octstr_format("%lu", strtoll(octstr_get_cstr(msgid), NULL, 10)); } } dlrmsg = dlr_find(smpp->conn->id, tmp, /* smsc message id */ destination_addr, /* destination */ dlrstat); octstr_destroy(msgid); } else tmp = octstr_create(""); if (dlrmsg != NULL) { /* * we found the delivery report in our storage, so recode the * message structure. * The DLR trigger URL is indicated by msg->sms.dlr_url. */ dlrmsg->sms.msgdata = octstr_duplicate(respstr); dlrmsg->sms.sms_type = report_mo; } else { error(0,"SMPP[%s]: got DLR but could not find message or was not interested " "in it id<%s> dst<%s>, type<%d>", octstr_get_cstr(smpp->conn->id), octstr_get_cstr(tmp), octstr_get_cstr(destination_addr), dlrstat); } octstr_destroy(tmp); return dlrmsg; }

Here is the call graph for this function:

void handle_pdu (  SMPP *  smpp, Connection *  conn, SMPP_PDU *  pdu, long *  pending_submits )  [static]

Definition at line 1320 of file smsc_smpp.c. References bb_alog_sms(), bb_smscconn_connected(), bb_smscconn_receive(), bb_smscconn_send_failed(), bb_smscconn_sent(), bind_receiver_resp, bind_transceiver_resp, bind_transmitter_resp, SMPP::conn, smscconn::connect_time, data_sm, data_sm_resp, data_sm_to_msg(), debug(), deliver_sm, deliver_sm_resp, dict_remove(), dlr_add(), DLR_IS_ENABLED_DEVICE, enquire_link, enquire_link_resp, error(), smscconn::flow_mutex, generic_nack, gw_isdigit(), handle_dlr(), smscconn::id, smscconn::is_stopped, smpp_msg::msg, msg_destroy(), mutex_lock, mutex_unlock, SMPP::my_number, octstr_check_range(), octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_len(), pdu, pdu_to_msg(), SMPP::quitting, reason, send_pdu(), SMPP::sent_msgs, smpp_error_to_string(), SMPP_ESME_RINVSYSID, smpp_msg_destroy(), SMPP::smpp_msg_id_type, smpp_pdu_create(), smpp_pdu_destroy(), smpp_status_to_smscconn_failure_reason(), smscconn_failure_reason_to_smpp_status(), smscconn::status, submit_sm_resp, SMPP::throttling_err_time, SMPP_PDU::type, SMPP_PDU::u, unbind, unbind_resp, and warning(). { SMPP_PDU *resp; Octstr *os; Msg *msg, *dlrmsg = NULL; long reason; long cmd_stat; struct smpp_msg *smpp_msg = NULL; resp = NULL; switch (pdu->type) { case data_sm: resp = smpp_pdu_create(data_sm_resp, pdu->u.data_sm.sequence_number); /* * If SMSCConn stopped then send temp. error code */ mutex_lock(smpp->conn->flow_mutex); if (smpp->conn->is_stopped) { mutex_unlock(smpp->conn->flow_mutex); resp->u.data_sm.command_status = SMPP_ESME_RX_T_APPN; break; } mutex_unlock(smpp->conn->flow_mutex); /* got a deliver ack (DLR)? * NOTE: following SMPP v3.4. spec. we are interested * only on bits 2-5 (some SMSC's send 0x44, and it's * spec. conforme) */ if (pdu->u.data_sm.esm_class & (0x04|0x08)) { debug("bb.sms.smpp",0,"SMPP[%s] handle_pdu, got DLR", octstr_get_cstr(smpp->conn->id)); dlrmsg = handle_dlr(smpp, pdu->u.data_sm.source_addr, NULL, pdu->u.data_sm.message_payload, pdu->u.data_sm.receipted_message_id, pdu->u.data_sm.message_state); if (dlrmsg != NULL) { /* passing DLR to upper layer */ reason = bb_smscconn_receive(smpp->conn, dlrmsg); } else { /* no DLR will be passed, but we write an access-log entry */ reason = SMSCCONN_SUCCESS; msg = data_sm_to_msg(smpp, pdu, &reason); bb_alog_sms(smpp->conn, msg, "FAILED DLR SMS"); msg_destroy(msg); } resp->u.data_sm_resp.command_status = smscconn_failure_reason_to_smpp_status(reason); } else { /* MO message */ msg = data_sm_to_msg(smpp, pdu, &reason); if (msg == NULL || reason != SMPP_ESME_ROK) { resp->u.data_sm_resp.command_status = reason; break; } /* Replace MO destination number with my-number */ if (octstr_len(smpp->my_number)) { octstr_destroy(msg->sms.receiver); msg->sms.receiver = octstr_duplicate(smpp->my_number); } time(&msg->sms.time); msg->sms.smsc_id = octstr_duplicate(smpp->conn->id); reason = bb_smscconn_receive(smpp->conn, msg); resp->u.data_sm_resp.command_status = smscconn_failure_reason_to_smpp_status(reason); } break; case deliver_sm: /* * If SMSCConn stopped then send temp. error code */ mutex_lock(smpp->conn->flow_mutex); if (smpp->conn->is_stopped) { mutex_unlock(smpp->conn->flow_mutex); resp = smpp_pdu_create(deliver_sm_resp, pdu->u.deliver_sm.sequence_number); resp->u.deliver_sm.command_status = SMPP_ESME_RX_T_APPN; break; } mutex_unlock(smpp->conn->flow_mutex); /* got a deliver ack (DLR)? * NOTE: following SMPP v3.4. spec. we are interested * only on bits 2-5 (some SMSC's send 0x44, and it's * spec. conforme) */ if (pdu->u.deliver_sm.esm_class & (0x04|0x08)) { debug("bb.sms.smpp",0,"SMPP[%s] handle_pdu, got DLR", octstr_get_cstr(smpp->conn->id)); dlrmsg = handle_dlr(smpp, pdu->u.deliver_sm.source_addr, pdu->u.deliver_sm.short_message, pdu->u.deliver_sm.message_payload, pdu->u.deliver_sm.receipted_message_id, pdu->u.deliver_sm.message_state); resp = smpp_pdu_create(deliver_sm_resp, pdu->u.deliver_sm.sequence_number); if (dlrmsg != NULL) reason = bb_smscconn_receive(smpp->conn, dlrmsg); else reason = SMSCCONN_SUCCESS; resp->u.deliver_sm_resp.command_status = smscconn_failure_reason_to_smpp_status(reason); } else {/* MO-SMS */ resp = smpp_pdu_create(deliver_sm_resp, pdu->u.deliver_sm.sequence_number); /* ensure the smsc-id is set */ msg = pdu_to_msg(smpp, pdu, &reason); if (msg == NULL) { resp->u.deliver_sm_resp.command_status = reason; break; } /* Replace MO destination number with my-number */ if (octstr_len(smpp->my_number)) { octstr_destroy(msg->sms.receiver); msg->sms.receiver = octstr_duplicate(smpp->my_number); } time(&msg->sms.time); msg->sms.smsc_id = octstr_duplicate(smpp->conn->id); reason = bb_smscconn_receive(smpp->conn, msg); resp->u.deliver_sm_resp.command_status = smscconn_failure_reason_to_smpp_status(reason); } break; case enquire_link: resp = smpp_pdu_create(enquire_link_resp, pdu->u.enquire_link.sequence_number); break; case enquire_link_resp: break; case submit_sm_resp: os = octstr_format("%ld", pdu->u.submit_sm_resp.sequence_number); smpp_msg = dict_remove(smpp->sent_msgs, os); octstr_destroy(os); if (smpp_msg == NULL) { warning(0, "SMPP[%s]: SMSC sent submit_sm_resp " "with wrong sequence number 0x%08lx", octstr_get_cstr(smpp->conn->id), pdu->u.submit_sm_resp.sequence_number); break; } msg = smpp_msg->msg; smpp_msg_destroy(smpp_msg, 0); if (pdu->u.submit_sm_resp.command_status != 0) { error(0, "SMPP[%s]: SMSC returned error code 0x%08lx (%s) " "in response to submit_sm.", octstr_get_cstr(smpp->conn->id), pdu->u.submit_sm_resp.command_status, smpp_error_to_string(pdu->u.submit_sm_resp.command_status)); reason = smpp_status_to_smscconn_failure_reason( pdu->u.submit_sm_resp.command_status); /* * check to see if we got a "throttling error", in which case we'll just * sleep for a while */ if (pdu->u.submit_sm_resp.command_status == SMPP_ESME_RTHROTTLED) time(&(smpp->throttling_err_time)); else smpp->throttling_err_time = 0; bb_smscconn_send_failed(smpp->conn, msg, reason, octstr_format("%ld/%s", pdu->u.submit_sm_resp.command_status, smpp_error_to_string(pdu->u.submit_sm_resp.command_status))); --(*pending_submits); } else { Octstr *tmp; /* check if msg_id is C string, decimal or hex for this SMSC */ if (smpp->smpp_msg_id_type == -1) { /* the default, C string */ tmp = octstr_duplicate(pdu->u.submit_sm_resp.message_id); } else { if ((smpp->smpp_msg_id_type & 0x01) || (!octstr_check_range(pdu->u.submit_sm_resp.message_id, 0, octstr_len(pdu->u.submit_sm_resp.message_id), gw_isdigit))) { tmp = octstr_format("%lu", strtoll( /* hex */ octstr_get_cstr(pdu->u.submit_sm_resp.message_id), NULL, 16)); } else { tmp = octstr_format("%lu", strtoll( /* decimal */ octstr_get_cstr(pdu->u.submit_sm_resp.message_id), NULL, 10)); } } /* SMSC ACK.. now we have the message id. */ if (DLR_IS_ENABLED_DEVICE(msg->sms.dlr_mask)) dlr_add(smpp->conn->id, tmp, msg); octstr_destroy(tmp); bb_smscconn_sent(smpp->conn, msg, NULL); --(*pending_submits); } /* end if for SMSC ACK */ break; case bind_transmitter_resp: if (pdu->u.bind_transmitter_resp.command_status != 0) { error(0, "SMPP[%s]: SMSC rejected login to transmit, " "code 0x%08lx (%s).", octstr_get_cstr(smpp->conn->id), pdu->u.bind_transmitter_resp.command_status, smpp_error_to_string(pdu->u.bind_transmitter_resp.command_status)); if (pdu->u.bind_transmitter_resp.command_status == SMPP_ESME_RINVSYSID || pdu->u.bind_transmitter_resp.command_status == SMPP_ESME_RINVPASWD) smpp->quitting = 1; } else { *pending_submits = 0; mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_ACTIVE; smpp->conn->connect_time = time(NULL); mutex_unlock(smpp->conn->flow_mutex); bb_smscconn_connected(smpp->conn); } break; case bind_transceiver_resp: if (pdu->u.bind_transceiver_resp.command_status != 0) { error(0, "SMPP[%s]: SMSC rejected login to transmit, " "code 0x%08lx (%s).", octstr_get_cstr(smpp->conn->id), pdu->u.bind_transceiver_resp.command_status, smpp_error_to_string(pdu->u.bind_transceiver_resp.command_status)); if (pdu->u.bind_transceiver_resp.command_status == SMPP_ESME_RINVSYSID || pdu->u.bind_transceiver_resp.command_status == SMPP_ESME_RINVPASWD) smpp->quitting = 1; } else { *pending_submits = 0; mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_ACTIVE; smpp->conn->connect_time = time(NULL); mutex_unlock(smpp->conn->flow_mutex); bb_smscconn_connected(smpp->conn); } break; case bind_receiver_resp: if (pdu->u.bind_receiver_resp.command_status != 0) { error(0, "SMPP[%s]: SMSC rejected login to receive, " "code 0x%08lx (%s).", octstr_get_cstr(smpp->conn->id), pdu->u.bind_receiver_resp.command_status, smpp_error_to_string(pdu->u.bind_receiver_resp.command_status)); if (pdu->u.bind_receiver_resp.command_status == SMPP_ESME_RINVSYSID || pdu->u.bind_receiver_resp.command_status == SMPP_ESME_RINVPASWD) smpp->quitting = 1; } else { /* set only resceive status if no transmitt is bind */ mutex_lock(smpp->conn->flow_mutex); if (smpp->conn->status != SMSCCONN_ACTIVE) { smpp->conn->status = SMSCCONN_ACTIVE_RECV; smpp->conn->connect_time = time(NULL); } mutex_unlock(smpp->conn->flow_mutex); } break; case unbind: resp = smpp_pdu_create(unbind_resp, pdu->u.unbind.sequence_number); mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_DISCONNECTED; mutex_unlock(smpp->conn->flow_mutex); break; case unbind_resp: mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_DISCONNECTED; mutex_unlock(smpp->conn->flow_mutex); break; case generic_nack: cmd_stat = pdu->u.generic_nack.command_status; os = octstr_format("%ld", pdu->u.generic_nack.sequence_number); smpp_msg = dict_remove(smpp->sent_msgs, os); octstr_destroy(os); if (smpp_msg == NULL) { error(0, "SMPP[%s]: SMSC rejected last command" "code 0x%08lx (%s).", octstr_get_cstr(smpp->conn->id), cmd_stat, smpp_error_to_string(cmd_stat)); } else { msg = smpp_msg->msg; smpp_msg_destroy(smpp_msg, 0); error(0, "SMPP[%s]: SMSC returned error code 0x%08lx (%s) " "in response to submit_sm.", octstr_get_cstr(smpp->conn->id), cmd_stat, smpp_error_to_string(cmd_stat)); /* * check to see if we got a "throttling error", in which case we'll just * sleep for a while */ if (cmd_stat == SMPP_ESME_RTHROTTLED) time(&(smpp->throttling_err_time)); else smpp->throttling_err_time = 0; reason = smpp_status_to_smscconn_failure_reason(cmd_stat); bb_smscconn_send_failed(smpp->conn, msg, reason, octstr_format("%ld/%s", cmd_stat, smpp_error_to_string(cmd_stat))); --(*pending_submits); } break; default: error(0, "SMPP[%s]: Unknown PDU type 0x%08lx, ignored.", octstr_get_cstr(smpp->conn->id), pdu->type); /* send gnack , see smpp3.4 spec., section 3.3 because we doesn't know what kind of pdu received, we assume generick_nack_resp (header always the same) */ resp = smpp_pdu_create(generic_nack, pdu->u.generic_nack.sequence_number); resp->u.generic_nack.command_status = SMPP_ESME_RINVCMDID; break; } if (resp != NULL) { send_pdu(conn, smpp->conn->id, resp); smpp_pdu_destroy(resp); } }

Here is the call graph for this function:

struct io_arg* io_arg_create (  SMPP *  smpp, int  transmitter )  [static]

Definition at line 1650 of file smsc_smpp.c. References io_arg::smpp, and SMPP::transmitter. Referenced by smsc_smpp_create(). { struct io_arg *io_arg; io_arg = gw_malloc(sizeof(*io_arg)); io_arg->smpp = smpp; io_arg->transmitter = transmitter; return io_arg; }

void io_thread (  void *  arg  )  [static]

Definition at line 1730 of file smsc_smpp.c. References bb_smscconn_send_failed(), SMPP::conn, conn_destroy(), conn_wait(), SMPP::connection_timeout, date_universal_now(), debug(), dict_keys(), dict_remove(), do_queue_cleanup(), dump_pdu, SMPP::enquire_link_interval, error(), smscconn::flow_mutex, gwlist_destroy(), gwlist_extract_first(), gwthread_sleep(), handle_pdu(), smscconn::id, smscconn::log_idx, log_thread_to(), smpp_msg::msg, SMPP::msgs_to_send, mutex_lock, mutex_unlock, octstr_destroy(), octstr_get_cstr, open_receiver(), open_transceiver(), open_transmitter(), pdu, SMPP::quitting, read_pdu(), reason, smscconn::reconnect_delay, send_enquire_link(), send_messages(), send_unbind(), SMPP::sent_msgs, io_arg::smpp, SMPP_DEFAULT_SHUTDOWN_TIMEOUT, smpp_msg_destroy(), smpp_pdu_destroy(), SMSCCONN_ACTIVE, SMSCCONN_FAILED_SHUTDOWN, smscconn::status, SMPP::throttling_err_time, io_arg::transmitter, SMPP::wait_ack, and SMPP::wait_ack_action. Referenced by smsc_smpp_create(). { SMPP *smpp; struct io_arg *io_arg; int transmitter; Connection *conn; int ret; long last_enquire_sent; long pending_submits; long len; SMPP_PDU *pdu; double timeout; time_t last_response, last_cleanup; io_arg = arg; smpp = io_arg->smpp; transmitter = io_arg->transmitter; gw_free(io_arg); /* Make sure we log into our own log-file if defined */ log_thread_to(smpp->conn->log_idx); conn = NULL; while (!smpp->quitting) { if (transmitter == 1) conn = open_transmitter(smpp); else if (transmitter == 2) conn = open_transceiver(smpp); else conn = open_receiver(smpp); last_enquire_sent = last_cleanup = last_response = date_universal_now(); pending_submits = -1; len = 0; smpp->throttling_err_time = 0; for (;conn != NULL;) { timeout = last_enquire_sent + smpp->enquire_link_interval - date_universal_now(); if (conn_wait(conn, timeout) == -1) break; /* unbind * Read so long as unbind_resp received or timeout passed. Otherwise we have * double delivered messages. */ if (smpp->quitting) { send_unbind(smpp, conn); last_response = time(NULL); while(conn_wait(conn, 1.00) != -1 && difftime(time(NULL), last_response) < SMPP_DEFAULT_SHUTDOWN_TIMEOUT && smpp->conn->status != SMSCCONN_DISCONNECTED) { if (read_pdu(smpp, conn, &len, &pdu) == 1) { dump_pdu("Got PDU:", smpp->conn->id, pdu); handle_pdu(smpp, conn, pdu, &pending_submits); smpp_pdu_destroy(pdu); } } debug("bb.sms.smpp", 0, "SMPP[%s]: %s: break and shutting down", octstr_get_cstr(smpp->conn->id), __func__); break; } send_enquire_link(smpp, conn, &last_enquire_sent); while ((ret = read_pdu(smpp, conn, &len, &pdu)) == 1) { last_response = time(NULL); /* Deal with the PDU we just got */ dump_pdu("Got PDU:", smpp->conn->id, pdu); handle_pdu(smpp, conn, pdu, &pending_submits); smpp_pdu_destroy(pdu); /* * check if we are still connected. * Note: smsc can send unbind request, so we must check it. */ if (smpp->conn->status != SMSCCONN_ACTIVE && smpp->conn->status != SMSCCONN_ACTIVE_RECV) { /* we are disconnected */ ret = -1; break; } /* Make sure we send enquire_link even if we read a lot */ send_enquire_link(smpp, conn, &last_enquire_sent); /* Make sure we send even if we read a lot */ if (transmitter && difftime(time(NULL), smpp->throttling_err_time) > SMPP_THROTTLING_SLEEP_TIME) { smpp->throttling_err_time = 0; send_messages(smpp, conn, &pending_submits); } } if (ret == -1) { error(0, "SMPP[%s]: I/O error or other error. Re-connecting.", octstr_get_cstr(smpp->conn->id)); break; } /* if no PDU was received and connection timeout was set and over the limit */ if (ret == 0 && smpp->connection_timeout > 0 && difftime(time(NULL), last_response) > smpp->connection_timeout) { error(0, "SMPP[%s]: No responses from SMSC within %ld sec. Reconnecting.", octstr_get_cstr(smpp->conn->id), smpp->connection_timeout); break; } /* cleanup sent queue */ if (transmitter && difftime(time(NULL), last_cleanup) > smpp->wait_ack) { if (do_queue_cleanup(smpp, &pending_submits, smpp->wait_ack_action)) break; /* reconnect */ last_cleanup = time(NULL); } if (transmitter && difftime(time(NULL), smpp->throttling_err_time) > SMPP_THROTTLING_SLEEP_TIME) { smpp->throttling_err_time = 0; send_messages(smpp, conn, &pending_submits); } } if (conn != NULL) { conn_destroy(conn); conn = NULL; } /* set reconnect status */ mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_RECONNECTING; mutex_unlock(smpp->conn->flow_mutex); /* * Put all queued messages back into global queue,so if * we have another link running then messages will be delivered * quickly. */ if (transmitter) { Msg *msg; struct smpp_msg *smpp_msg; List *noresp; Octstr *key; long reason = (smpp->quitting?SMSCCONN_FAILED_SHUTDOWN:SMSCCONN_FAILED_TEMPORARILY); while((msg = gwlist_extract_first(smpp->msgs_to_send)) != NULL) bb_smscconn_send_failed(smpp->conn, msg, reason, NULL); noresp = dict_keys(smpp->sent_msgs); while((key = gwlist_extract_first(noresp)) != NULL) { smpp_msg = dict_remove(smpp->sent_msgs, key); if (smpp_msg != NULL && smpp_msg->msg) { bb_smscconn_send_failed(smpp->conn, smpp_msg->msg, reason, NULL); smpp_msg_destroy(smpp_msg, 0); } octstr_destroy(key); } gwlist_destroy(noresp, NULL); } /* * Reconnect if that was a connection problem. */ if (!smpp->quitting) { error(0, "SMPP[%s]: Couldn't connect to SMS center (retrying in %ld seconds).", octstr_get_cstr(smpp->conn->id), smpp->conn->reconnect_delay); gwthread_sleep(smpp->conn->reconnect_delay); } } mutex_lock(smpp->conn->flow_mutex); smpp->conn->status = SMSCCONN_DEAD; mutex_unlock(smpp->conn->flow_mutex); }

Here is the call graph for this function:

SMPP_PDU* msg_to_pdu (  SMPP *  smpp, Msg *  msg )  [static]

Definition at line 733 of file smsc_smpp.c. References SMPP::alt_addr_charset, SMPP::alt_charset, smscconn::alt_dcs, SMPP::autodetect_addr, charset_convert(), charset_utf8_to_gsm(), SMPP::conn, counter_increase(), DC_7BIT, DC_UNDEF, debug(), SMPP::dest_addr_npi, SMPP::dest_addr_ton, DLR_IS_FAIL, DLR_IS_SUCCESS, DLR_IS_SUCCESS_OR_FAIL, error(), fields_to_dcs(), gw_gmtime(), gw_isdigit(), smscconn::id, SMPP::message_id_counter, MWI_UNDEF, octstr_check_range(), octstr_delete(), octstr_duplicate, octstr_format(), octstr_get_char(), octstr_get_cstr, octstr_imm(), octstr_insert(), octstr_len(), octstr_replace(), octstr_str_case_compare(), pdu, SMPP::priority, SMPP::service_type, SMPP_DEFAULT_CHARSET, smpp_pdu_create(), smpp_pdu_destroy(), SMS_PARAM_UNDEFINED, SMPP::source_addr_npi, SMPP::source_addr_ton, submit_sm, SMPP_PDU::u, SMPP::validityperiod, and SMPP::version. Referenced by send_messages(). { SMPP_PDU *pdu; int validity; pdu = smpp_pdu_create(submit_sm, counter_increase(smpp->message_id_counter)); pdu->u.submit_sm.source_addr = octstr_duplicate(msg->sms.sender); pdu->u.submit_sm.destination_addr = octstr_duplicate(msg->sms.receiver); /* Set the service type of the outgoing message. We'll use the config * directive as default and 'binfo' as specific parameter. */ pdu->u.submit_sm.service_type = octstr_len(msg->sms.binfo) ? octstr_duplicate(msg->sms.binfo) : octstr_duplicate(smpp->service_type); /* Check for manual override of source ton and npi values */ if(smpp->source_addr_ton > -1 && smpp->source_addr_npi > -1) { pdu->u.submit_sm.source_addr_ton = smpp->source_addr_ton; pdu->u.submit_sm.source_addr_npi = smpp->source_addr_npi; debug("bb.sms.smpp", 0, "SMPP[%s]: Manually forced source addr ton = %d, source add npi = %d", octstr_get_cstr(smpp->conn->id), smpp->source_addr_ton, smpp->source_addr_npi); } else { /* setup default values */ pdu->u.submit_sm.source_addr_ton = GSM_ADDR_TON_NATIONAL; /* national */ pdu->u.submit_sm.source_addr_npi = GSM_ADDR_NPI_E164; /* ISDN number plan */ } if (smpp->autodetect_addr && pdu->u.submit_sm.source_addr) { /* lets see if its international or alphanumeric sender */ if (octstr_get_char(pdu->u.submit_sm.source_addr, 0) == '+') { if (!octstr_check_range(pdu->u.submit_sm.source_addr, 1, 256, gw_isdigit)) { pdu->u.submit_sm.source_addr_ton = GSM_ADDR_TON_ALPHANUMERIC; /* alphanum */ pdu->u.submit_sm.source_addr_npi = GSM_ADDR_NPI_UNKNOWN; /* short code */ if (smpp->alt_addr_charset) { if (octstr_str_case_compare(smpp->alt_addr_charset, "gsm") == 0) { /* @ would break PDU if converted into GSM*/ octstr_replace(pdu->u.submit_sm.source_addr, octstr_imm("@"), octstr_imm("?")); charset_utf8_to_gsm(pdu->u.submit_sm.source_addr); } else if (charset_convert(pdu->u.submit_sm.source_addr, SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_addr_charset)) != 0) error(0, "Failed to convert source_addr from charset <%s> to <%s>, will send as is.", SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_addr_charset)); } } else { /* numeric sender address with + in front -> international (remove the +) */ octstr_delete(pdu->u.submit_sm.source_addr, 0, 1); pdu->u.submit_sm.source_addr_ton = GSM_ADDR_TON_INTERNATIONAL; } } else { if (!octstr_check_range(pdu->u.submit_sm.source_addr,0, 256, gw_isdigit)) { pdu->u.submit_sm.source_addr_ton = GSM_ADDR_TON_ALPHANUMERIC; pdu->u.submit_sm.source_addr_npi = GSM_ADDR_NPI_UNKNOWN; if (smpp->alt_addr_charset) { if (octstr_str_case_compare(smpp->alt_addr_charset, "gsm") == 0) { /* @ would break PDU if converted into GSM */ octstr_replace(pdu->u.submit_sm.source_addr, octstr_imm("@"), octstr_imm("?")); charset_utf8_to_gsm(pdu->u.submit_sm.source_addr); } else if (charset_convert(pdu->u.submit_sm.source_addr, SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_addr_charset)) != 0) error(0, "Failed to convert source_addr from charset <%s> to <%s>, will send as is.", SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_addr_charset)); } } } } /* Check for manual override of destination ton and npi values */ if (smpp->dest_addr_ton > -1 && smpp->dest_addr_npi > -1) { pdu->u.submit_sm.dest_addr_ton = smpp->dest_addr_ton; pdu->u.submit_sm.dest_addr_npi = smpp->dest_addr_npi; debug("bb.sms.smpp", 0, "SMPP[%s]: Manually forced dest addr ton = %d, dest add npi = %d", octstr_get_cstr(smpp->conn->id), smpp->dest_addr_ton, smpp->dest_addr_npi); } else { pdu->u.submit_sm.dest_addr_ton = GSM_ADDR_TON_NATIONAL; /* national */ pdu->u.submit_sm.dest_addr_npi = GSM_ADDR_NPI_E164; /* ISDN number plan */ } /* * if its a international number starting with +, lets remove the * '+' and set number type to international instead */ if (octstr_get_char(pdu->u.submit_sm.destination_addr,0) == '+') { octstr_delete(pdu->u.submit_sm.destination_addr, 0,1); pdu->u.submit_sm.dest_addr_ton = GSM_ADDR_TON_INTERNATIONAL; } /* check length of src/dst address */ if (octstr_len(pdu->u.submit_sm.destination_addr) > 20 || octstr_len(pdu->u.submit_sm.source_addr) > 20) { smpp_pdu_destroy(pdu); return NULL; } /* * set the data coding scheme (DCS) field * check if we have a forced value for this from the smsc-group. * Note: if message class is set, then we _must_ force alt_dcs otherwise * dcs has reserved values (e.g. mclass=2, dcs=0x11). We check MWI flag * first here, because MWI and MCLASS can not be set at the same time and * function fields_to_dcs check MWI first, so we have no need to force alt_dcs * if MWI is set. */ if (msg->sms.mwi == MWI_UNDEF && msg->sms.mclass != MC_UNDEF) pdu->u.submit_sm.data_coding = fields_to_dcs(msg, 1); /* force alt_dcs */ else pdu->u.submit_sm.data_coding = fields_to_dcs(msg, (msg->sms.alt_dcs != SMS_PARAM_UNDEFINED ? msg->sms.alt_dcs : smpp->conn->alt_dcs)); /* set protocol id */ if(msg->sms.pid != SMS_PARAM_UNDEFINED) pdu->u.submit_sm.protocol_id = msg->sms.pid; /* * set the esm_class field * default is store and forward, plus udh and rpi if requested */ pdu->u.submit_sm.esm_class = ESM_CLASS_SUBMIT_STORE_AND_FORWARD_MODE; if (octstr_len(msg->sms.udhdata)) pdu->u.submit_sm.esm_class = pdu->u.submit_sm.esm_class | ESM_CLASS_SUBMIT_UDH_INDICATOR; if (msg->sms.rpi > 0) pdu->u.submit_sm.esm_class = pdu->u.submit_sm.esm_class | ESM_CLASS_SUBMIT_RPI; /* * set data segments and length */ pdu->u.submit_sm.short_message = octstr_duplicate(msg->sms.msgdata); /* * only re-encoding if using default smsc charset that is defined via * alt-charset in smsc group and if MT is not binary */ if (msg->sms.coding == DC_7BIT || (msg->sms.coding == DC_UNDEF && octstr_len(msg->sms.udhdata) == 0)) { /* * consider 3 cases: * a) data_coding 0xFX: encoding should always be GSM 03.38 charset * b) data_coding 0x00: encoding may be converted according to alt-charset * c) data_coding 0x00: assume GSM 03.38 charset if alt-charset is not defined */ if ((pdu->u.submit_sm.data_coding & 0xF0) || (pdu->u.submit_sm.data_coding == 0 && !smpp->alt_charset)) { charset_utf8_to_gsm(pdu->u.submit_sm.short_message); } else if (pdu->u.submit_sm.data_coding == 0 && smpp->alt_charset) { /* * convert to the given alternative charset */ if (charset_convert(pdu->u.submit_sm.short_message, SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_charset)) != 0) error(0, "Failed to convert msgdata from charset <%s> to <%s>, will send as is.", SMPP_DEFAULT_CHARSET, octstr_get_cstr(smpp->alt_charset)); } } /* prepend udh if present */ if (octstr_len(msg->sms.udhdata)) { octstr_insert(pdu->u.submit_sm.short_message, msg->sms.udhdata, 0); } pdu->u.submit_sm.sm_length = octstr_len(pdu->u.submit_sm.short_message); /* * check for validity and defered settings * were message value has higher priiority then smsc config group value */ validity = msg->sms.validity >= 0 ? msg->sms.validity : smpp->validityperiod; if (validity >= 0) { struct tm tm = gw_gmtime(time(NULL) + validity * 60); pdu->u.submit_sm.validity_period = octstr_format("%02d%02d%02d%02d%02d%02d000+", tm.tm_year % 100, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec); } if (msg->sms.deferred >= 0) { struct tm tm = gw_gmtime(time(NULL) + msg->sms.deferred * 60); pdu->u.submit_sm.schedule_delivery_time = octstr_format("%02d%02d%02d%02d%02d%02d000+", tm.tm_year % 100, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec); } /* ask for the delivery reports if needed */ if (DLR_IS_SUCCESS_OR_FAIL(msg->sms.dlr_mask)) pdu->u.submit_sm.registered_delivery = 1; else if (DLR_IS_FAIL(msg->sms.dlr_mask) && !DLR_IS_SUCCESS(msg->sms.dlr_mask)) pdu->u.submit_sm.registered_delivery = 2; /* set priority */ if (msg->sms.priority >= 0 && msg->sms.priority <= 3) pdu->u.submit_sm.priority_flag = msg->sms.priority; else pdu->u.submit_sm.priority_flag = smpp->priority; /* set more messages to send */ if (smpp->version > 0x33 && msg->sms.msg_left > 0) pdu->u.submit_sm.more_messages_to_send = 1; return pdu; }

Here is the call graph for this function:

Connection* open_receiver (  SMPP *  smpp  )  [static]

Definition at line 1112 of file smsc_smpp.c. References SMPP::address_range, SMPP::bind_addr_npi, SMPP::bind_addr_ton, bind_receiver, SMPP::conn, conn_open_tcp(), counter_increase(), error(), SMPP::host, smscconn::id, SMPP::message_id_counter, octstr_create, octstr_duplicate, octstr_get_cstr, smscconn::our_host, SMPP::password, SMPP::receive_port, send_pdu(), smpp_pdu_create(), smpp_pdu_destroy(), SMPP::system_type, SMPP_PDU::u, SMPP::username, and SMPP::version. Referenced by io_thread(). { SMPP_PDU *bind; Connection *conn; conn = conn_open_tcp(smpp->host, smpp->receive_port, smpp->conn->our_host ); if (conn == NULL) { error(0, "SMPP[%s]: Couldn't connect to server.", octstr_get_cstr(smpp->conn->id)); return NULL; } bind = smpp_pdu_create(bind_receiver, counter_increase(smpp->message_id_counter)); bind->u.bind_receiver.system_id = octstr_duplicate(smpp->username); bind->u.bind_receiver.password = octstr_duplicate(smpp->password); if (smpp->system_type == NULL) bind->u.bind_receiver.system_type = octstr_create("VMA"); else bind->u.bind_receiver.system_type = octstr_duplicate(smpp->system_type); bind->u.bind_receiver.interface_version = smpp->version; bind->u.bind_receiver.address_range = octstr_duplicate(smpp->address_range); bind->u.bind_receiver.addr_ton = smpp->bind_addr_ton; bind->u.bind_receiver.addr_npi = smpp->bind_addr_npi; send_pdu(conn, smpp->conn->id, bind); smpp_pdu_destroy(bind); return conn; }

Here is the call graph for this function:

Connection* open_transceiver (  SMPP *  smpp  )  [static]

Definition at line 1076 of file smsc_smpp.c. References SMPP::address_range, SMPP::bind_addr_npi, SMPP::bind_addr_ton, bind_transceiver, SMPP::conn, conn_open_tcp(), counter_increase(), error(), SMPP::host, smscconn::id, SMPP::message_id_counter, octstr_create, octstr_duplicate, octstr_get_cstr, smscconn::our_host, SMPP::password, send_pdu(), smpp_pdu_create(), smpp_pdu_destroy(), SMPP::system_type, SMPP::transmit_port, SMPP_PDU::u, SMPP::username, and SMPP::version. Referenced by io_thread(). { SMPP_PDU *bind; Connection *conn; conn = conn_open_tcp(smpp->host, smpp->transmit_port, smpp->conn->our_host ); if (conn == NULL) { error(0, "SMPP[%s]: Couldn't connect to server.", octstr_get_cstr(smpp->conn->id)); return NULL; } bind = smpp_pdu_create(bind_transceiver, counter_increase(smpp->message_id_counter)); bind->u.bind_transceiver.system_id = octstr_duplicate(smpp->username); bind->u.bind_transceiver.password = octstr_duplicate(smpp->password); if (smpp->system_type == NULL) bind->u.bind_transceiver.system_type = octstr_create("VMA"); else bind->u.bind_transceiver.system_type = octstr_duplicate(smpp->system_type); bind->u.bind_transceiver.interface_version = smpp->version; bind->u.bind_transceiver.address_range = octstr_duplicate(smpp->address_range); bind->u.bind_transceiver.addr_ton = smpp->bind_addr_ton; bind->u.bind_transceiver.addr_npi = smpp->bind_addr_npi; send_pdu(conn, smpp->conn->id, bind); smpp_pdu_destroy(bind); return conn; }

Here is the call graph for this function:

Connection* open_transmitter (  SMPP *  smpp  )  [static]

Definition at line 1038 of file smsc_smpp.c. References SMPP::address_range, SMPP::bind_addr_npi, SMPP::bind_addr_ton, bind_transmitter, SMPP::conn, conn_open_tcp(), counter_increase(), error(), SMPP::host, smscconn::id, SMPP::message_id_counter, octstr_create, octstr_duplicate, octstr_get_cstr, smscconn::our_host, SMPP::password, send_pdu(), smpp_pdu_create(), smpp_pdu_destroy(), SMPP::system_type, SMPP::transmit_port, SMPP_PDU::u, SMPP::username, and SMPP::version. Referenced by io_thread(). { SMPP_PDU *bind; Connection *conn; conn = conn_open_tcp(smpp->host, smpp->transmit_port, smpp->conn->our_host ); if (conn == NULL) { error(0, "SMPP[%s]: Couldn't connect to server.", octstr_get_cstr(smpp->conn->id)); return NULL; } bind = smpp_pdu_create(bind_transmitter, counter_increase(smpp->message_id_counter)); bind->u.bind_transmitter.system_id = octstr_duplicate(smpp->username); bind->u.bind_transmitter.password = octstr_duplicate(smpp->password); if (smpp->system_type == NULL) bind->u.bind_transmitter.system_type = octstr_create("VMA"); else bind->u.bind_transmitter.system_type = octstr_duplicate(smpp->system_type); bind->u.bind_transmitter.interface_version = smpp->version; bind->u.bind_transmitter.address_range = octstr_duplicate(smpp->address_range); bind->u.bind_transmitter.addr_ton = smpp->bind_addr_ton; bind->u.bind_transmitter.addr_npi = smpp->bind_addr_npi; send_pdu(conn, smpp->conn->id, bind); smpp_pdu_destroy(bind); return conn; }

Here is the call graph for this function:

Msg* pdu_to_msg (  SMPP *  smpp, SMPP_PDU *  pdu, long *  reason )  [static]

Definition at line 416 of file smsc_smpp.c. References SMPP::alt_addr_charset, SMPP::alt_charset, charset_convert(), charset_gsm_to_utf8(), SMPP::conn, convert_addr_from_pdu(), DC_7BIT, DC_UNDEF, dcs_to_fields(), debug(), deliver_sm, error(), gw_assert, smscconn::id, msg_create, msg_destroy(), octstr_copy, octstr_delete(), octstr_get_char(), octstr_get_cstr, octstr_len(), pdu, reason, SMPP_DEFAULT_CHARSET, sms, SMPP_PDU::type, SMPP_PDU::u, and SMPP::version. Referenced by handle_pdu(). { Msg *msg; int ton, npi; gw_assert(pdu->type == deliver_sm); msg = msg_create(sms); gw_assert(msg != NULL); *reason = SMPP_ESME_ROK; /* * Reset source addr to have a prefixed '+' in case we have an * intl. TON to allow backend boxes (ie. smsbox) to distinguish * between national and international numbers. */ ton = pdu->u.deliver_sm.source_addr_ton; npi = pdu->u.deliver_sm.source_addr_npi; /* check source addr */ if ((*reason = convert_addr_from_pdu(smpp->conn->id, pdu->u.deliver_sm.source_addr, ton, npi, smpp->alt_addr_charset)) != SMPP_ESME_ROK) goto error; msg->sms.sender = pdu->u.deliver_sm.source_addr; pdu->u.deliver_sm.source_addr = NULL; /* * Follows SMPP spec. v3.4. issue 1.2 * it's not allowed to have destination_addr NULL */ if (pdu->u.deliver_sm.destination_addr == NULL) { error(0, "SMPP[%s]: Mallformed destination_addr `%s', may not be empty. " "Discarding MO message.", octstr_get_cstr(smpp->conn->id), octstr_get_cstr(pdu->u.deliver_sm.destination_addr)); *reason = SMPP_ESME_RINVDSTADR; goto error; } /* Same reset of destination number as for source */ ton = pdu->u.deliver_sm.dest_addr_ton; npi = pdu->u.deliver_sm.dest_addr_npi; /* check destination addr */ if ((*reason = convert_addr_from_pdu(smpp->conn->id, pdu->u.deliver_sm.destination_addr, ton, npi, smpp->alt_addr_charset)) != SMPP_ESME_ROK) goto error; msg->sms.receiver = pdu->u.deliver_sm.destination_addr; pdu->u.deliver_sm.destination_addr = NULL; /* SMSCs use service_type for billing information */ msg->sms.binfo = pdu->u.deliver_sm.service_type; pdu->u.deliver_sm.service_type = NULL; if (pdu->u.deliver_sm.esm_class & ESM_CLASS_SUBMIT_RPI) msg->sms.rpi = 1; /* * Check for message_payload if version > 0x33 and sm_length == 0 * Note: SMPP spec. v3.4. doesn't allow to send both: message_payload & short_message! */ if (smpp->version > 0x33 && pdu->u.deliver_sm.sm_length == 0 && pdu->u.deliver_sm.message_payload) { msg->sms.msgdata = pdu->u.deliver_sm.message_payload; pdu->u.deliver_sm.message_payload = NULL; } else { msg->sms.msgdata = pdu->u.deliver_sm.short_message; pdu->u.deliver_sm.short_message = NULL; } /* * Encode udh if udhi set * for reference see GSM03.40, section 9.2.3.24 */ if (pdu->u.deliver_sm.esm_class & ESM_CLASS_SUBMIT_UDH_INDICATOR) { int udhl; udhl = octstr_get_char(msg->sms.msgdata, 0) + 1; debug("bb.sms.smpp",0,"SMPP[%s]: UDH length read as %d", octstr_get_cstr(smpp->conn->id), udhl); if (udhl > octstr_len(msg->sms.msgdata)) { error(0, "SMPP[%s]: Mallformed UDH length indicator 0x%03x while message length " "0x%03lx. Discarding MO message.", octstr_get_cstr(smpp->conn->id), udhl, octstr_len(msg->sms.msgdata)); *reason = SMPP_ESME_RINVESMCLASS; goto error; } msg->sms.udhdata = octstr_copy(msg->sms.msgdata, 0, udhl); octstr_delete(msg->sms.msgdata, 0, udhl); } dcs_to_fields(&msg, pdu->u.deliver_sm.data_coding); /* handle default data coding */ switch (pdu->u.deliver_sm.data_coding) { case 0x00: /* default SMSC alphabet */ /* * try to convert from something interesting if specified so * unless it was specified binary, ie. UDH indicator was detected */ if (smpp->alt_charset && msg->sms.coding != DC_8BIT) { if (charset_convert(msg->sms.msgdata, octstr_get_cstr(smpp->alt_charset), SMPP_DEFAULT_CHARSET) != 0) error(0, "Failed to convert msgdata from charset <%s> to <%s>, will leave as is.", octstr_get_cstr(smpp->alt_charset), SMPP_DEFAULT_CHARSET); msg->sms.coding = DC_7BIT; } else { /* assume GSM 03.38 7-bit alphabet */ charset_gsm_to_utf8(msg->sms.msgdata); msg->sms.coding = DC_7BIT; } break; case 0x01: /* ASCII or IA5 - not sure if I need to do anything */ case 0x03: /* ISO-8859-1 - do nothing */ msg->sms.coding = DC_7BIT; break; case 0x02: /* 8 bit binary - do nothing */ case 0x04: /* 8 bit binary - do nothing */ msg->sms.coding = DC_8BIT; break; case 0x05: /* JIS - what do I do with that ? */ break; case 0x06: /* Cyrllic - iso-8859-5, I'll convert to unicode */ if (charset_convert(msg->sms.msgdata, "ISO-8859-5", "UTF-8") != 0) error(0, "Failed to convert msgdata from cyrllic to UTF-8, will leave as is"); msg->sms.coding = DC_7BIT; break; case 0x07: /* Hebrew iso-8859-8, I'll convert to unicode */ if (charset_convert(msg->sms.msgdata, "ISO-8859-8", "UTF-8") != 0) error(0, "Failed to convert msgdata from hebrew to UTF-8, will leave as is"); msg->sms.coding = DC_7BIT; break; case 0x08: /* unicode UCS-2, yey */ msg->sms.coding = DC_UCS2; break; /* * don't much care about the others, * you implement them if you feel like it */ default: /* * some of smsc send with dcs from GSM 03.38 , but these are reserved in smpp spec. * So we just look decoded values from dcs_to_fields and if none there make our assumptions. * if we have an UDH indicator, we assume DC_8BIT. */ if (msg->sms.coding == DC_UNDEF && pdu->u.deliver_sm.esm_class & ESM_CLASS_SUBMIT_UDH_INDICATOR) msg->sms.coding = DC_8BIT; else if (msg->sms.coding == DC_7BIT || msg->sms.coding == DC_UNDEF) { /* assume GSM 7Bit , reencode */ msg->sms.coding = DC_7BIT; charset_gsm_to_utf8(msg->sms.msgdata); } } msg->sms.pid = pdu->u.deliver_sm.protocol_id; /* set priority flag */ msg->sms.priority = pdu->u.deliver_sm.priority_flag; return msg; error: msg_destroy(msg); return NULL; }

Here is the call graph for this function:

long queued_cb (  SMSCConn *  conn  )  [static]

Definition at line 1906 of file smsc_smpp.c. References smscconn::data, gwlist_len(), smscconn::load, SMPP::msgs_to_send, SMSCConn, SMSCCONN_DEAD, and smscconn::status. { SMPP *smpp; smpp = conn->data; conn->load = (smpp ? (conn->status != SMSCCONN_DEAD ? gwlist_len(smpp->msgs_to_send) : 0) : 0); return conn->load; }

Here is the call graph for this function:

int read_pdu (  SMPP *  smpp, Connection *  conn, long *  len, SMPP_PDU **  pdu )  [static]

Definition at line 297 of file smsc_smpp.c. References SMPP::conn, conn_eof(), conn_error(), debug(), error(), smscconn::id, octstr_destroy(), octstr_dump, octstr_get_cstr, pdu, smpp_pdu_read_data(), smpp_pdu_read_len(), and smpp_pdu_unpack(). Referenced by io_thread(), and smasi_thread(). { Octstr *os; if (*len == 0) { *len = smpp_pdu_read_len(conn); if (*len == -1) { error(0, "SMPP[%s]: Server sent garbage, ignored.", octstr_get_cstr(smpp->conn->id)); return -1; } else if (*len == 0) { if (conn_eof(conn) || conn_error(conn)) return -1; return 0; } } os = smpp_pdu_read_data(conn, *len); if (os == NULL) { if (conn_eof(conn) || conn_error(conn)) return -1; return 0; } *len = 0; *pdu = smpp_pdu_unpack(os); if (*pdu == NULL) { error(0, "SMPP[%s]: PDU unpacking failed.", octstr_get_cstr(smpp->conn->id)); debug("bb.sms.smpp", 0, "SMPP[%s]: Failed PDU follows.", octstr_get_cstr(smpp->conn->id)); octstr_dump(os, 0); octstr_destroy(os); return -1; } octstr_destroy(os); return 1; }

Here is the call graph for this function:

void send_enquire_link (  SMPP *  smpp, Connection *  conn, long *  last_sent )  [static]

Definition at line 936 of file smsc_smpp.c. References SMPP::conn, conn_write(), counter_increase(), date_universal_now(), dump_pdu, enquire_link, SMPP::enquire_link_interval, smscconn::id, SMPP::message_id_counter, octstr_destroy(), pdu, smpp_pdu_create(), smpp_pdu_destroy(), and smpp_pdu_pack(). Referenced by io_thread(), and smasi_thread(). { SMPP_PDU *pdu; Octstr *os; if (date_universal_now() - *last_sent < smpp->enquire_link_interval) return; *last_sent = date_universal_now(); pdu = smpp_pdu_create(enquire_link, counter_increase(smpp->message_id_counter)); dump_pdu("Sending enquire link:", smpp->conn->id, pdu); os = smpp_pdu_pack(pdu); if (os) conn_write(conn, os); /* Write errors checked by caller. */ octstr_destroy(os); smpp_pdu_destroy(pdu); }

Here is the call graph for this function:

void send_messages (  SMPP *  smpp, Connection *  conn, long *  pending_submits )  [static]

Definition at line 984 of file smsc_smpp.c. References bb_smscconn_send_failed(), SMPP::conn, dict_put(), gwlist_extract_first(), gwthread_sleep(), smscconn::id, SMPP::max_pending_submits, msg_to_pdu(), SMPP::msgs_to_send, octstr_create, octstr_destroy(), octstr_format(), pdu, send_pdu(), SMPP::sent_msgs, smpp_msg_create(), smpp_pdu_destroy(), SMSCCONN_FAILED_MALFORMED, SMSCCONN_FAILED_TEMPORARILY, smscconn::throughput, and SMPP_PDU::u. Referenced by io_thread(), and smasi_thread(). { Msg *msg; SMPP_PDU *pdu; Octstr *os; double delay = 0; if (*pending_submits == -1) return; if (smpp->conn->throughput > 0) { delay = 1.0 / smpp->conn->throughput; } while (*pending_submits < smpp->max_pending_submits) { /* Get next message, quit if none to be sent */ msg = gwlist_extract_first(smpp->msgs_to_send); if (msg == NULL) break; /* Send PDU, record it as waiting for ack from SMS center */ pdu = msg_to_pdu(smpp, msg); if (pdu == NULL) { bb_smscconn_send_failed(smpp->conn, msg, SMSCCONN_FAILED_MALFORMED, octstr_create("MALFORMED SMS")); continue; } /* check for write errors */ if (send_pdu(conn, smpp->conn->id, pdu) == 0) { struct smpp_msg *smpp_msg = smpp_msg_create(msg); os = octstr_format("%ld", pdu->u.submit_sm.sequence_number); dict_put(smpp->sent_msgs, os, smpp_msg); smpp_pdu_destroy(pdu); octstr_destroy(os); ++(*pending_submits); /* * obey throughput speed limit, if any. */ if (smpp->conn->throughput > 0) gwthread_sleep(delay); } else { /* write error occurs */ smpp_pdu_destroy(pdu); bb_smscconn_send_failed(smpp->conn, msg, SMSCCONN_FAILED_TEMPORARILY, NULL); break; } } }

Here is the call graph for this function:

int send_msg_cb (  SMSCConn *  conn, Msg *  msg )  [static]

Definition at line 1917 of file smsc_smpp.c. References smscconn::data, gwlist_produce(), gwthread_wakeup(), msg_duplicate(), SMPP::msgs_to_send, SMSCConn, and SMPP::transmitter. { SMPP *smpp; smpp = conn->data; gwlist_produce(smpp->msgs_to_send, msg_duplicate(msg)); gwthread_wakeup(smpp->transmitter); return 0; }

Here is the call graph for this function:

int send_pdu (  Connection *  conn, Octstr *  id, SMPP_PDU *  pdu )  [static]

Definition at line 968 of file smsc_smpp.c. References conn_write(), dump_pdu, octstr_destroy(), pdu, and smpp_pdu_pack(). { Octstr *os; int ret; dump_pdu("Sending PDU:", id, pdu); os = smpp_pdu_pack(pdu); if (os) ret = conn_write(conn, os); /* Caller checks for write errors later */ else ret = -1; octstr_destroy(os); return ret; }

Here is the call graph for this function:

void send_unbind (  SMPP *  smpp, Connection *  conn )  [static]

Definition at line 955 of file smsc_smpp.c. References SMPP::conn, conn_write(), counter_increase(), dump_pdu, smscconn::id, SMPP::message_id_counter, octstr_destroy(), pdu, smpp_pdu_create(), smpp_pdu_destroy(), smpp_pdu_pack(), and unbind. Referenced by io_thread(). { SMPP_PDU *pdu; Octstr *os; pdu = smpp_pdu_create(unbind, counter_increase(smpp->message_id_counter)); dump_pdu("Sending unbind:", smpp->conn->id, pdu); os = smpp_pdu_pack(pdu); conn_write(conn, os); octstr_destroy(os); smpp_pdu_destroy(pdu); }

Here is the call graph for this function:

int shutdown_cb (  SMSCConn *  conn, int  finish_sending )  [static]

Definition at line 1928 of file smsc_smpp.c. References bb_smscconn_killed(), smscconn::data, debug(), gwthread_join(), gwthread_wakeup(), smscconn::name, octstr_get_cstr, SMPP::quitting, SMPP::receiver, smpp_destroy(), SMSCConn, smscconn::status, SMPP::transmitter, and smscconn::why_killed. { SMPP *smpp; debug("bb.smpp", 0, "Shutting down SMSCConn %s (%s)", octstr_get_cstr(conn->name), finish_sending ? "slow" : "instant"); conn->why_killed = SMSCCONN_KILLED_SHUTDOWN; /* XXX implement finish_sending */ smpp = conn->data; smpp->quitting = 1; if (smpp->transmitter != -1) { gwthread_wakeup(smpp->transmitter); gwthread_join(smpp->transmitter); } if (smpp->receiver != -1) { gwthread_wakeup(smpp->receiver); gwthread_join(smpp->receiver); } smpp_destroy(smpp); debug("bb.smpp", 0, "SMSCConn %s shut down.", octstr_get_cstr(conn->name)); conn->status = SMSCCONN_DEAD; bb_smscconn_killed(); return 0; }

Here is the call graph for this function:

SMPP* smpp_create (  SMSCConn *  conn, Octstr *  host, int  transmit_port, int  receive_port, Octstr *  system_type, Octstr *  username, Octstr *  password, Octstr *  address_range, int  source_addr_ton, int  source_addr_npi, int  dest_addr_ton, int  dest_addr_npi, int  enquire_link_interval, int  max_pending_submits, int  version, int  priority, int  validity, Octstr *  my_number, int  smpp_msg_id_type, int  autodetect_addr, Octstr *  alt_charset, Octstr *  alt_addr_charset, Octstr *  service_type, long  connection_timeout, long  wait_ack, int  wait_ack_action )  [static]

Definition at line 209 of file smsc_smpp.c. References counter_create(), counter_increase(), dict_create(), gwlist_add_producer(), gwlist_create, SMPP::msgs_to_send, octstr_duplicate, password, SMPP::receiver, SMSCConn, SMPP::transmitter, and username. Referenced by smsc_smpp_create(). { SMPP *smpp; smpp = gw_malloc(sizeof(*smpp)); smpp->transmitter = -1; smpp->receiver = -1; smpp->msgs_to_send = gwlist_create(); smpp->sent_msgs = dict_create(max_pending_submits, NULL); gwlist_add_producer(smpp->msgs_to_send); smpp->received_msgs = gwlist_create(); smpp->message_id_counter = counter_create(); counter_increase(smpp->message_id_counter); smpp->host = octstr_duplicate(host); smpp->system_type = octstr_duplicate(system_type); smpp->username = octstr_duplicate(username); smpp->password = octstr_duplicate(password); smpp->address_range = octstr_duplicate(address_range); smpp->source_addr_ton = source_addr_ton; smpp->source_addr_npi = source_addr_npi; smpp->dest_addr_ton = dest_addr_ton; smpp->dest_addr_npi = dest_addr_npi; smpp->my_number = octstr_duplicate(my_number); smpp->service_type = octstr_duplicate(service_type); smpp->transmit_port = transmit_port; smpp->receive_port = receive_port; smpp->enquire_link_interval = enquire_link_interval; smpp->max_pending_submits = max_pending_submits; smpp->quitting = 0; smpp->version = version; smpp->priority = priority; smpp->validityperiod = validity; smpp->conn = conn; smpp->throttling_err_time = 0; smpp->smpp_msg_id_type = smpp_msg_id_type; smpp->autodetect_addr = autodetect_addr; smpp->alt_charset = octstr_duplicate(alt_charset); smpp->alt_addr_charset = octstr_duplicate(alt_addr_charset); smpp->connection_timeout = connection_timeout; smpp->wait_ack = wait_ack; smpp->wait_ack_action = wait_ack_action; smpp->bind_addr_ton = 0; smpp->bind_addr_npi = 0; return smpp; }

Here is the call graph for this function:

void smpp_destroy (  SMPP *  smpp  )  [static]

Definition at line 268 of file smsc_smpp.c. References SMPP::address_range, SMPP::alt_addr_charset, SMPP::alt_charset, counter_destroy(), dict_destroy(), gwlist_destroy(), SMPP::host, SMPP::message_id_counter, msg_destroy_item(), SMPP::msgs_to_send, SMPP::my_number, octstr_destroy(), SMPP::password, SMPP::received_msgs, SMPP::sent_msgs, SMPP::service_type, SMPP::system_type, and SMPP::username. Referenced by shutdown_cb(), and smsc_smpp_create(). { if (smpp != NULL) { gwlist_destroy(smpp->msgs_to_send, msg_destroy_item); dict_destroy(smpp->sent_msgs); gwlist_destroy(smpp->received_msgs, msg_destroy_item); counter_destroy(smpp->message_id_counter); octstr_destroy(smpp->host); octstr_destroy(smpp->username); octstr_destroy(smpp->password); octstr_destroy(smpp->system_type); octstr_destroy(smpp->service_type); octstr_destroy(smpp->address_range); octstr_destroy(smpp->my_number); octstr_destroy(smpp->alt_charset); octstr_destroy(smpp->alt_addr_charset); gw_free(smpp); } }

Here is the call graph for this function:

struct smpp_msg* smpp_msg_create (  Msg *  msg  )  [static]

Definition at line 181 of file smsc_smpp.c. References gw_assert, smpp_msg::msg, result, and smpp_msg::sent_time. Referenced by send_messages(). { struct smpp_msg *result = gw_malloc(sizeof(struct smpp_msg)); gw_assert(result != NULL); result->sent_time = time(NULL); result->msg = msg; return result; }

void smpp_msg_destroy (  struct smpp_msg *  msg, int  destroy_msg )  [static]

Definition at line 196 of file smsc_smpp.c. References smpp_msg::msg, and msg_destroy(). Referenced by do_queue_cleanup(), handle_pdu(), and io_thread(). { /* sanity check */ if (msg == NULL) return; if (destroy_msg && msg->msg != NULL) msg_destroy(msg->msg); gw_free(msg); }

Here is the call graph for this function:

long smpp_status_to_smscconn_failure_reason (  long  status  )  [static]

Definition at line 717 of file smsc_smpp.c. References SMPP_ESME_RMSGQFUL, SMPP_ESME_RSYSERR, SMPP_ESME_RTHROTTLED, and SMPP_ESME_RX_T_APPN. Referenced by handle_pdu(). { switch(status) { case SMPP_ESME_RMSGQFUL: case SMPP_ESME_RTHROTTLED: case SMPP_ESME_RX_T_APPN: case SMPP_ESME_RSYSERR: return SMSCCONN_FAILED_TEMPORARILY; break; default: return SMSCCONN_FAILED_REJECTED; } }

int smsc_smpp_create (  SMSCConn *  conn, CfgGroup *  grp )

Definition at line 1966 of file smsc_smpp.c. References SMPP::bind_addr_npi, SMPP::bind_addr_ton, cfg_get, cfg_get_bool(), cfg_get_integer(), SMPP::conn, smscconn::data, error(), gwthread_create, gwthread_join(), gwthread_wakeup(), smscconn::id, io_arg_create(), io_thread(), smscconn::name, octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_imm(), octstr_len(), ok, panic, password, port, smscconn::queued, SMPP::quitting, SMPP::receiver, smscconn::send_msg, smscconn::shutdown, smpp_create(), smpp_destroy(), SMSCConn, smscconn::status, SMPP::transmitter, username, and warning(). Referenced by smscconn_create(). { Octstr *host; long port; long receive_port; Octstr *username; Octstr *password; Octstr *system_id; Octstr *system_type; Octstr *address_range; long source_addr_ton; long source_addr_npi; long dest_addr_ton; long dest_addr_npi; Octstr *my_number; Octstr *service_type; SMPP *smpp; int ok; int transceiver_mode; Octstr *smsc_id; long enquire_link_interval; long max_pending_submits; long version; long priority; long validity; long smpp_msg_id_type; int autodetect_addr; Octstr *alt_charset; Octstr *alt_addr_charset; long connection_timeout, wait_ack, wait_ack_action; my_number = alt_addr_charset = alt_charset = NULL; transceiver_mode = 0; autodetect_addr = 1; host = cfg_get(grp, octstr_imm("host")); if (cfg_get_integer(&port, grp, octstr_imm("port")) == -1) port = 0; if (cfg_get_integer(&receive_port, grp, octstr_imm("receive-port")) == -1) receive_port = 0; cfg_get_bool(&transceiver_mode, grp, octstr_imm("transceiver-mode")); username = cfg_get(grp, octstr_imm("smsc-username")); password = cfg_get(grp, octstr_imm("smsc-password")); system_type = cfg_get(grp, octstr_imm("system-type")); address_range = cfg_get(grp, octstr_imm("address-range")); my_number = cfg_get(grp, octstr_imm("my-number")); service_type = cfg_get(grp, octstr_imm("service-type")); system_id = cfg_get(grp, octstr_imm("system-id")); if (system_id != NULL) { warning(0, "SMPP: obsolete system-id variable is set, " "use smsc-username instead."); if (username == NULL) { warning(0, "SMPP: smsc-username not set, using system-id instead"); username = system_id; } else octstr_destroy(system_id); } /* * check if timing values have been configured, otherwise * use the predefined default values. */ if (cfg_get_integer(&enquire_link_interval, grp, octstr_imm("enquire-link-interval")) == -1) enquire_link_interval = SMPP_ENQUIRE_LINK_INTERVAL; if (cfg_get_integer(&max_pending_submits, grp, octstr_imm("max-pending-submits")) == -1) max_pending_submits = SMPP_MAX_PENDING_SUBMITS; /* Check that config is OK */ ok = 1; if (host == NULL) { error(0,"SMPP: Configuration file doesn't specify host"); ok = 0; } if (username == NULL) { error(0, "SMPP: Configuration file doesn't specify username."); ok = 0; } if (password == NULL) { error(0, "SMPP: Configuration file doesn't specify password."); ok = 0; } if (system_type == NULL) { error(0, "SMPP: Configuration file doesn't specify system-type."); ok = 0; } if (octstr_len(service_type) > 6) { error(0, "SMPP: Service type must be 6 characters or less."); ok = 0; } if (!ok) return -1; /* if the ton and npi values are forced, set them, else set them to -1 */ if (cfg_get_integer(&source_addr_ton, grp, octstr_imm("source-addr-ton")) == -1) source_addr_ton = -1; if (cfg_get_integer(&source_addr_npi, grp, octstr_imm("source-addr-npi")) == -1) source_addr_npi = -1; if (cfg_get_integer(&dest_addr_ton, grp, octstr_imm("dest-addr-ton")) == -1) dest_addr_ton = -1; if (cfg_get_integer(&dest_addr_npi, grp, octstr_imm("dest-addr-npi")) == -1) dest_addr_npi = -1; /* if source addr autodetection should be used set this to 1 */ if (cfg_get_bool(&autodetect_addr, grp, octstr_imm("source-addr-autodetect")) == -1) autodetect_addr = 1; /* default is autodetect if no option defined */ /* check for any specified interface version */ if (cfg_get_integer(&version, grp, octstr_imm("interface-version")) == -1) version = SMPP_DEFAULT_VERSION; else /* convert decimal to BCD */ version = ((version / 10) << 4) + (version % 10); /* check for any specified priority value in range [0-5] */ if (cfg_get_integer(&priority, grp, octstr_imm("priority")) == -1) priority = SMPP_DEFAULT_PRIORITY; else if (priority < 0 || priority > 3) panic(0, "SMPP: Invalid value for priority directive in configuraton (allowed range 0-3)."); /* check for message validity period */ if (cfg_get_integer(&validity, grp, octstr_imm("validityperiod")) == -1) validity = -1; else if (validity < 0) panic(0, "SMPP: Invalid value for validity period (allowed value >= 0)."); /* set the msg_id type variable for this SMSC */ if (cfg_get_integer(&smpp_msg_id_type, grp, octstr_imm("msg-id-type")) == -1) { /* * defaults to C string "as-is" style */ smpp_msg_id_type = -1; } else { if (smpp_msg_id_type < 0 || smpp_msg_id_type > 3) panic(0,"SMPP: Invalid value for msg-id-type directive in configuraton"); } /* check for an alternative charset */ alt_charset = cfg_get(grp, octstr_imm("alt-charset")); alt_addr_charset = cfg_get(grp, octstr_imm("alt-addr-charset")); /* check for connection timeout */ if (cfg_get_integer(&connection_timeout, grp, octstr_imm("connection-timeout")) == -1) connection_timeout = SMPP_DEFAULT_CONNECTION_TIMEOUT; /* check if wait-ack timeout set */ if (cfg_get_integer(&wait_ack, grp, octstr_imm("wait-ack")) == -1) wait_ack = SMPP_DEFAULT_WAITACK; if (cfg_get_integer(&wait_ack_action, grp, octstr_imm("wait-ack-expire")) == -1) wait_ack_action = SMPP_WAITACK_REQUEUE; if (wait_ack_action > 0x03 || wait_ack_action < 0) panic(0, "SMPP: Invalid wait-ack-expire directive in configuration."); smpp = smpp_create(conn, host, port, receive_port, system_type, username, password, address_range, source_addr_ton, source_addr_npi, dest_addr_ton, dest_addr_npi, enquire_link_interval, max_pending_submits, version, priority, validity, my_number, smpp_msg_id_type, autodetect_addr, alt_charset, alt_addr_charset, service_type, connection_timeout, wait_ack, wait_ack_action); cfg_get_integer(&smpp->bind_addr_ton, grp, octstr_imm("bind-addr-ton")); cfg_get_integer(&smpp->bind_addr_npi, grp, octstr_imm("bind-addr-npi")); conn->data = smpp; conn->name = octstr_format("SMPP:%S:%d/%d:%S:%S", host, port, (receive_port ? receive_port : port), username, system_type); smsc_id = cfg_get(grp, octstr_imm("smsc-id")); if (smsc_id == NULL) { conn->id = octstr_duplicate(conn->name); } octstr_destroy(host); octstr_destroy(username); octstr_destroy(password); octstr_destroy(system_type); octstr_destroy(address_range); octstr_destroy(my_number); octstr_destroy(smsc_id); octstr_destroy(alt_charset); octstr_destroy(alt_addr_charset); octstr_destroy(service_type); conn->status = SMSCCONN_CONNECTING; /* * I/O threads are only started if the corresponding ports * have been configured with positive numbers. Use 0 to * disable the creation of the corresponding thread. */ if (port != 0) smpp->transmitter = gwthread_create(io_thread, io_arg_create(smpp, (transceiver_mode ? 2 : 1))); if (receive_port != 0) smpp->receiver = gwthread_create(io_thread, io_arg_create(smpp, 0)); if ((port != 0 && smpp->transmitter == -1) || (receive_port != 0 && smpp->receiver == -1)) { error(0, "SMPP[%s]: Couldn't start I/O threads.", octstr_get_cstr(smpp->conn->id)); smpp->quitting = 1; if (smpp->transmitter != -1) { gwthread_wakeup(smpp->transmitter); gwthread_join(smpp->transmitter); } if (smpp->receiver != -1) { gwthread_wakeup(smpp->receiver); gwthread_join(smpp->receiver); } smpp_destroy(conn->data); return -1; } conn->shutdown = shutdown_cb; conn->queued = queued_cb; conn->send_msg = send_msg_cb; return 0; }

Here is the call graph for this function:

long smscconn_failure_reason_to_smpp_status (  long  reason  )  [static]

Definition at line 1305 of file smsc_smpp.c. References SMSCCONN_FAILED_QFULL, SMSCCONN_FAILED_REJECTED, SMSCCONN_FAILED_TEMPORARILY, and SMSCCONN_SUCCESS. Referenced by handle_pdu(). { switch (reason) { case SMSCCONN_FAILED_REJECTED: return SMPP_ESME_RX_R_APPN; case SMSCCONN_SUCCESS: return SMPP_ESME_ROK; case SMSCCONN_FAILED_QFULL: case SMSCCONN_FAILED_TEMPORARILY: return SMPP_ESME_RX_T_APPN; } return SMPP_ESME_RX_T_APPN; }

See file LICENSE for details about the license agreement for using, modifying, copying or deriving work from this software.