FreeCalypso > hg > sipout-test-utils
diff test-fsk/rtp_tx.c @ 4:030d52b96a23
test-fsk: implement SpanDSP Tx output
author | Mychaela Falconia <falcon@freecalypso.org> |
---|---|
date | Mon, 04 Mar 2024 22:08:19 -0800 |
parents | cc997f9ae186 |
children |
line wrap: on
line diff
--- a/test-fsk/rtp_tx.c Mon Mar 04 21:22:27 2024 -0800 +++ b/test-fsk/rtp_tx.c Mon Mar 04 22:08:19 2024 -0800 @@ -12,19 +12,23 @@ #include <string.h> #include <strings.h> #include <unistd.h> +#include <spandsp.h> #include "../include/tmgw_const.h" #include "../include/rtp_defs.h" +#include "../include/pstn_defs.h" #include "../libutil/osmo_bits.h" extern struct sockaddr_in rtp_local_addr, rtp_remote_addr; extern int rtp_udp_fd, rtcp_udp_fd, pcma_selected; extern struct timeval cur_event_time; +extern int fsk_mode_tx; static uint32_t rtp_ssrc; static uint32_t rtp_out_ts; static uint16_t rtp_out_seq; -static uint8_t pcm_fill_octet; +static fsk_tx_state_t *fsk_tx_state; +static g711_state_t *g711_enc_state; void assign_rtpout_ssrc() @@ -32,13 +36,26 @@ rtp_ssrc = cur_event_time.tv_sec ^ cur_event_time.tv_usec ^ getpid(); } +static int +supply_bit() +{ + return 1; +} + void -init_pcm_fill_octet() +init_pcm_tx() { - if (pcma_selected) - pcm_fill_octet = 0xD5; - else - pcm_fill_octet = 0xFF; + fsk_tx_state = fsk_tx_init(NULL, &preset_fsk_specs[fsk_mode_tx], + supply_bit, NULL); + if (!fsk_tx_state) { + fprintf(stderr, "error: fsk_tx_init() failed!\n"); + exit(1); + } + g711_enc_state = g711_init(NULL, pcma_selected ? G711_ALAW : G711_ULAW); + if (!g711_enc_state) { + fprintf(stderr, "error: g711_init() failed!\n"); + exit(1); + } } void @@ -46,22 +63,17 @@ { struct rtp_packet pkt; socklen_t addrlen; + int16_t linear[FRAME_20MS]; pkt.v_p_x_cc = 0x80; pkt.m_pt = pcma_selected ? PSTN_CODEC_PCMA : PSTN_CODEC_PCMU; pkt.seq = htons(rtp_out_seq++); pkt.tstamp = htonl(rtp_out_ts); - rtp_out_ts += 160; + rtp_out_ts += FRAME_20MS; pkt.ssrc = rtp_ssrc; - memset(pkt.payload, pcm_fill_octet, RTP_MAX_PAYLOAD); + fsk_tx(fsk_tx_state, linear, FRAME_20MS); + g711_encode(g711_enc_state, pkt.payload, linear, FRAME_20MS); addrlen = sizeof(struct sockaddr_in); sendto(rtp_udp_fd, &pkt, RTP_PACKET_SIZE_PSTN, 0, (struct sockaddr *) &rtp_remote_addr, addrlen); } - -void -set_pcm_fill_octet(oct) - unsigned oct; -{ - pcm_fill_octet = oct; -}