mirror of
https://gitea.osmocom.org/cellular-infrastructure/osmo-mgw.git
synced 2025-11-02 13:03:33 +00:00
c3ff38ee4c
This has never been used afaik, and it's only clogging the code and adding extra indirect function pointer calls to hot paths for no good reason. Drop all of it, and re-ad whatever makes sense once someone really wants to implement transcoding. Change-Id: Id16af528d94612e771f94333ad5404e5cd1c3318
114 lines
3.7 KiB
C
114 lines
3.7 KiB
C
#pragma once
|
|
|
|
#include <inttypes.h>
|
|
#include <stdbool.h>
|
|
|
|
#include <osmocom/core/socket.h>
|
|
#include <osmocom/core/osmo_io.h>
|
|
|
|
#include <osmocom/mgcp/mgcp.h>
|
|
|
|
/* The following constant defines an RTP dummy payload that is used for
|
|
* "UDP Hole Punching" (NAT) */
|
|
#define MGCP_DUMMY_LOAD 0x23
|
|
static const char rtp_dummy_payload[] = { MGCP_DUMMY_LOAD };
|
|
|
|
/* Check if the data in a given message buffer matches the rtp dummy payload
|
|
* defined above */
|
|
#define mgcp_is_rtp_dummy_payload(msg) \
|
|
(msgb_length(msg) == sizeof(rtp_dummy_payload) && \
|
|
memcmp(msgb_data(msg), rtp_dummy_payload, sizeof(rtp_dummy_payload)) == 0)
|
|
|
|
#define RTP_BUF_SIZE 4096
|
|
|
|
struct mgcp_rtp_stream_state {
|
|
uint32_t ssrc;
|
|
uint16_t last_seq;
|
|
uint32_t last_timestamp;
|
|
struct rate_ctr *err_ts_ctr;
|
|
int32_t last_tsdelta;
|
|
uint32_t last_arrival_time;
|
|
};
|
|
|
|
struct mgcp_rtp_state {
|
|
/* has this state structure been initialized? */
|
|
int initialized;
|
|
|
|
struct {
|
|
/* are we patching the SSRC value? */
|
|
bool patch_ssrc;
|
|
/* original SSRC (to which we shall patch any different SSRC) */
|
|
uint32_t orig_ssrc;
|
|
/* offset to apply on the sequence number */
|
|
int seq_offset;
|
|
/* offset to apply on the timestamp number */
|
|
int32_t timestamp_offset;
|
|
} patch;
|
|
|
|
/* duration of a packet (FIXME: in which unit?) */
|
|
uint32_t packet_duration;
|
|
|
|
/* Note: These states are not continuously updated, they serve as an
|
|
* information source to patch certain values in the RTP header. Do
|
|
* not use this state if constantly updated data about the RTP stream
|
|
* is needed. (see also mgcp_patch_and_count() */
|
|
struct mgcp_rtp_stream_state in_stream;
|
|
struct mgcp_rtp_stream_state out_stream;
|
|
|
|
/* jitter and packet loss calculation */
|
|
struct {
|
|
int initialized;
|
|
uint16_t base_seq;
|
|
uint16_t max_seq;
|
|
uint32_t ssrc;
|
|
uint32_t jitter;
|
|
int32_t transit;
|
|
int cycles;
|
|
} stats;
|
|
|
|
/* Alternative values for RTP tx, in case no sufficient header
|
|
* information is available so the header needs to be generated
|
|
* locally (when just forwarding packets, the header of incoming
|
|
* data is just re-used) */
|
|
uint16_t alt_rtp_tx_sequence;
|
|
uint32_t alt_rtp_tx_ssrc;
|
|
};
|
|
|
|
struct mgcp_rtp_tap {
|
|
/* is this tap active (1) or not (0) */
|
|
int enabled;
|
|
/* IP/port to which we're forwarding the tapped data */
|
|
struct osmo_sockaddr forward;
|
|
};
|
|
|
|
struct mgcp_conn;
|
|
|
|
int mgcp_send(struct mgcp_endpoint *endp, int is_rtp, struct osmo_sockaddr *addr,
|
|
struct msgb *msg, struct mgcp_conn_rtp *conn_src,
|
|
struct mgcp_conn_rtp *conn_dst);
|
|
int mgcp_send_dummy(struct mgcp_endpoint *endp, struct mgcp_conn_rtp *conn);
|
|
int mgcp_dispatch_rtp_bridge_cb(struct msgb *msg);
|
|
void mgcp_cleanup_rtp_bridge_cb(struct mgcp_endpoint *endp, struct mgcp_conn *conn);
|
|
int mgcp_dispatch_e1_bridge_cb(struct msgb *msg);
|
|
void mgcp_cleanup_e1_bridge_cb(struct mgcp_endpoint *endp, struct mgcp_conn *conn);
|
|
int mgcp_conn_rtp_bind_rtp_ports(struct mgcp_conn_rtp *conn, int rtp_port);
|
|
void mgcp_patch_and_count(const struct mgcp_endpoint *endp,
|
|
struct mgcp_rtp_state *state,
|
|
struct mgcp_rtp_end *rtp_end,
|
|
struct osmo_sockaddr *addr, struct msgb *msg);
|
|
int mgcp_get_local_addr(char *addr, struct mgcp_conn_rtp *conn);
|
|
|
|
/* internal RTP Annex A counting */
|
|
void mgcp_rtp_annex_count(const struct mgcp_endpoint *endp, struct mgcp_rtp_state *state,
|
|
const uint16_t seq, const int32_t transit,
|
|
const uint32_t ssrc, const bool marker_bit);
|
|
|
|
void rtpconn_rate_ctr_add(struct mgcp_conn_rtp *conn_rtp, struct mgcp_endpoint *endp,
|
|
int id, int inc);
|
|
void rtpconn_rate_ctr_inc(struct mgcp_conn_rtp *conn_rtp, struct mgcp_endpoint *endp,
|
|
int id);
|
|
void forward_data_tap(struct osmo_io_fd *iofd, struct mgcp_rtp_tap *tap, struct msgb *msg);
|
|
uint32_t mgcp_get_current_ts(unsigned codec_rate);
|
|
|
|
int amr_oa_bwe_convert(struct mgcp_endpoint *endp, struct msgb *msg, bool target_is_oa);
|