test_cimd2.c File Reference

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <ctype.h>
#include <stdarg.h>
#include <limits.h>
#include <unistd.h>
#include <time.h>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "gwlib/gwlib.h"

Include dependency graph for test_cimd2.c:

Go to the source code of this file.

Typedefs
typedef void(*	packet_handler )(Octstr *, Octstr *, int)
Enumerations
enum	{ TIMESTAMP_MAXLEN = 13 }
enum	ACT { ACT_listen = 0, ACT_reply = 1, ACT_deliver = 2, ACT_flood = 3 }
enum	SPEW { SPEW_nothing = 0, SPEW_binary = 1, SPEW_characters = 2, SPEW_packets = 3 }
enum	LOG { LOG_nothing = 0, LOG_data = 1, LOG_packets = 2, LOG_sms = 3 }
enum	CHK {   CHK_nothing = 0, CHK_packets = 1, CHK_sums = 2, CHK_protocol = 3,   CHK_sms = 4 }
enum	{ OUTBUFFER_LIMIT = 65536 }
enum	{ EVIL_BUFSIZE = 1021 }
enum	CHARS {   STX = 2, ETX = 3, TAB = 9, LF = 10,   CR = 13 }
Functions
void	usage (FILE *out)
void	pretty_print (unsigned char *data, size_t length)
void	read_data (Octstr *in, int fd)
void	write_data (Octstr *out, int fd)
void	gen_message (Octstr *out)
long	gen_data (Octstr *out)
void	make_timestamp (unsigned char *buf, time_t fortime)
void	send_packet (Octstr *out, int opcode, int sequence,...)
void	send_error (Octstr *out, int opcode, int sequence, unsigned char *errorcode, unsigned char *errortext)
int	eat_char (Octstr *packet, int ch)
Octstr *	eat_string_parm (Octstr *packet, int parm, int maxlen)
long	eat_number (Octstr *ostr)
long	eat_int_parm (Octstr *packet, int parm, int maxlen)
void	eat_checksum (Octstr *packet)
void	handle_login (Octstr *packet, Octstr *out, int sequence)
void	handle_logout (Octstr *packet, Octstr *out, int sequence)
void	handle_submit (Octstr *packet, Octstr *out, int sequence)
void	handle_enquire (Octstr *packet, Octstr *out, int sequence)
void	handle_delivery_request (Octstr *packet, Octstr *out, int sequence)
void	handle_cancel (Octstr *packet, Octstr *out, int sequence)
void	handle_set (Octstr *packet, Octstr *out, int sequence)
void	handle_get (Octstr *packet, Octstr *out, int sequence)
void	handle_alive (Octstr *packet, Octstr *out, int sequence)
void	handle_deliver_response (Octstr *packet, Octstr *out, int sequence)
void	handle_deliver_status_report_response (Octstr *packet, Octstr *out, int sequence)
void	handle_alive_response (Octstr *packet, Octstr *out, int sequence)
void	handle_nack (Octstr *packet, Octstr *out, int sequence)
void	parse_packet (Octstr *packet, Octstr *out)
void	parse_data (Octstr *in, Octstr *out)
void	random_address (unsigned char *buf, int size)
void	random_message (unsigned char *buf, int size)
void	random_hex (unsigned char *buf, int size)
void	main_loop (void)
int	wait_for_client (int port)
int	main (int argc, char *argv[])
Variables
unsigned char *	progname
unsigned char *	username = "foo"
unsigned char *	password = "bar"
int	port = 6789
unsigned char *	intro = ""
int	activity = ACT_listen
int	spew = SPEW_nothing
int	logging = LOG_nothing
int	checking = CHK_nothing
int	max_deliveries = -1
int	deliveries = 0
time_t	start_time = 0
int	sockfd = -1
Octstr *	inbuffer
Octstr *	outbuffer
int	awaiting_response = 0
struct {
int   opcode
packet_handler   handler
}	handlers []
struct {
unsigned char *   option
void *   location
int   number
}	options []

---

Typedef Documentation

typedef void(* packet_handler)(Octstr *, Octstr *, int)

Definition at line 766 of file test_cimd2.c.

---

Enumeration Type Documentation

anonymous enum

Enumeration values: TIMESTAMP_MAXLEN  Definition at line 94 of file test_cimd2.c. { TIMESTAMP_MAXLEN = 13 };

anonymous enum

Enumeration values: OUTBUFFER_LIMIT  Definition at line 151 of file test_cimd2.c. { OUTBUFFER_LIMIT = 65536 };

anonymous enum

Enumeration values: EVIL_BUFSIZE  Definition at line 156 of file test_cimd2.c. { EVIL_BUFSIZE = 1021 };

enum ACT

Enumeration values: ACT_listen  ACT_reply  ACT_deliver  ACT_flood  Definition at line 107 of file test_cimd2.c. { ACT_listen = 0, ACT_reply = 1, ACT_deliver = 2, ACT_flood = 3 };

enum CHARS

