get rid of mgcp_internal.h
The file mgcp_internal.h still contains mostly definitions and types
that are relevant for mgcp_network.c and mgcp_protocol.c. Lets give
the network and protocol module its own header files, also move stuff
that does not relate to protocol and network to the appropiate places.
Change-Id: I837eaad771ed7252304db4a81c37953b70766fff
diff --git a/include/osmocom/mgcp/mgcp_network.h b/include/osmocom/mgcp/mgcp_network.h
new file mode 100644
index 0000000..c08d009
--- /dev/null
+++ b/include/osmocom/mgcp/mgcp_network.h
@@ -0,0 +1,163 @@
+#pragma once
+
+#include <inttypes.h>
+#include <stdbool.h>
+#include <osmocom/mgcp/mgcp.h>
+
+#define MGCP_DUMMY_LOAD 0x23
+#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? */
+ int 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;
+
+ bool patched_first_rtp_payload; /* FIXME: drop this, see OS#2459 */
+};
+
+struct mgcp_rtp_codec {
+ uint32_t rate;
+ int channels;
+ uint32_t frame_duration_num;
+ uint32_t frame_duration_den;
+
+ int payload_type;
+ char *audio_name;
+ char *subtype_name;
+
+ bool param_present;
+ struct mgcp_codec_param param;
+};
+
+/* 'mgcp_rtp_end': basically a wrapper around the RTP+RTCP ports */
+struct mgcp_rtp_end {
+ /* local IP address of the RTP socket */
+ struct in_addr addr;
+
+ /* in network byte order */
+ int rtp_port, rtcp_port;
+
+ /* currently selected audio codec */
+ struct mgcp_rtp_codec *codec;
+
+ /* array with assigned audio codecs to choose from (SDP) */
+ struct mgcp_rtp_codec codecs[MGCP_MAX_CODECS];
+
+ /* number of assigned audio codecs (SDP) */
+ unsigned int codecs_assigned;
+
+ /* per endpoint data */
+ int frames_per_packet;
+ uint32_t packet_duration_ms;
+ int maximum_packet_time; /* -1: not set */
+ char *fmtp_extra;
+ /* are we transmitting packets (1) or dropping (0) outbound packets */
+ int output_enabled;
+ /* FIXME: This parameter can be set + printed, but is nowhere used! */
+ int force_output_ptime;
+
+ /* RTP patching */
+ int force_constant_ssrc; /* -1: always, 0: don't, 1: once */
+ /* should we perform align_rtp_timestamp_offset() (1) or not (0) */
+ int force_aligned_timing;
+ bool rfc5993_hr_convert;
+
+ /* Each end has a separate socket for RTP and RTCP */
+ struct osmo_fd rtp;
+ struct osmo_fd rtcp;
+
+ /* local UDP port number of the RTP socket; RTCP is +1 */
+ int local_port;
+};
+
+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 sockaddr_in forward;
+};
+
+struct mgcp_conn;
+
+int mgcp_send(struct mgcp_endpoint *endp, int is_rtp, struct sockaddr_in *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_bind_net_rtp_port(struct mgcp_endpoint *endp, int rtp_port,
+ struct mgcp_conn_rtp *conn);
+void mgcp_free_rtp_port(struct mgcp_rtp_end *end);
+void mgcp_patch_and_count(struct mgcp_endpoint *endp,
+ struct mgcp_rtp_state *state,
+ struct mgcp_rtp_end *rtp_end,
+ struct sockaddr_in *addr, struct msgb *msg);
+void mgcp_get_local_addr(char *addr, struct mgcp_conn_rtp *conn);
+int mgcp_set_ip_tos(int fd, int tos);
+
+/* payload processing default functions */
+int mgcp_rtp_processing_default(struct mgcp_endpoint *endp, struct mgcp_rtp_end *dst_end,
+ char *data, int *len, int buf_size);
+
+int mgcp_setup_rtp_processing_default(struct mgcp_endpoint *endp,
+ struct mgcp_conn_rtp *conn_dst,
+ struct mgcp_conn_rtp *conn_src);
+
+void mgcp_get_net_downlink_format_default(struct mgcp_endpoint *endp,
+ const struct mgcp_rtp_codec **codec,
+ const char **fmtp_extra,
+ struct mgcp_conn_rtp *conn);
+
+/* internal RTP Annex A counting */
+void mgcp_rtp_annex_count(struct mgcp_endpoint *endp, struct mgcp_rtp_state *state,
+ const uint16_t seq, const int32_t transit,
+ const uint32_t ssrc);