Fork me on GitHub
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
Data Structures | Macros | Typedefs | Enumerations | Functions | Variables
janus_streaming.c File Reference
Plugins

Janus Streaming plugin. More...

#include "plugin.h"
#include <errno.h>
#include <netdb.h>
#include <sys/poll.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <jansson.h>
#include "../debug.h"
#include "../apierror.h"
#include "../config.h"
#include "../mutex.h"
#include "../rtp.h"
#include "../rtpsrtp.h"
#include "../rtcp.h"
#include "../record.h"
#include "../utils.h"
#include "../ip-utils.h"
Include dependency graph for janus_streaming.c:

Data Structures

struct  janus_streaming_rtp_keyframe
 
struct  janus_streaming_rtp_relay_packet
 
struct  janus_streaming_codecs
 
struct  janus_streaming_rtp_source
 
struct  janus_streaming_rtp_source_stream
 
struct  janus_streaming_file_source
 
struct  multiple_fds
 
struct  janus_streaming_mountpoint
 
struct  janus_streaming_helper
 
struct  janus_streaming_message
 
struct  janus_streaming_session_stream
 
struct  janus_streaming_session
 

Macros

#define JANUS_STREAMING_VERSION   9
 
#define JANUS_STREAMING_VERSION_STRING   "0.0.9"
 
#define JANUS_STREAMING_DESCRIPTION   "This is a streaming plugin for Janus, allowing WebRTC peers to watch/listen to pre-recorded files or media generated by an external source."
 
#define JANUS_STREAMING_NAME   "JANUS Streaming plugin"
 
#define JANUS_STREAMING_AUTHOR   "Meetecho s.r.l."
 
#define JANUS_STREAMING_PACKAGE   "janus.plugin.streaming"
 
#define DEFAULT_RTP_RANGE_MIN   10000
 
#define DEFAULT_RTP_RANGE_MAX   60000
 
#define JANUS_STREAMING_ERROR_NO_MESSAGE   450
 
#define JANUS_STREAMING_ERROR_INVALID_JSON   451
 
#define JANUS_STREAMING_ERROR_INVALID_REQUEST   452
 
#define JANUS_STREAMING_ERROR_MISSING_ELEMENT   453
 
#define JANUS_STREAMING_ERROR_INVALID_ELEMENT   454
 
#define JANUS_STREAMING_ERROR_NO_SUCH_MOUNTPOINT   455
 
#define JANUS_STREAMING_ERROR_CANT_CREATE   456
 
#define JANUS_STREAMING_ERROR_UNAUTHORIZED   457
 
#define JANUS_STREAMING_ERROR_CANT_SWITCH   458
 
#define JANUS_STREAMING_ERROR_CANT_RECORD   459
 
#define JANUS_STREAMING_ERROR_UNKNOWN_ERROR   470
 

Typedefs

typedef enum janus_streaming_type janus_streaming_type
 
typedef enum janus_streaming_source janus_streaming_source
 
typedef struct
janus_streaming_rtp_keyframe 		janus_streaming_rtp_keyframe
 
typedef struct
janus_streaming_rtp_relay_packet 		janus_streaming_rtp_relay_packet
 
typedef struct
janus_streaming_codecs 		janus_streaming_codecs
 
typedef struct
janus_streaming_rtp_source 		janus_streaming_rtp_source
 
typedef enum janus_streaming_media janus_streaming_media
 
typedef struct
janus_streaming_rtp_source_stream 		janus_streaming_rtp_source_stream
 
typedef struct
janus_streaming_file_source 		janus_streaming_file_source
 
typedef struct multiple_fds multiple_fds
 
typedef struct
janus_streaming_mountpoint 		janus_streaming_mountpoint
 
typedef struct
janus_streaming_helper 		janus_streaming_helper
 
typedef struct
janus_streaming_message 		janus_streaming_message
 
typedef struct
janus_streaming_session_stream 		janus_streaming_session_stream
 
typedef struct
janus_streaming_session 		janus_streaming_session
 

Enumerations

enum  janus_streaming_type { janus_streaming_type_none = 0, janus_streaming_type_live, janus_streaming_type_on_demand }
 
enum  janus_streaming_source { janus_streaming_source_none = 0, janus_streaming_source_file, janus_streaming_source_rtp }
 
enum  janus_streaming_media { JANUS_STREAMING_MEDIA_NONE = 0, JANUS_STREAMING_MEDIA_AUDIO, JANUS_STREAMING_MEDIA_VIDEO, JANUS_STREAMING_MEDIA_DATA }
 

Functions

janus_plugin * create (void)
 
