# HG changeset patch # User Mychaela Falconia # Date 1691268753 28800 # Node ID 243ed87880a141c55bed3d13ba467ee16caad51d # Parent 62184b971c8e90cca8d26c0c9e7a297aeaab3c25 smpp-send: implement sending via local socket diff -r 62184b971c8e -r 243ed87880a1 smpp-send/Makefile --- a/smpp-send/Makefile Sat Aug 05 12:27:36 2023 -0800 +++ b/smpp-send/Makefile Sat Aug 05 12:52:33 2023 -0800 @@ -1,7 +1,7 @@ CC= gcc CFLAGS= -O2 PROG= smpp-send -OBJS= build_pdu.o hexdump.o input.o main.o msg_cmd.o settings.o +OBJS= build_pdu.o hexdump.o input.o main.o msg_cmd.o settings.o sock_send.o LIBS= ../libutil/libutil.a INSTBIN=/usr/local/bin diff -r 62184b971c8e -r 243ed87880a1 smpp-send/build_pdu.c --- a/smpp-send/build_pdu.c Sat Aug 05 12:27:36 2023 -0800 +++ b/smpp-send/build_pdu.c Sat Aug 05 12:52:33 2023 -0800 @@ -16,6 +16,7 @@ extern u_char prio_flag, reg_deliv, replace_flag; extern int input_lineno; +extern char *trx_socket; void build_submit_sm(payload, payload_len, udhi) @@ -86,5 +87,8 @@ pdu[2] = pdu_len >> 8; pdu[3] = pdu_len; /* local datagram socket output to be implemented */ - hex_dump_output(pdu, pdu_len); + if (trx_socket) + send_pdu_via_socket(pdu, pdu_len); + else + hex_dump_output(pdu, pdu_len); } diff -r 62184b971c8e -r 243ed87880a1 smpp-send/sock_send.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/smpp-send/sock_send.c Sat Aug 05 12:52:33 2023 -0800 @@ -0,0 +1,36 @@ +/* + * This module implements local datagram socket transmission of the constructed + * submit_sm PDU to our smpp-trx-sa daemon process. + */ + +#include +#include +#include +#include +#include +#include + +extern char *trx_socket; + +void +send_pdu_via_socket(pdu, pdulen) + u_char *pdu; + unsigned pdulen; +{ + struct sockaddr_un sa; + unsigned sa_len; + int lsock, rc; + + lsock = socket(AF_UNIX, SOCK_DGRAM, 0); + if (lsock < 0) { + perror("socket(AF_UNIX, SOCK_DGRAM, 0)"); + exit(1); + } + fill_sockaddr_un(trx_socket, &sa, &sa_len); + rc = sendto(lsock, pdu, pdulen, 0, (struct sockaddr *) &sa, sa_len); + if (rc != pdulen) { + perror("send via local socket"); + exit(1); + } + close(lsock); +}