Enumeration values: STX  ETX  TAB  LF  CR  Definition at line 159 of file test_cimd2.c. { STX = 2, ETX = 3, TAB = 9, LF = 10, CR = 13 };

enum CHK

Enumeration values: CHK_nothing  CHK_packets  CHK_sums  CHK_protocol  CHK_sms  Definition at line 128 of file test_cimd2.c. { CHK_nothing = 0, CHK_packets = 1, CHK_sums = 2, CHK_protocol = 3, CHK_sms = 4 };

enum LOG

Enumeration values: LOG_nothing  LOG_data  LOG_packets  LOG_sms  Definition at line 121 of file test_cimd2.c. { LOG_nothing = 0, LOG_data = 1, LOG_packets = 2, LOG_sms = 3 };

enum SPEW

Enumeration values: SPEW_nothing  SPEW_binary  SPEW_characters  SPEW_packets  Definition at line 114 of file test_cimd2.c. { SPEW_nothing = 0, SPEW_binary = 1, SPEW_characters = 2, SPEW_packets = 3 };

---

Function Documentation

int eat_char (  Octstr *  packet, int  ch )  [static]

Definition at line 368 of file test_cimd2.c. References octstr_delete(), and octstr_get_char(). Referenced by parse_packet(). { if (octstr_get_char(packet, 0) == ch) { octstr_delete(packet, 0, 1); return 0; } return -1; }

Here is the call graph for this function:

void eat_checksum (  Octstr *  packet  )  [static]

Definition at line 429 of file test_cimd2.c. References octstr_delete(), octstr_get_char(), and octstr_len(). Referenced by parse_packet(). { int len; int ch1, ch2, ch3; len = octstr_len(packet); if (len < 3) return; ch1 = octstr_get_char(packet, len - 3); ch2 = octstr_get_char(packet, len - 2); ch3 = octstr_get_char(packet, len - 1); if (isxdigit(ch3) && isxdigit(ch2) && ch1 == TAB) octstr_delete(packet, len - 3, 3); }

Here is the call graph for this function:

long eat_int_parm (  Octstr *  packet, int  parm, int  maxlen )  [static]

Definition at line 413 of file test_cimd2.c. References eat_number(), eat_string_parm(), maxlen, octstr_destroy(), octstr_len(), and result. Referenced by handle_cancel(), handle_delivery_request(), handle_get(), and handle_submit(). { Octstr *value; long result; value = eat_string_parm(packet, parm, maxlen); if (!value) return INT_MIN; result = eat_number(value); if (octstr_len(value) > 0) result = INT_MIN; octstr_destroy(value); return result; }

Here is the call graph for this function:

long eat_number (  Octstr *  ostr  )  [static]

Definition at line 401 of file test_cimd2.c. References octstr_delete(), octstr_parse_long(), and result. Referenced by eat_int_parm(), and parse_packet(). { long result; long pos; pos = octstr_parse_long(&result, ostr, 0, 10); if (pos < 0) return INT_MIN; octstr_delete(ostr, 0, pos); return result; }

Here is the call graph for this function:

Octstr* eat_string_parm (  Octstr *  packet, int  parm, int  maxlen )  [static]

Definition at line 376 of file test_cimd2.c. References octstr_copy, octstr_delete(), octstr_destroy(), octstr_format(), octstr_len(), octstr_search(), octstr_search_char(), result, and TAB. Referenced by eat_int_parm(), handle_cancel(), handle_enquire(), handle_login(), handle_set(), and handle_submit(). { long start, datastart; long tab; Octstr *result; Octstr *parmheader; parmheader = octstr_format("%c%03d:", TAB, parm); start = octstr_search(packet, parmheader, 0); if (start < 0) { octstr_destroy(parmheader); return NULL; } datastart = start + octstr_len(parmheader); tab = octstr_search_char(packet, TAB, datastart + 1); if (tab < 0) { tab = octstr_len(packet); } result = octstr_copy(packet, datastart, tab - datastart); octstr_delete(packet, start, tab - start); octstr_destroy(parmheader); return result; }

Here is the call graph for this function:

long gen_data (  Octstr *  out  )  [static]

Definition at line 275 of file test_cimd2.c. References ACT_deliver, ACT_flood, deliveries, gen_message(), interval, max_deliveries, octstr_append_data(), and SPEW_binary. Referenced by main_loop(). { unsigned char buf[EVIL_BUFSIZE]; size_t i; long interval = -1; static int last_sms; /* Used by ACT_deliver */ time_t now; if (max_deliveries < 0 || deliveries < max_deliveries) { switch (activity) { case ACT_deliver: now = time(NULL); if (last_sms == 0) last_sms = now; while (last_sms < now) { if (random() % 7 == 1) { gen_message(out); last_sms = now; } else last_sms++; } interval = 1000000; break; case ACT_flood: gen_message(out); break; } } switch (spew) { case SPEW_binary: for (i = 0; i < sizeof(buf); i++) { buf[i] = random() % 256; } octstr_append_data(out, buf, sizeof(buf)); break; } return interval; }

Here is the call graph for this function:

void gen_message (  Octstr *  out  )  [static]

