janus_lua_data.h

Go to the documentation of this file.

 
#ifndef JANUS_LUA_DATA_H
#define JANUS_LUA_DATA_H
 
#include <lua.h>
#include <lualib.h>
#include <lauxlib.h>
 
#include "plugin.h"
 
#include "debug.h"
#include "apierror.h"
#include "config.h"
#include "mutex.h"
#include "rtp.h"
#include "rtcp.h"
#include "sdp-utils.h"
#include "record.h"
#include "utils.h"
 
/* Core pointer and related flags */
extern volatile gint lua_initialized, lua_stopping;
extern janus_callbacks *lua_janus_core;
 
/* Lua state: we define state and mutex as extern */
extern lua_State *lua_state;
extern janus_mutex lua_mutex;
 
/* Lua session: we keep only the barebone stuff here, the rest will be in the Lua script */
typedef struct janus_lua_session {
        janus_plugin_session *handle;           /* Pointer to the core-plugin session */
        uint32_t id;                                            /* Unique session ID (will be used to correlate with the Lua script) */
        /* The following are only needed for media manipulation, feedback and routing, and may not all be used */
        gboolean accept_audio;                          /* Whether incoming audio can be accepted or must be dropped */
        gboolean accept_video;                          /* Whether incoming video can be accepted or must be dropped */
        gboolean accept_data;                           /* Whether incoming data can be accepted or must be dropped */
        gboolean send_audio;                            /* Whether outgoing audio can be sent or must be dropped */
        gboolean send_video;                            /* Whether outgoing video can be sent or must be dropped */
        gboolean send_data;                                     /* Whether outgoing data can be sent or must be dropped */
        janus_rtp_switching_context artpctx, vrtpctx;
        janus_videocodec vcodec;                        /* Video codec this session is using */
        uint32_t ssrc[3];                                       /* Only needed in case VP8 (or H.264) simulcasting is involved */
        char *rid[3];                                           /* Only needed if simulcasting is rid-based */
        int rid_extmap_id;                                      /* rid extmap ID */
        janus_mutex rid_mutex;                          /* Mutex to protect access to the rid array and the extmap ID */
        janus_rtp_simulcasting_context sim_context;
        janus_vp8_simulcast_context vp8_context;
        uint32_t bitrate;                                       /* Bitrate limit */
        uint16_t pli_freq;                                      /* Regular PLI frequency (0=disabled) */
        gint64 pli_latest;                                      /* Time of latest sent PLI (to avoid flooding) */
        GSList *recipients;                                     /* Sessions that should receive media from this session */
        struct janus_lua_session *sender;       /* Other session this session is receiving media from */
        janus_mutex recipients_mutex;           /* Mutex to lock the recipients list */
        janus_recorder *arc;                            /* The Janus recorder instance for audio, if enabled */
        janus_recorder *vrc;                            /* The Janus recorder instance for video, if enabled */
        janus_recorder *drc;                            /* The Janus recorder instance for data, if enabled */
        janus_rtp_switching_context rec_ctx;
        janus_rtp_simulcasting_context rec_simctx;
        gboolean e2ee;                                          /* Whether media is encrypted, e.g., using Insertable Streams */
        janus_mutex rec_mutex;                          /* Mutex to protect the recorders from race conditions */
        volatile gint started;                          /* Whether this session's PeerConnection is ready or not */
        volatile gint dataready;                        /* Whether the data channel was established on this sessions's PeerConnection */
        volatile gint hangingup;                        /* Whether this session's PeerConnection is hanging up */
        volatile gint destroyed;                        /* Whether this session's been marked as destroyed */
        /* If you need any additional property (e.g., for hooks you added in janus_lua_extra.c) add them below this line */
 
        /* Reference counter */
        janus_refcount ref;
} janus_lua_session;
extern GHashTable *lua_sessions, *lua_ids;
extern janus_mutex lua_sessions_mutex;
janus_lua_session *janus_lua_lookup_session(janus_plugin_session *handle);
 
#endif