int janus_streaming_init (janus_callbacks *callback, const char *config_path)
 
void janus_streaming_destroy (void)
 
int janus_streaming_get_api_compatibility (void)
 
int janus_streaming_get_version (void)
 
const char * janus_streaming_get_version_string (void)
 
const char * janus_streaming_get_description (void)
 
const char * janus_streaming_get_name (void)
 
const char * janus_streaming_get_author (void)
 
const char * janus_streaming_get_package (void)
 
void janus_streaming_create_session (janus_plugin_session *handle, int *error)
 
struct janus_plugin_result * janus_streaming_handle_message (janus_plugin_session *handle, char *transaction, json_t *message, json_t *jsep)
 
json_t * janus_streaming_handle_admin_message (json_t *message)
 
void janus_streaming_setup_media (janus_plugin_session *handle)
 
void janus_streaming_incoming_rtp (janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len)
 
void janus_streaming_incoming_rtcp (janus_plugin_session *handle, int mindex, gboolean video, char *buf, int len)
 
void janus_streaming_hangup_media (janus_plugin_session *handle)
 
void janus_streaming_destroy_session (janus_plugin_session *handle, int *error)
 
json_t * janus_streaming_query_session (janus_plugin_session *handle)
 
janus_streaming_rtp_source_stream * janus_streaming_create_rtp_source_stream (const char *name, int mindex, const char *type, const char *mid, const char *label, char *mcast, char *miface, const janus_network_address *iface, uint16_t port, uint16_t port2, uint16_t port3, uint16_t rtcpport, uint8_t codec, const char *rtpmap, const char *fmtp, gboolean doskew, gboolean bufferkf, gboolean buffermsg, gboolean simulcast, gboolean svc)
 
janus_streaming_mountpoint * janus_streaming_create_rtp_source (uint64_t id, char *name, char *desc, GList *media, int srtpsuite, char *srtpcrypto, int threads, int rtp_collision)
 
janus_streaming_mountpoint * janus_streaming_create_file_source (uint64_t id, char *name, char *desc, char *filename, gboolean live, gboolean doaudio, gboolean dovideo)
 
janus_streaming_mountpoint * janus_streaming_create_rtsp_source (uint64_t id, char *name, char *desc, char *url, char *username, char *password, gboolean doaudio, int audiopt, char *artpmap, char *afmtp, gboolean dovideo, int videopt, char *vrtpmap, char *vfmtp, const janus_network_address *iface, gboolean error_on_failure)
 

Variables

GHashTable * mountpoints
 
janus_mutex mountpoints_mutex
 

Detailed Description

Janus Streaming plugin.

Author
Lorenzo Miniero loren.nosp@m.zo@m.nosp@m.eetec.nosp@m.ho.c.nosp@m.om
Copyright
GNU General Public License v3

Check the Streaming plugin documentation for more details.

Plugins

Macro Definition Documentation

#define DEFAULT_RTP_RANGE_MAX   60000
#define DEFAULT_RTP_RANGE_MIN   10000
#define JANUS_STREAMING_AUTHOR   "Meetecho s.r.l."
#define JANUS_STREAMING_DESCRIPTION   "This is a streaming plugin for Janus, allowing WebRTC peers to watch/listen to pre-recorded files or media generated by an external source."
#define JANUS_STREAMING_ERROR_CANT_CREATE   456
#define JANUS_STREAMING_ERROR_CANT_RECORD   459
#define JANUS_STREAMING_ERROR_CANT_SWITCH   458
#define JANUS_STREAMING_ERROR_INVALID_ELEMENT   454
#define JANUS_STREAMING_ERROR_INVALID_JSON   451
#define JANUS_STREAMING_ERROR_INVALID_REQUEST   452
#define JANUS_STREAMING_ERROR_MISSING_ELEMENT   453
#define JANUS_STREAMING_ERROR_NO_MESSAGE   450
#define JANUS_STREAMING_ERROR_NO_SUCH_MOUNTPOINT   455
#define JANUS_STREAMING_ERROR_UNAUTHORIZED   457
#define JANUS_STREAMING_ERROR_UNKNOWN_ERROR   470
#define JANUS_STREAMING_NAME   "JANUS Streaming plugin"
#define JANUS_STREAMING_PACKAGE   "janus.plugin.streaming"
#define JANUS_STREAMING_VERSION   9
#define JANUS_STREAMING_VERSION_STRING   "0.0.9"

Typedef Documentation