Definition at line 886 of file test_cimd2.c. References awaiting_response, logging, make_timestamp(), message, random_address(), random_hex(), random_message(), and send_packet(). Referenced by gen_data(). { static int send_seq = 0; unsigned char dest[21]; unsigned char orig[21]; unsigned char scts[TIMESTAMP_MAXLEN]; unsigned char message[481]; unsigned char udh[281]; if (awaiting_response == 1) return; random_address(dest, sizeof(dest)); random_address(orig, sizeof(orig)); make_timestamp(scts, time(NULL)); random_message(message, sizeof(message)); if (random() % 2 == 0) random_hex(udh, sizeof(udh)); else *udh = 0; if (logging == LOG_packets) printf("SND: Deliver message (random)\n"); if (*udh) { send_packet(out, 20, send_seq, 21, dest, 23, orig, 60, scts, 32, udh, 33, message, 0); } else { send_packet(out, 20, send_seq, 21, dest, 23, orig, 60, scts, 33, message, 0); } send_seq += 2; if (send_seq > 255) send_seq = 0; awaiting_response = 1; }

Here is the call graph for this function:

void handle_alive (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 723 of file test_cimd2.c. References logging, and send_packet(). { if (logging == LOG_packets) printf("RCV: Alive?\n"); if (logging == LOG_packets) printf("SND: Alive.\n"); send_packet(out, 90, sequence, 0); }

Here is the call graph for this function:

void handle_alive_response (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 751 of file test_cimd2.c. References awaiting_response, and logging. { awaiting_response = 0; if (logging == LOG_packets) printf("RCV: Alive.\n"); /* No need to respond to a response */ }

void handle_cancel (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 659 of file test_cimd2.c. References eat_int_parm(), eat_string_parm(), logging, octstr_get_cstr, send_error(), and send_packet(). { long mode = eat_int_parm(packet, 59, 1); Octstr *timestamp = eat_string_parm(packet, 60, 12); Octstr *destination = eat_string_parm(packet, 21, 20); if (logging == LOG_packets) { printf("RCV: Cancel"); if (mode != INT_MIN) printf(", mode %ld", mode); if (destination) printf(", dest '%s'", octstr_get_cstr(destination)); if (timestamp) printf(", time '%s'", octstr_get_cstr(timestamp)); printf("\n"); } if (mode < 0 || mode > 2) send_error(out, 56, sequence, "602", "bad mode"); else { if (logging == LOG_packets) printf("SND: OK\n"); send_packet(out, 56, sequence, 0); } }

Here is the call graph for this function:

void handle_deliver_response (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 731 of file test_cimd2.c. References awaiting_response, deliveries, logging, and max_deliveries. { awaiting_response = 0; if (logging == LOG_packets) printf("RCV: Deliver response\n"); deliveries++; if (max_deliveries > 0 && deliveries == max_deliveries) { time_t elapsed = time(NULL) - start_time; printf("LOG: %ld deliveries in %ld seconds\n", (long) max_deliveries, (long) elapsed); } /* No need to respond to a response */ }

void handle_deliver_status_report_response (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 744 of file test_cimd2.c. References awaiting_response, and logging. { awaiting_response = 0; if (logging == LOG_packets) printf("RCV: Deliver status report response\n"); /* No need to respond to a response */ }

void handle_delivery_request (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 614 of file test_cimd2.c. References eat_int_parm(), logging, send_error(), and send_packet(). { long mode = eat_int_parm(packet, 68, 1); if (logging == LOG_packets) { switch (mode) { case 0: printf("RCV: Delivery request, messages waiting?\n"); break; case 1: printf("RCV: Delivery request, one message\n"); break; case 2: printf("RCV: Delivery request, all messages\n"); break; case INT_MIN: printf("RCV: Delivery request, no mode\n"); break; default: printf("RCV: Delivery request, mode %ld\n", mode); } } if (mode == INT_MIN) mode = 1; switch (mode) { case 0: if (logging == LOG_packets) printf("SND: Respond: 0 messages\n"); send_packet(out, 55, sequence, 66, "0", 0); break; case 1: send_error(out, 55, sequence, "500", "no messages available"); break; case 2: send_error(out, 55, sequence, "500", "no messages available"); break; default: send_error(out, 55, sequence, "501", "bad mode"); break; } }

Here is the call graph for this function:

void handle_enquire (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 588 of file test_cimd2.c. References eat_string_parm(), logging, octstr_destroy(), octstr_get_cstr, send_error(), and send_packet(). { Octstr *dest_addr = eat_string_parm(packet, 21, 20); Octstr *timestamp = eat_string_parm(packet, 60, 12); if (logging == LOG_packets) printf("RCV: Enquire status, dest='%s', time='%s'\n", dest_addr ? octstr_get_cstr(dest_addr) : "", timestamp ? octstr_get_cstr(timestamp) : ""); if (!dest_addr) { send_error(out, 54, sequence, "400", "no destination"); } else if (!timestamp) { send_error(out, 54, sequence, "401", "no timestamp"); } else { if (logging == LOG_packets) printf("SND: Respond: status unknown\n"); send_packet(out, 54, sequence, 21, octstr_get_cstr(dest_addr), 60, octstr_get_cstr(timestamp), 61, "0", 0); } octstr_destroy(dest_addr); octstr_destroy(timestamp); }

Here is the call graph for this function:

void handle_get (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 702 of file test_cimd2.c. References eat_int_parm(), logging, make_timestamp(), number, send_error(), and send_packet(). { long number = eat_int_parm(packet, 500, 3); if (logging == LOG_packets) printf("RCV: Get parameter #%ld\n", number); if (number == INT_MIN) { send_error(out, 59, sequence, "900", "missing parameter"); } else if (number == 501) { unsigned char buf[TIMESTAMP_MAXLEN]; make_timestamp(buf, time(NULL)); if (logging == LOG_packets) printf("SND: OK, SMSC timestamp is '%s'\n", buf); send_packet(out, 59, sequence, 501, buf, 0); } else { send_error(out, 59, sequence, "900", "unknown parameter"); } }

Here is the call graph for this function:

void handle_login (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 446 of file test_cimd2.c. References eat_string_parm(), logging, octstr_create, octstr_destroy(), octstr_get_cstr, octstr_str_compare(), password, send_error(), send_packet(), and username. { Octstr *user = eat_string_parm(packet, 10, 32); Octstr *pass = eat_string_parm(packet, 11, 32); if (user == NULL) user = octstr_create(""); if (pass == NULL) pass = octstr_create(""); if (logging == LOG_packets) printf("RCV: Login user '%s', password '%s'\n", octstr_get_cstr(user), octstr_get_cstr(pass)); if (octstr_str_compare(user, username) == 0 && octstr_str_compare(pass, password) == 0) { if (logging == LOG_packets) printf("SND: Login OK\n"); send_packet(out, 51, sequence, 0); } else { send_error(out, 51, sequence, "100", "invalid login"); } octstr_destroy(user); octstr_destroy(pass); }

Here is the call graph for this function:

void handle_logout (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 472 of file test_cimd2.c. References logging, and send_packet(). { if (logging == LOG_packets) printf("RCV: Logout\n"); if (logging == LOG_packets) printf("SND: Logout OK\n"); send_packet(out, 52, sequence, 0); }

Here is the call graph for this function:

void handle_nack (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 758 of file test_cimd2.c. References awaiting_response, and logging. { awaiting_response = 0; if (logging == LOG_packets) printf("RCV: NACK\n"); /* TODO: We should retransmit if we get a nack, but there's * no record of what request we sent. */ }

void handle_set (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 685 of file test_cimd2.c. References eat_string_parm(), logging, octstr_get_cstr, and send_error(). { Octstr *pass = eat_string_parm(packet, 11, 32); if (pass) { if (logging == LOG_packets) printf("RCV: Set password to '%s'\n", octstr_get_cstr(pass)); send_error(out, 58, sequence, "801", "changing password not allowed"); } else { if (logging == LOG_packets) printf("RCV: Set, unknown parameters\n"); send_error(out, 58, sequence, "3", "cannot set"); } }

Here is the call graph for this function:

void handle_submit (  Octstr *  packet, Octstr *  out, int  sequence )  [static]

Definition at line 480 of file test_cimd2.c. References eat_int_parm(), eat_string_parm(), gwlist_append(), gwlist_create, gwlist_destroy(), gwlist_get(), gwlist_len(), logging, make_timestamp(), octstr_destroy(), octstr_destroy_item(), octstr_get_cstr, send_error(), send_packet(), and text. { Octstr *dest_addr = eat_string_parm(packet, 21, 20); Octstr *orig_addr = eat_string_parm(packet, 23, 20); long DCS = eat_int_parm(packet, 30, 3); Octstr *UDH = eat_string_parm(packet, 32, 280); Octstr *text = eat_string_parm(packet, 33, 480); Octstr *textb = eat_string_parm(packet, 34, 280); long valid_rel = eat_int_parm(packet, 50, 3); Octstr *valid_abs = eat_string_parm(packet, 51, 12); long proto_id = eat_int_parm(packet, 52, 3); long delivery_rel = eat_int_parm(packet, 53, 3); Octstr *delivery_abs = eat_string_parm(packet, 54, 12); long reply_path = eat_int_parm(packet, 55, 1); long SRR = eat_int_parm(packet, 56, 2); long cancel = eat_int_parm(packet, 58, 1); long tariff_class = eat_int_parm(packet, 64, 2); long service_desc = eat_int_parm(packet, 65, 1); long priority = eat_int_parm(packet, 67, 1); List *other_dests = gwlist_create(); Octstr *tmp; while ((tmp = eat_string_parm(packet, 21, 20))) gwlist_append(other_dests, tmp); if (logging == LOG_packets) { int i; printf("RCV: Submit to %s", octstr_get_cstr(dest_addr)); for (i = 0; i < gwlist_len(other_dests); i++) { printf(", %s", octstr_get_cstr(gwlist_get(other_dests, i))); } printf("\n"); if (orig_addr) printf(" From: %s\n", octstr_get_cstr(orig_addr)); if (DCS > INT_MIN) printf(" Data coding: %ld\n", DCS); if (UDH) printf(" User data header: %s\n", octstr_get_cstr(UDH)); if (text) printf(" Text: %s\n", octstr_get_cstr(text)); if (textb) printf(" Text (binary): %s\n", octstr_get_cstr(textb)); if (valid_rel > INT_MIN) printf(" Validity period: %ld (relative)\n", valid_rel); if (valid_abs) printf(" Validity period: %s (absolute)\n", octstr_get_cstr(valid_abs)); if (proto_id > INT_MIN) printf(" Protocol ID: %ld\n", proto_id); if (delivery_rel > INT_MIN) printf(" First delivery: %ld (relative)\n", delivery_rel); if (delivery_abs) printf(" First delivery: %s (absolute)\n", octstr_get_cstr(delivery_abs)); if (reply_path == 0) printf(" Reply path disabled\n"); else if (reply_path == 1) printf(" Reply path enabled\n"); else if (reply_path > INT_MAX) printf(" Reply path: %ld\n", reply_path); if (SRR > INT_MAX) printf(" Status report flags: %ld\n", SRR); if (cancel == 0) printf(" Cancel disabled\n"); else if (cancel == 1) printf(" Cancel enabled\n"); else if (cancel > INT_MAX) printf(" Cancel enabled: %ld\n", cancel); if (tariff_class > INT_MAX) printf(" Tariff class: %ld\n", tariff_class); if (service_desc > INT_MAX) printf(" Service description: %ld\n", service_desc); if (priority > INT_MAX) printf(" Priority: %ld\n", priority); } if (!dest_addr) { send_error(out, 53, sequence, "300", "no destination"); } else if (gwlist_len(other_dests) > 0) { send_error(out, 53, sequence, "301", "too many destinations"); /* TODO: Report many other possible errors here */ } else { unsigned char buf[TIMESTAMP_MAXLEN]; make_timestamp(buf, time(NULL)); if (logging == LOG_packets) printf("SND: Submit OK\n"); send_packet(out, 53, sequence, 21, octstr_get_cstr(dest_addr), 60, buf, 0); } octstr_destroy(dest_addr); octstr_destroy(orig_addr); octstr_destroy(UDH); octstr_destroy(text); octstr_destroy(textb); octstr_destroy(valid_abs); octstr_destroy(delivery_abs); gwlist_destroy(other_dests, octstr_destroy_item); }

Here is the call graph for this function:

int main (  int  argc, char *  argv[] )

Definition at line 1053 of file test_cimd2.c. References gwlib_init(), main_loop(), option, options, port, progname, sockfd, usage(), and wait_for_client(). { int i; int opt; gwlib_init(); progname = argv[0]; srandom(0); /* Make "random" data reproducible */ for (i = 1; i < argc; i++) { for (opt = 0; options[opt].option; opt++) { if (strcmp(argv[i], options[opt].option) == 0) { if (i + 1 >= argc) { fprintf(stderr, "%s: missing argument to %s", progname, argv[i]); exit(2); } if (options[opt].number) { * (int *) options[opt].location = atoi(argv[i+1]); } else { * (char **) options[opt].location = argv[i+1]; } i++; break; } } if (options[opt].option) continue; if (strcmp(argv[i], "--help") == 0) { usage(stdout); exit(0); } if (argv[i][0] == '-') { fprintf(stderr, "%s: unknown option %s\n", progname, argv[i]); usage(stderr); exit(2); } } sockfd = wait_for_client(port); main_loop(); return 0; }

Here is the call graph for this function:

void main_loop (  void   )  [static]

Definition at line 935 of file test_cimd2.c. References error(), gen_data(), inbuffer, interval, intro, octstr_create, octstr_len(), outbuffer, parse_data(), read_data(), sockfd, start_time, warning(), and write_data(). Referenced by main(). { fd_set readfds, writefds; int n; static int reported_outfull = 0; int interval = -1; inbuffer = octstr_create(""); outbuffer = octstr_create(intro); start_time = time(NULL); for (;;) { if (octstr_len(outbuffer) < OUTBUFFER_LIMIT) { interval = gen_data(outbuffer); } else if (!reported_outfull) { warning(0, "outbuffer getting full; waiting..."); reported_outfull = 1; } FD_ZERO(&readfds); FD_SET(sockfd, &readfds); if (octstr_len(outbuffer) > 0) { FD_ZERO(&writefds); FD_SET(sockfd, &writefds); n = select(sockfd+1, &readfds, &writefds, NULL, NULL); } else { struct timeval tv; struct timeval *tvp; if (interval >= 0) { tv.tv_sec = 0; tv.tv_usec = interval; tvp = &tv; } else { tvp = NULL; } n = select(sockfd+1, &readfds, NULL, NULL, tvp); } if (n < 0) { if (errno == EINTR) { warning(errno, "main loop, select"); continue; } error(errno, "main loop, select"); sleep(1); continue; } if (n > 0) { if (FD_ISSET(sockfd, &readfds)) { read_data(inbuffer, sockfd); parse_data(inbuffer, outbuffer); } if (octstr_len(outbuffer) > 0 && FD_ISSET(sockfd, &writefds)) { write_data(outbuffer, sockfd); } if (octstr_len(outbuffer) < OUTBUFFER_LIMIT) { reported_outfull = 0; } } } }

Here is the call graph for this function:

void make_timestamp (  unsigned char *  buf, time_t  fortime )  [static]

Definition at line 320 of file test_cimd2.c. References gw_gmtime(). Referenced by gen_message(), handle_get(), and handle_submit(). { /* Is there a thread-safe version of gmtime? */ struct tm tm = gw_gmtime(fortime); sprintf(buf, "%02d%02d%02d%02d%02d%02d", tm.tm_year % 100, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec); }

Here is the call graph for this function:

void parse_data (  Octstr *  in, Octstr *  out )  [static]

Definition at line 817 of file test_cimd2.c. References ETX, Octstr, octstr_copy, octstr_delete(), octstr_destroy(), octstr_len(), octstr_search_char(), parse_packet(), and STX. Referenced by main_loop(), parse_array_element(), and parse_data(). { int stx, etx; Octstr *packet; for (;;) { /* Look for start of packet. Delete everything up to the start * marker. (CIMD2 section 3.1 says we can ignore any data * transmitted between packets.) */ stx = octstr_search_char(in, STX, 0); if (stx < 0) octstr_delete(in, 0, octstr_len(in)); else if (stx > 0) octstr_delete(in, 0, stx); etx = octstr_search_char(in, ETX, 0); if (etx < 0) return; /* Incomplete packet; wait for more data. */ /* Copy the data between stx and etx */ packet = octstr_copy(in, 1, etx - 1); /* Then cut the packet (including stx and etx) from inbuffer */ octstr_delete(in, 0, etx + 1); parse_packet(packet, out); octstr_destroy(packet); } }

Here is the call graph for this function:

void parse_packet (  Octstr *  packet, Octstr *  out )  [static]

Definition at line 788 of file test_cimd2.c. References eat_char(), eat_checksum(), eat_number(), handlers, logging, opcode, and send_error(). Referenced by parse_data(). { int opcode, sequence; int i; eat_checksum(packet); opcode = eat_number(packet); if (opcode < 0 || eat_char(packet, ':') < 0) return; sequence = eat_number(packet); if (sequence < 0) return; for (i = 0; handlers[i].opcode >= 0; i++) { if (handlers[i].opcode == opcode) { (handlers[i].handler)(packet, out, sequence); break; } } if (handlers[i].opcode < 0) { /* Loop failed */ if (logging == LOG_packets) printf("RCV: unknown operation %ld\n", (long) handlers[i].opcode); send_error(out, 98, sequence, "1", "unexpected operation"); } }

Here is the call graph for this function:

void pretty_print (  unsigned char *  data, size_t  length )  [static]

Definition at line 201 of file test_cimd2.c. References CR, data, ETX, LF, STX, and TAB. Referenced by read_data(), and write_data(). { size_t i; int c; for (i = 0; i < length; i++) { c = data[i]; switch(c) { default: if (isprint(c)) putchar(c); else printf("<%d>", c); break; case TAB: fputs("<TAB>", stdout); break; case LF: fputs("<LF>\n", stdout); break; case CR: fputs("<CR>", stdout); break; case STX: fputs("<STX>", stdout); break; case ETX: fputs("<ETX>\n", stdout); break; } } fflush(stdout); }

void random_address (  unsigned char *  buf, int  size )  [static]

Definition at line 846 of file test_cimd2.c. Referenced by gen_message(). { int len = random() % size; while (len--) { *buf++ = '0' + random() % 10; } *buf++ = '\0'; }

void random_hex (  unsigned char *  buf, int  size )  [static]

Definition at line 869 of file test_cimd2.c. Referenced by gen_message(). { int len = random() % size; /* Make even */ len -= (len % 2); while (len--) { int c = random() % 16; if (c < 10) *buf++ = c + '0'; else *buf++ = c - 10 + 'a'; } *buf++ = '\0'; }

void random_message (  unsigned char *  buf, int  size )  [static]

Definition at line 856 of file test_cimd2.c. References ETX, and STX. Referenced by gen_message(). { int len = random() % size; while (len--) { do { *buf = random() % 256; } while (*buf == STX || *buf == ETX || *buf == TAB); buf++; } *buf++ = '\0'; }

void read_data (  Octstr *  in, int  fd )  [static]

Definition at line 224 of file test_cimd2.c. References error(), logging, octstr_append_data(), and pretty_print(). Referenced by main_loop(). { unsigned char buf[EVIL_BUFSIZE]; int ret; ret = read(fd, buf, sizeof(buf)); if (ret > 0) { octstr_append_data(in, buf, ret); if (logging == LOG_data) pretty_print(buf, ret); } else if (ret == 0) { fprintf(stderr, "Client closed socket\n"); exit(0); } else { if (errno == EINTR || errno == EAGAIN) return; error(errno, "read_data"); exit(1); } }

Here is the call graph for this function:

void send_error (  Octstr *  out, int  opcode, int  sequence, unsigned char *  errorcode, unsigned char *  errortext )  [static]

Definition at line 360 of file test_cimd2.c. References logging, opcode, and send_packet(). Referenced by handle_cancel(), handle_delivery_request(), handle_enquire(), handle_get(), handle_login(), handle_set(), handle_submit(), and parse_packet(). { if (logging == LOG_packets) printf("SND: ERROR, %s\n", errortext); send_packet(out, opcode, sequence, 900, errorcode, 901, errortext, 0); }

Here is the call graph for this function:

void send_packet (  Octstr *  out, int  opcode, int  sequence,   ... )  [static]

Definition at line 330 of file test_cimd2.c. References activity, ETX, octstr_format_append(), octstr_get_char(), octstr_len(), opcode, STX, and TAB. Referenced by gen_message(), handle_alive(), handle_cancel(), handle_delivery_request(), handle_enquire(), handle_get(), handle_login(), handle_logout(), handle_submit(), and send_error(). { va_list ap; int parm; unsigned char *value; int checksum; int old_len, new_len; if (activity == ACT_listen) return; old_len = octstr_len(out); octstr_format_append(out, "%c%02d:%03d%c", STX, opcode, sequence, TAB); va_start(ap, sequence); for (parm = va_arg(ap, int); parm != 0; parm = va_arg(ap, int)) { value = va_arg(ap, unsigned char *); octstr_format_append(out, "%03d:%s\11", parm, value); } va_end(ap); /* Calculate checksum */ checksum = 0; for (new_len = octstr_len(out); old_len < new_len; old_len++) { checksum = (checksum + octstr_get_char(out, old_len)) & 0xff; } octstr_format_append(out, "%02X%c", checksum, ETX); }

Here is the call graph for this function:

void usage (  FILE *  out  )  [static]

Definition at line 167 of file test_cimd2.c. References activity, checking, logging, password, port, progname, spew, and username. { fprintf(out, "Usage: %s [options...]\n" " --help Print this message\n" " --user USER Allow clients to log in with username USER (default %s)\n" " --password PASS Allow clients to log in with password PASS (default %s)\n" " --intro INTRO Send INTRO string before anything else (default nothing)\n" " --port PORT TCP port to listen on (default %d)\n" " --activity ACT Activity level of test server (default %d)\n" " ACT = 0 send nothing, just listen\n" " ACT = 1 send valid replies, do not initiate any transactions\n" " ACT = 2 attempt to deliver a random SMS every few seconds (NI)\n" " ACT = 3 deliver many random SMSes, measure throughput (NI)\n" " --spew SPEW Flood client, overrides --activity (default %d)\n" " SPEW = 0 don't spew, use --activity instead\n" " SPEW = 1 spew random binary gunk at client\n" " SPEW = 2 spew random data of the right character set at client (NI)\n" " SPEW = 3 spew valid packets with random contents at client (NI)\n" " --logging LOG Log level of test server (default %d)\n" " LOG = 0 log nothing\n" " LOG = 1 log all data\n" " LOG = 2 log summaries of valid packets\n" " LOG = 3 log successfully sent and received SMSes (NI)\n" " --checking CHK Check level of test server (default %d)\n" " CHK = 0 check nothing\n" " CHK = 1 signal invalid packets (NI)\n" " CHK = 2 signal checksum errors (NI)\n" " CHK = 3 signal protocol errors (NI)\n" " CHK = 4 signal invalid SMS contents (NI)\n" " --max MAX With high activity values, stop after MAX deliveries\n" " NI means Not Implemented\n" , progname, username, password, port, activity, spew, logging, checking); }

int wait_for_client (  int  port  )  [static]

Definition at line 1016 of file test_cimd2.c. References error(), gw_netaddr_to_octstr(), info(), make_server_socket(), Octstr, octstr_destroy(), octstr_get_cstr, panic, port, progname, and socket_set_blocking(). Referenced by main(). { struct sockaddr_in sin; socklen_t addrlen; int listenfd; int clientfd; Octstr *addr; listenfd = make_server_socket(port, NULL); if (listenfd < 0) { fprintf(stderr, "%s: failed to open socket at port %d\n", progname, port); exit(1); } do { addrlen = sizeof(sin); clientfd = accept(listenfd, (struct sockaddr *)&sin, &addrlen); if (clientfd < 0) { error(errno, "failed to accept new connection"); } } while (clientfd < 0); if (socket_set_blocking(clientfd, 0) < 0) { panic(0, "failed to make client socket nonblocking"); } addr = gw_netaddr_to_octstr(AF_INET, &sin.sin_addr); info(0, "Accepted client from %s:%d", octstr_get_cstr(addr), ntohs(sin.sin_port)); octstr_destroy(addr); close(listenfd); return clientfd; }

Here is the call graph for this function:

void write_data (  Octstr *  out, int  fd )  [static]

Definition at line 244 of file test_cimd2.c. References error(), logging, octstr_delete(), octstr_get_many_chars(), octstr_len(), pretty_print(), and warning(). Referenced by main_loop(). { unsigned char buf[EVIL_BUFSIZE]; int len; ssize_t ret; len = sizeof(buf); if (len > octstr_len(out)) len = octstr_len(out); if (len == 0) return; octstr_get_many_chars(buf, out, 0, len); ret = write(fd, buf, len); if (ret > 0) { if (logging == LOG_data) pretty_print(buf, ret); octstr_delete(out, 0, ret); } else if (ret == 0) { warning(0, "empty write"); } else { if (errno == EINTR || errno == EAGAIN) return; error(errno, "write_data"); exit(1); } }

Here is the call graph for this function:

---

Variable Documentation

int activity = ACT_listen

Definition at line 136 of file test_cimd2.c. Referenced by send_packet(), and usage().

int awaiting_response = 0

Definition at line 317 of file test_cimd2.c. Referenced by gen_message(), handle_alive_response(), handle_deliver_response(), handle_deliver_status_report_response(), and handle_nack().

int checking = CHK_nothing

Definition at line 139 of file test_cimd2.c. Referenced by usage().

int deliveries = 0

Definition at line 142 of file test_cimd2.c. Referenced by gen_data(), and handle_deliver_response().

packet_handler handler

Definition at line 770 of file test_cimd2.c.

struct { ... } handlers[]

Referenced by parse_packet().

Octstr* inbuffer

Definition at line 147 of file test_cimd2.c. Referenced by main_loop().

unsigned char* intro = ""

Definition at line 105 of file test_cimd2.c. Referenced by main_loop().

void* location

Definition at line 1001 of file test_cimd2.c. Referenced by at2_read_pending_incoming_messages().

int logging = LOG_nothing

Definition at line 138 of file test_cimd2.c. Referenced by gen_message(), handle_alive(), handle_alive_response(), handle_cancel(), handle_deliver_response(), handle_deliver_status_report_response(), handle_delivery_request(), handle_enquire(), handle_get(), handle_login(), handle_logout(), handle_nack(), handle_set(), handle_submit(), parse_packet(), read_data(), send_error(), usage(), and write_data().

int max_deliveries = -1

Definition at line 141 of file test_cimd2.c. Referenced by gen_data(), and handle_deliver_response().

int number

Definition at line 1002 of file test_cimd2.c.

int opcode

Definition at line 769 of file test_cimd2.c. Referenced by parse_packet(), send_error(), and send_packet().

unsigned char* option

Definition at line 1000 of file test_cimd2.c. Referenced by main(), and parse_options().

struct { ... } options[] [static]

Referenced by main().

Octstr* outbuffer

Definition at line 148 of file test_cimd2.c. Referenced by main_loop().

unsigned char* password = "bar"

Definition at line 100 of file test_cimd2.c. Referenced by authorise_username(), cimd_open(), emi_open(), handle_login(), http_add_basic_auth(), http_use_proxy(), httpd_check_authorization(), init_wapbox(), main(), make_url(), pack_credentials(), parse_cgivars_for_password(), password_matches(), proxy_unpack_credentials(), push_headers_create(), read_test_ppg_config(), receive_push_reply(), smpp_create(), smsc_open(), smsc_smpp_create(), unpack_credentials(), usage(), and wap_push_ppg_pushuser_authenticate().

int port = 6789

Definition at line 102 of file test_cimd2.c.

unsigned char* progname

Definition at line 96 of file test_cimd2.c. Referenced by badusage(), build_box_arglist(), do_stop(), fatal(), main(), print_usage(), rebind_standard_streams(), usage(), wait_for_client(), and write_pidfile().

int sockfd = -1

Definition at line 145 of file test_cimd2.c. Referenced by conn_open_tcp_nb_with_port(), conn_open_tcp_with_port(), main(), and main_loop().

int spew = SPEW_nothing

Definition at line 137 of file test_cimd2.c. Referenced by usage().

time_t start_time = 0

Definition at line 143 of file test_cimd2.c.

unsigned char* username = "foo"

Definition at line 99 of file test_cimd2.c. Referenced by authorise_username(), cimd_open(), emi_open(), handle_login(), http_add_basic_auth(), http_use_proxy(), main(), make_url(), ota_tokenize_settings(), pap_request_thread(), parse_cgivars_for_username(), push_headers_create(), read_test_ppg_config(), receive_push_reply(), set_dlr_url(), set_smsbox_id(), set_smsc_id(), smpp_create(), smsc_open(), smsc_smpp_create(), usage(), user_find_by_username(), wap_push_ppg_pushuser_authenticate(), wap_push_ppg_pushuser_client_phone_number_acceptable(), wap_push_ppg_pushuser_dlr_url_get(), wap_push_ppg_pushuser_smsbox_id_get(), and wap_push_ppg_pushuser_smsc_id_get().

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