FreeCalypso > hg > themwi-system-sw
changeset 218:211a043a385f
smpp-test1 program written, compiles
author | Mychaela Falconia <falcon@freecalypso.org> |
---|---|
date | Tue, 01 Aug 2023 22:38:04 -0800 |
parents | 9f6a148ceb25 |
children | 9ba474e918c0 |
files | .hgignore utils/Makefile utils/smpp-test1.c |
diffstat | 3 files changed, 158 insertions(+), 1 deletions(-) [+] |
line wrap: on
line diff
--- a/.hgignore Mon Jul 24 22:33:01 2023 -0800 +++ b/.hgignore Tue Aug 01 22:38:04 2023 -0800 @@ -20,6 +20,7 @@ ^utils/sip-out-test$ ^utils/sip-rx-test$ ^utils/sip-udp-dump$ +^utils/smpp-test1$ ^utils/tcpserv-dump$ ^utils/themwi-check-own$ ^utils/themwi-dump-numdb$
--- a/utils/Makefile Mon Jul 24 22:33:01 2023 -0800 +++ b/utils/Makefile Tue Aug 01 22:38:04 2023 -0800 @@ -3,7 +3,7 @@ PROGS= sip-out-test sip-rx-test sip-udp-dump themwi-check-own \ themwi-dump-numdb themwi-short-dial themwi-update-numdb \ themwi-update-outrt -NOINST= rtp-alloc-test tcpserv-dump +NOINST= rtp-alloc-test smpp-test1 tcpserv-dump LIBNUMDB=../libnumdb/libnumdb.a LIBRTPA=../librtpalloc/librtpalloc.a LIBSIP= ../libsip/libsip.a @@ -24,6 +24,9 @@ sip-udp-dump: sip-udp-dump.c ${CC} ${CFLAGS} -o $@ $@.c +smpp-test1: smpp-test1.c + ${CC} ${CFLAGS} -o $@ $@.c + tcpserv-dump: tcpserv-dump.c ${CC} ${CFLAGS} -o $@ $@.c
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/utils/smpp-test1.c Tue Aug 01 22:38:04 2023 -0800 @@ -0,0 +1,153 @@ +/* + * This program connects to an SMPP server in the role of a client, + * sends a bind_transceiver request, and then dumps everything + * that comes back. + */ + +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <strings.h> +#include <unistd.h> + +static const u_char bind_req[] = { + 0x00, 0x00, 0x00, 0x17, /* command_length */ + 0x00, 0x00, 0x00, 0x09, /* command_id: bind_transceiver */ + 0x00, 0x00, 0x00, 0x00, /* command_status */ + 0x00, 0x00, 0x00, 0x00, /* sequence_number */ + 0, 0, 0, /* empty strings */ + 0x34, /* interface_version */ + 0, 0, 0 /* empty address params */ +}; + +static int tcpsock; +static struct sockaddr_in server_sin; +static u_char rx_hdr[16]; +static unsigned rx_pkt_len; + +static void +init_stage() +{ + int rc; + + rc = connect(tcpsock, (struct sockaddr *) &server_sin, + sizeof(struct sockaddr_in)); + if (rc < 0) { + perror("connect"); + exit(1); + } + rc = write(tcpsock, bind_req, sizeof bind_req); + if (rc != sizeof bind_req) { + perror("write"); + exit(1); + } +} + +static void +rx_bytes(buf, need_len) + u_char *buf; + unsigned need_len; +{ + int cc; + unsigned remain; + + for (remain = need_len; remain; remain -= cc) { + cc = read(tcpsock, buf, remain); + if (cc <= 0) { + perror("read"); + exit(1); + } + } +} + +static void +print_hdr() +{ + int i, j, pos; + + fputs("Got header:", stdout); + pos = 0; + for (i = 0; i < 4; i++) { + putchar(' '); + for (j = 0; j < 4; j++) + printf("%02X", rx_hdr[pos++]); + } + putchar('\n'); +} + +static void +preen_rx_len() +{ + rx_pkt_len = (rx_hdr[0] << 24) | (rx_hdr[1] << 16) | (rx_hdr[2] << 8) | + rx_hdr[3]; + printf("Rx packet length: %u bytes\n", rx_pkt_len); + if (rx_pkt_len < 16) { + printf("Error: packet length is too short\n"); + exit(1); + } +} + +static void +read_and_dump_body() +{ + u_char buf[16]; + unsigned offset, chunk; + int i, c; + + for (offset = 16; offset < rx_pkt_len; offset += chunk) { + chunk = rx_pkt_len - offset; + if (chunk > 16) + chunk = 16; + rx_bytes(buf, chunk); + printf("%08X: ", offset); + for (i = 0; i < 16; i++) { + if (i < chunk) + printf("%02X ", buf[i]); + else + fputs(" ", stdout); + if (i == 7 || i == 15) + putchar(' '); + } + for (i = 0; i < chunk; i++) { + c = buf[i]; + if (c < ' ' || c > '~') + c = '.'; + putchar(c); + } + putchar('\n'); + } +} + +main(argc, argv) + char **argv; +{ + if (argc != 2) { + fprintf(stderr, "usage: %s server-ip\n", argv[0]); + exit(1); + } + server_sin.sin_family = AF_INET; + server_sin.sin_addr.s_addr = inet_addr(argv[1]); + if (server_sin.sin_addr.s_addr == INADDR_NONE) { + fprintf(stderr, "error: invalid IP address argument \"%s\"\n", + argv[1]); + exit(1); + } + server_sin.sin_port = htons(2775); + tcpsock = socket(AF_INET, SOCK_STREAM, 0); + if (tcpsock < 0) { + perror("socket"); + exit(1); + } + setlinebuf(stdout); + init_stage(); + for (;;) { + rx_bytes(rx_hdr, 16); + print_hdr(); + preen_rx_len(); + read_and_dump_body(); + } +}