typedef struct janus_streaming_codecs janus_streaming_codecs
typedef struct janus_streaming_file_source janus_streaming_file_source
typedef struct janus_streaming_helper janus_streaming_helper
typedef enum janus_streaming_media janus_streaming_media
typedef struct janus_streaming_message janus_streaming_message
typedef struct janus_streaming_mountpoint janus_streaming_mountpoint
typedef struct janus_streaming_rtp_keyframe janus_streaming_rtp_keyframe
typedef struct janus_streaming_rtp_relay_packet janus_streaming_rtp_relay_packet
typedef struct janus_streaming_rtp_source janus_streaming_rtp_source
typedef struct janus_streaming_rtp_source_stream janus_streaming_rtp_source_stream
typedef struct janus_streaming_session janus_streaming_session
typedef struct janus_streaming_session_stream janus_streaming_session_stream
typedef enum janus_streaming_source janus_streaming_source
typedef enum janus_streaming_type janus_streaming_type
typedef struct multiple_fds multiple_fds

Enumeration Type Documentation

enum janus_streaming_media
Enumerator
JANUS_STREAMING_MEDIA_NONE 
JANUS_STREAMING_MEDIA_AUDIO 
JANUS_STREAMING_MEDIA_VIDEO 
JANUS_STREAMING_MEDIA_DATA 
enum janus_streaming_source
Enumerator
janus_streaming_source_none 
janus_streaming_source_file 
janus_streaming_source_rtp 
enum janus_streaming_type
Enumerator
janus_streaming_type_none 
janus_streaming_type_live 
janus_streaming_type_on_demand 

Function Documentation

janus_plugin* create ( void  )
janus_streaming_mountpoint * janus_streaming_create_file_source ( uint64_t  id,
char *  name,
char *  desc,
char *  filename,
gboolean  live,
gboolean  doaudio,
gboolean  dovideo 
)
janus_streaming_mountpoint * janus_streaming_create_rtp_source ( uint64_t  id,
char *  name,
char *  desc,
GList *  media,
int  srtpsuite,
char *  srtpcrypto,
int  threads,
int  rtp_collision 
)
janus_streaming_rtp_source_stream * janus_streaming_create_rtp_source_stream ( const char *  name,
int  mindex,
const char *  type,
const char *  mid,
const char *  label,
char *  mcast,
char *  miface,
const janus_network_address *  iface,
uint16_t  port,
uint16_t  port2,
uint16_t  port3,
uint16_t  rtcpport,
uint8_t  codec,
const char *  rtpmap,
const char *  fmtp,
gboolean  doskew,
gboolean  bufferkf,
gboolean  buffermsg,
gboolean  simulcast,
gboolean  svc 
)
janus_streaming_mountpoint * janus_streaming_create_rtsp_source ( uint64_t  id,
char *  name,
char *  desc,
char *  url,
char *  username,
char *  password,
gboolean  doaudio,
int  audiopt,
char *  artpmap,
char *  afmtp,
gboolean  dovideo,
int  videopt,
char *  vrtpmap,
char *  vfmtp,
const janus_network_address *  iface,
gboolean  error_on_failure 
)
void janus_streaming_create_session ( janus_plugin_session *  handle,
int *  error 
)
void janus_streaming_destroy ( void  )
void janus_streaming_destroy_session ( janus_plugin_session *  handle,
int *  error 
)
int janus_streaming_get_api_compatibility ( void  )
const char * janus_streaming_get_author ( void  )
const char * janus_streaming_get_description ( void  )
const char * janus_streaming_get_name ( void  )
const char * janus_streaming_get_package ( void  )
int janus_streaming_get_version ( void  )
const char * janus_streaming_get_version_string ( void  )
json_t * janus_streaming_handle_admin_message ( json_t *  message)
struct janus_plugin_result * janus_streaming_handle_message ( janus_plugin_session *  handle,
char *  transaction,
json_t *  message,
json_t *  jsep 
)
void janus_streaming_hangup_media ( janus_plugin_session *  handle)
void janus_streaming_incoming_rtcp ( janus_plugin_session *  handle,
int  mindex,
gboolean  video,
char *  buf,
int  len 
)
void janus_streaming_incoming_rtp ( janus_plugin_session *  handle,
int  mindex,
gboolean  video,
char *  buf,
int  len 
)
int janus_streaming_init ( janus_callbacks *  callback,
const char *  config_path 
)
json_t * janus_streaming_query_session ( janus_plugin_session *  handle)
void janus_streaming_setup_media ( janus_plugin_session *  handle)

Variable Documentation

GHashTable* mountpoints
janus_mutex mountpoints_mutex
Last updated on Wed Sep 18 2019 — Janus WebRTC Server © Meetecho 2014-2019