mirror of
https://gitea.osmocom.org/cellular-infrastructure/osmo-mgw.git
synced 2025-10-23 08:12:01 +00:00
cc29933ee5
This should really be using the FSM in libosmocore/laforge/iu_up: take the best of both sides and integate in the libosmocore FSM implementation, then use it here. - in libosmocore, the FSM definition is nicer. - here, we have correct header checksums. Introduce using msgb to receive, pass and send RTP packets. Add/strip IuUP from RTP data (for which msgb is particularly useful). The payload type on an IuUP conn is maintained as negotiated in the IuUP Initialization. For the pure RTP side, an SDP "AMR" ptmap attribute is looked up, so that payload type numbers are translated between IuUP <-> RTP. Change-Id: Ibc70e0aa00476926dd1f4ea8139c34f31f9cdfa3
114 lines
3.5 KiB
C
114 lines
3.5 KiB
C
/* Endpoint types */
|
|
|
|
/*
|
|
* (C) 2017 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
|
|
* All Rights Reserved
|
|
*
|
|
* Author: Philipp Maier
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
* the Free Software Foundation; either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <osmocom/core/msgb.h>
|
|
|
|
struct sockaddr_in;
|
|
struct mgcp_conn;
|
|
struct mgcp_conn_rtp;
|
|
struct mgcp_endpoint;
|
|
|
|
struct osmo_rtp_msg_ctx {
|
|
int proto;
|
|
struct mgcp_conn_rtp *conn_src;
|
|
struct sockaddr_in *from_addr;
|
|
};
|
|
|
|
#define OSMO_RTP_MSG_CTX(MSGB) (*(struct osmo_rtp_msg_ctx**)&((MSGB)->dst))
|
|
|
|
#define LOG_ENDP(endp, level, fmt, args...) \
|
|
LOGP(DRTP, level, "%x@ " fmt, ENDPOINT_NUMBER(endp), ## args)
|
|
|
|
/* Callback type for RTP dispatcher functions (e.g mgcp_dispatch_rtp_bridge_cb, see below).
|
|
* The OSMO_RTP_MSG_CTX() should be set appropriately on the msg. */
|
|
typedef int (*mgcp_dispatch_rtp_cb) (struct msgb *msg);
|
|
|
|
/* Callback type for endpoint specific cleanup actions. This function
|
|
* is automatically executed when a connection is freed (see mgcp_conn_free()
|
|
* in mgcp_conn.c). Depending on the type of the endpoint there may be endpoint
|
|
* specific things to take care of once a connection has been removed. */
|
|
typedef void (*mgcp_cleanup_cp) (struct mgcp_endpoint *endp,
|
|
struct mgcp_conn *conn);
|
|
|
|
/*! MGCP endpoint properties */
|
|
struct mgcp_endpoint_type {
|
|
/*! maximum number of connections */
|
|
int max_conns;
|
|
|
|
/*! callback that defines how to dispatch incoming RTP data */
|
|
mgcp_dispatch_rtp_cb dispatch_rtp_cb;
|
|
|
|
/*! callback that implements endpoint specific cleanup actions */
|
|
mgcp_cleanup_cp cleanup_cb;
|
|
};
|
|
|
|
/*! MGCP endpoint typeset */
|
|
struct mgcp_endpoint_typeset {
|
|
struct mgcp_endpoint_type rtp;
|
|
};
|
|
|
|
/*! static MGCP endpoint typeset (pre-initalized, read-only) */
|
|
extern const struct mgcp_endpoint_typeset ep_typeset;
|
|
|
|
/*! MGCP endpoint model */
|
|
struct mgcp_endpoint {
|
|
|
|
/*! Call identifier string (as supplied by the call agant) */
|
|
char *callid;
|
|
|
|
/*! Local connection options (see mgcp_internal.h) */
|
|
struct mgcp_lco local_options;
|
|
|
|
/*! List of struct mgcp_conn, of the connections active on this endpoint */
|
|
struct llist_head conns;
|
|
|
|
/*! Backpointer to the MGW configuration */
|
|
struct mgcp_config *cfg;
|
|
|
|
/*! Backpointer to the Trunk specific configuration */
|
|
struct mgcp_trunk_config *tcfg;
|
|
|
|
/*! Endpoint properties (see above) */
|
|
const struct mgcp_endpoint_type *type;
|
|
|
|
/*! Last MGCP transmission (in case re-transmission is required) */
|
|
char *last_trans;
|
|
|
|
/*! Last MGCP response (in case re-transmission is required) */
|
|
char *last_response;
|
|
|
|
/*! Memorize if this endpoint was choosen by the MGW (wildcarded, true)
|
|
* or if the user has choosen the particular endpoint explicitly. */
|
|
bool wildcarded_req;
|
|
|
|
/*! MGCP_X_OSMO_IGN_* flags from 'X-Osmo-IGN:' header */
|
|
uint32_t x_osmo_ign;
|
|
};
|
|
|
|
/*! Extract endpoint number for a given endpoint */
|
|
#define ENDPOINT_NUMBER(endp) abs((int)(endp - endp->tcfg->endpoints))
|
|
|
|
void mgcp_endp_release(struct mgcp_endpoint *endp);
|