16 #include <arpa/inet.h> 17 #if defined (__MACH__) || defined(__FreeBSD__) 18 #include <machine/endian.h> 19 #define __BYTE_ORDER BYTE_ORDER 20 #define __BIG_ENDIAN BIG_ENDIAN 21 #define __LITTLE_ENDIAN LITTLE_ENDIAN 33 #define RTP_HEADER_SIZE 12 38 #if __BYTE_ORDER == __BIG_ENDIAN 45 #elif __BYTE_ORDER == __LITTLE_ENDIAN 77 #if __BYTE_ORDER == __BIG_ENDIAN 83 #elif __BYTE_ORDER == __LITTLE_ENDIAN 93 #define JANUS_RTP_EXTMAP_AUDIO_LEVEL "urn:ietf:params:rtp-hdrext:ssrc-audio-level" 95 #define JANUS_RTP_EXTMAP_TOFFSET "urn:ietf:params:rtp-hdrext:toffset" 97 #define JANUS_RTP_EXTMAP_ABS_SEND_TIME "http://www.webrtc.org/experiments/rtp-hdrext/abs-send-time" 99 #define JANUS_RTP_EXTMAP_ABS_CAPTURE_TIME "http://www.webrtc.org/experiments/rtp-hdrext/abs-capture-time" 101 #define JANUS_RTP_EXTMAP_VIDEO_ORIENTATION "urn:3gpp:video-orientation" 103 #define JANUS_RTP_EXTMAP_TRANSPORT_WIDE_CC "http://www.ietf.org/id/draft-holmer-rmcat-transport-wide-cc-extensions-01" 105 #define JANUS_RTP_EXTMAP_PLAYOUT_DELAY "http://www.webrtc.org/experiments/rtp-hdrext/playout-delay" 107 #define JANUS_RTP_EXTMAP_MID "urn:ietf:params:rtp-hdrext:sdes:mid" 109 #define JANUS_RTP_EXTMAP_RID "urn:ietf:params:rtp-hdrext:sdes:rtp-stream-id" 111 #define JANUS_RTP_EXTMAP_REPAIRED_RID "urn:ietf:params:rtp-hdrext:sdes:repaired-rtp-stream-id" 113 #define JANUS_RTP_EXTMAP_DEPENDENCY_DESC "https://aomediacodec.github.io/av1-rtp-spec/#dependency-descriptor-rtp-header-extension" 115 #define JANUS_RTP_EXTMAP_ENCRYPTED "urn:ietf:params:rtp-hdrext:encrypt" 195 gboolean *c, gboolean *f, gboolean *r1, gboolean *r0);
205 uint16_t *min_delay, uint16_t *max_delay);
215 char *sdes_item,
int sdes_len);
225 char *sdes_item,
int sdes_len);
235 uint8_t *dd_item,
int *dd_len);
315 #define RTP_AUDIO_SKEW_TH_MS 120 316 #define RTP_VIDEO_SKEW_TH_MS 120 317 #define SKEW_DETECTION_WAIT_TIME_SECS 10 378 uint8_t *dd,
int dd_len, uint8_t *template_id, uint8_t *ebit);
445 char *buf,
int len, uint8_t *dd_content,
int dd_len, uint32_t *ssrcs,
char **rids,
493 char *buf,
int len, uint8_t *dd_content,
int dd_len,
gboolean changed_temporal
Whether the temporal layer has changed after processing a packet.
Definition: rtp.h:405
int templayer_target
As above, but to handle transitions (e.g., wait for keyframe)
Definition: rtp.h:397
gboolean changed_spatial
Whether the spatial layer has changed after processing a packet.
Definition: rtp.h:469
gint64 evaluating_start_time
Definition: rtp.h:301
gboolean ts_reset
Definition: rtp.h:298
gboolean new_ssrc
Definition: rtp.h:298
uint32_t base_ts_prev
Definition: rtp.h:296
int janus_rtp_header_extension_parse_audio_level(char *buf, int len, int id, gboolean *vad, int *level)
Helper to parse a ssrc-audio-level RTP extension (https://tools.ietf.org/html/rfc6464) ...
Definition: rtp.c:215
void janus_rtp_svc_context_reset(janus_rtp_svc_context *context)
Set (or reset) the context fields to their default values.
Definition: rtp.c:1351
Helper struct to track SVC templates.
Definition: rtp.h:353
struct json_t json_t
Definition: plugin.h:236
Helper struct for processing and tracking VP9-SVC streams.
Definition: rtp.h:453
Helper struct for processing and tracking AV1-SVC streams.
Definition: rtp.h:337
gint64 created
Definition: rtp.h:64
int janus_rtp_header_extension_parse_mid(char *buf, int len, int id, char *sdes_item, int sdes_len)
Helper to parse a sdes-mid RTP extension (https://tools.ietf.org/html/draft-ietf-mmusic-sdp-bundle-ne...
Definition: rtp.c:271
uint16_t duration
Definition: rtp.h:82
janus_plugin_rtp_extensions extensions
Definition: rtp.h:66
gint64 last_relayed
When we relayed the last packet (used to detect when substreams become unavailable) ...
Definition: rtp.h:401
gint rid_ext_id
RTP Stream extension ID, if any.
Definition: rtp.h:387
int janus_rtp_header_extension_replace_id(char *buf, int len, int id, int new_id)
Helper to replace the ID of an RTP extension with a different one (e.g., to turn a repaired-rtp-strea...
Definition: rtp.c:433
int janus_videocodec_pt(janus_videocodec vcodec)
Definition: rtp.c:1037
int templayer
Which simulcast temporal layer we should forward back.
Definition: rtp.h:395
GMutex janus_mutex
Janus mutex implementation.
Definition: mutex.h:73
int janus_rtp_skew_compensate_video(janus_rtp_header *header, janus_rtp_switching_context *context, gint64 now)
Use the context info to compensate for video source skew, if needed.
Definition: rtp.c:648
Plugin-Core communication (implementation)
gboolean need_pli
Whether we need to send the user a keyframe request (PLI)
Definition: rtp.h:473
uint32_t prev_ts
Definition: rtp.h:296
gboolean changed_substream
Whether the substream has changed after processing a packet.
Definition: rtp.h:403
gboolean seq_reset
Definition: rtp.h:298
int janus_rtp_header_extension_parse_video_orientation(char *buf, int len, int id, gboolean *c, gboolean *f, gboolean *r1, gboolean *r0)
Helper to parse a video-orientation RTP extension (http://www.3gpp.org/ftp/Specs/html-info/26114.htm)
Definition: rtp.c:230
uint16_t base_seq_prev
Definition: rtp.h:297
int temporal_layers
Definition: rtp.h:345
janus_videocodec
Definition: rtp.h:136
uint32_t last_ts
Definition: rtp.h:296
uint8_t reserved
Definition: rtp.h:80
struct janus_rtp_header_extension janus_rtp_header_extension
RTP extension.
int janus_rtp_header_extension_parse_rid(char *buf, int len, int id, char *sdes_item, int sdes_len)
Helper to parse a rtp-stream-id RTP extension (https://tools.ietf.org/html/draft-ietf-avtext-rid-09) ...
Definition: rtp.c:292
char * janus_rtp_payload(char *buf, int len, int *plen)
Helper to quickly access the RTP payload, skipping header and extensions.
Definition: rtp.c:25
gint32 active_delay
Definition: rtp.h:300
uint8_t tioff
Template ID offset, as advertised via Dependency Descriptor.
Definition: rtp.h:341
VP9 SVC info, as parsed from a payload descriptor.
Definition: utils.h:409
struct janus_rtp_svc_context janus_rtp_svc_context
Helper struct for processing and tracking VP9-SVC streams.
gint32 ts_offset
Definition: rtp.h:300
int janus_rtp_header_extension_set_abs_send_time(char *buf, int len, int id, uint32_t abs_ts)
Helper to set an abs-send-time RTP extension (http://www.webrtc.org/experiments/rtp-hdrext/abs-send-t...
Definition: rtp.c:354
const char * janus_videocodec_name(janus_videocodec vcodec)
Definition: rtp.c:1002
void janus_rtp_simulcasting_prepare(json_t *simulcast, int *rid_ext_id, uint32_t *ssrcs, char **rids)
Helper method to prepare the simulcasting info (rids and/or SSRCs) from the simulcast object the core...
Definition: rtp.c:1071
gboolean janus_rtp_svc_context_process_rtp(janus_rtp_svc_context *context, char *buf, int len, uint8_t *dd_content, int dd_len, janus_videocodec vcodec, janus_vp9_svc_info *info, janus_rtp_switching_context *sc)
Process an RTP packet, and decide whether this should be relayed or not, updating the context accordi...
Definition: rtp.c:1361
gint16 seq_offset
Definition: rtp.h:299
uint32_t base_ts
Definition: rtp.h:296
int temporal
Temporal layer associated to this template.
Definition: rtp.h:359
gboolean janus_is_rtp(char *buf, guint len)
Helper method to demultiplex RTP from other protocols.
Definition: rtp.c:18
struct rtp_header rtp_header
RTP Header (http://tools.ietf.org/html/rfc3550#section-5.1)
struct janus_rtp_simulcasting_context janus_rtp_simulcasting_context
Helper struct for processing and tracking simulcast streams.
int substream_target_temp
Definition: rtp.h:393
uint8_t end
Definition: rtp.h:79
int janus_rtp_header_extension_parse_transport_wide_cc(char *buf, int len, int id, uint16_t *transSeqNum)
Helper to parse a transport wide sequence number (https://tools.ietf.org/html/draft-holmer-rmcat-tran...
Definition: rtp.c:399
uint32_t start_ts
Definition: rtp.h:296
uint8_t id
Template ID.
Definition: rtp.h:355
janus_audiocodec
Definition: rtp.h:119
RTP packet.
Definition: rtp.h:61
void janus_rtp_header_update(janus_rtp_header *header, janus_rtp_switching_context *context, gboolean video, int step)
Use the context info to update the RTP header of a packet, if needed.
Definition: rtp.c:762
int janus_rtp_skew_compensate_audio(janus_rtp_header *header, janus_rtp_switching_context *context, gint64 now)
Use the context info to compensate for audio source skew, if needed.
Definition: rtp.c:532
janus_videocodec janus_videocodec_from_name(const char *name)
Definition: rtp.c:1021
janus_av1_svc_context av1_context[3]
Dependency Descriptors contexts, if any.
Definition: rtp.h:389
guint32 drop_trigger
How much time (in us, default 250000) without receiving packets will make us drop to the substream be...
Definition: rtp.h:399
int spatial
Which SVC spatial layer we should forward back.
Definition: rtp.h:457
RTP context, in order to make sure SSRC changes result in coherent seq/ts increases.
Definition: rtp.h:295
gboolean need_pli
Whether we need to send the user a keyframe request (PLI)
Definition: rtp.h:407
int substream
Which simulcast substream we should forward back.
Definition: rtp.h:391
gint64 start_time
Definition: rtp.h:301
RTP RFC2833 payload.
Definition: rtp.h:76
int temporal_target
As above, but to handle transitions (e.g., wait for keyframe)
Definition: rtp.h:463
gint64 last_retransmit
Definition: rtp.h:65
GHashTable * templates
Map of templates advertised via Dependency Descriptor, indexed by ID.
Definition: rtp.h:343
uint16_t prev_seq
Definition: rtp.h:297
int spatial
Spatial layer associated to this template.
Definition: rtp.h:357
int temporal
Which SVC temporal layer we should forward back.
Definition: rtp.h:461
int janus_rtp_header_extension_set_abs_capture_time(char *buf, int len, int id, uint64_t abs_ts)
Helper to set an abs-capture-time RTP extension (http://www.webrtc.org/experiments/rtp-hdrext/abs-cap...
Definition: rtp.c:385
void janus_rtp_simulcasting_cleanup(int *rid_ext_id, uint32_t *ssrcs, char **rids, janus_mutex *rid_mutex)
Helper method to cleanup some or all of the simulcasting info (rids and/or SSRCs) we may have prepare...
Definition: rtp.c:1101
uint8_t tcnt
Number of templates advertised via Dependency Descriptor.
Definition: rtp.h:339
gint64 reference_time
Definition: rtp.h:301
struct janus_rtp_packet janus_rtp_packet
RTP packet.
uint8_t volume
Definition: rtp.h:81
guint32 drop_trigger
How much time (in us, default 250000) without receiving packets will make us drop to the substream be...
Definition: rtp.h:465
void janus_av1_svc_context_reset(janus_av1_svc_context *context)
Set (or reset) the context fields to their default values.
Definition: rtp.c:1596
uint8_t event
Definition: rtp.h:78
janus_audiocodec janus_audiocodec_from_name(const char *name)
Definition: rtp.c:946
int substream_target
As above, but to handle transitions (e.g., wait for keyframe, or get this if available) ...
Definition: rtp.h:393
struct janus_rtp_switching_context janus_rtp_switching_context
RTP context, in order to make sure SSRC changes result in coherent seq/ts increases.
gint64 last_spatial_layer[3]
When we relayed the last packet (used to detect when layers become unavailable)
Definition: rtp.h:467
int janus_rtp_header_extension_set_transport_wide_cc(char *buf, int len, int id, uint16_t transSeqNum)
Helper to set a transport wide sequence number (https://tools.ietf.org/html/draft-holmer-rmcat-transp...
Definition: rtp.c:419
struct janus_av1_svc_template janus_av1_svc_template
Helper struct to track SVC templates.
uint32_t target_ts
Definition: rtp.h:296
Janus plugin RTP extensions.
Definition: plugin.h:562
int janus_rtp_header_extension_parse_abs_send_time(char *buf, int len, int id, uint32_t *abs_ts)
Helper to parse an abs-send-time RTP extension (http://www.webrtc.org/experiments/rtp-hdrext/abs-send...
Definition: rtp.c:337
int spatial_target
As above, but to handle transitions (e.g., wait for keyframe, or get this if available) ...
Definition: rtp.h:459
int janus_audiocodec_pt(janus_audiocodec acodec)
Definition: rtp.c:972
struct janus_av1_svc_context dd_context
Dependency Descriptor context, in case it's needed.
Definition: rtp.h:455
int janus_rtp_header_extension_parse_dependency_desc(char *buf, int len, int id, uint8_t *dd_item, int *dd_len)
Helper to parse a dependency descriptor RTP extension (https://aomediacodec.github.io/av1-rtp-spec/#dependency-descriptor-rtp-header-extension)
Definition: rtp.c:314
rtp_header janus_rtp_header
Definition: rtp.h:58
char * data
Definition: rtp.h:62
gboolean updated
Whether this context changed since the last update.
Definition: rtp.h:347
const char * janus_rtp_header_extension_get_from_id(const char *sdp, int id)
Ugly and dirty helper to quickly get the RTP extension namespace associated with an id (extmap) in an...
Definition: rtp.c:80
int spatial_layers
How many spatial and temporal layers are available.
Definition: rtp.h:345
int janus_rtp_header_extension_get_id(const char *sdp, const char *extension)
Ugly and dirty helper to quickly get the id associated with an RTP extension (extmap) in an SDP...
Definition: rtp.c:51
gboolean changed_temporal
Whether the temporal layer has changed after processing a packet.
Definition: rtp.h:471
Helper struct for processing and tracking simulcast streams.
Definition: rtp.h:385
gint32 prev_delay
Definition: rtp.h:300
void janus_rtp_switching_context_reset(janus_rtp_switching_context *context)
Set (or reset) the context fields to their default values.
Definition: rtp.c:525
int janus_rtp_extension_id(const char *type)
Definition: rtp.c:498
gint length
Definition: rtp.h:63
uint16_t last_seq
Definition: rtp.h:297
uint16_t base_seq
Definition: rtp.h:297
const char * janus_audiocodec_name(janus_audiocodec acodec)
Definition: rtp.c:917
int janus_rtp_header_extension_parse_playout_delay(char *buf, int len, int id, uint16_t *min_delay, uint16_t *max_delay)
Helper to parse a playout-delay RTP extension (https://webrtc.org/experiments/rtp-hdrext/playout-dela...
Definition: rtp.c:252
gint64 last_time
Definition: rtp.h:301
struct janus_av1_svc_context janus_av1_svc_context
Helper struct for processing and tracking AV1-SVC streams.
int janus_rtp_header_extension_parse_abs_capture_time(char *buf, int len, int id, uint64_t *abs_ts)
Helper to parse an abs-capture-time RTP extension (http://www.webrtc.org/experiments/rtp-hdrext/abs-c...
Definition: rtp.c:368
struct janus_rtp_rfc2833_payload janus_rtp_rfc2833_payload
RTP RFC2833 payload.
gboolean janus_av1_svc_context_process_dd(janus_av1_svc_context *context, uint8_t *dd, int dd_len, uint8_t *template_id, uint8_t *ebit)
Process a Dependency Descriptor payload, updating the SVC context accordingly.
Definition: rtp.c:1605
uint32_t last_ssrc
Definition: rtp.h:296
void janus_rtp_simulcasting_context_reset(janus_rtp_simulcasting_context *context)
Set (or reset) the context fields to their default values.
Definition: rtp.c:1057
gboolean janus_rtp_simulcasting_context_process_rtp(janus_rtp_simulcasting_context *context, char *buf, int len, uint8_t *dd_content, int dd_len, uint32_t *ssrcs, char **rids, janus_videocodec vcodec, janus_rtp_switching_context *sc, janus_mutex *rid_mutex)
Process an RTP packet, and decide whether this should be relayed or not, updating the context accordi...
Definition: rtp.c:1121