janus.h

Go to the documentation of this file.

 
#ifndef JANUS_CORE_H
#define JANUS_CORE_H
 
#include <inttypes.h>
#include <stdlib.h>
#include <stdint.h>
#include <stdio.h>
#include <string.h>
#include <ctype.h>
#include <unistd.h>
 
#include <jansson.h>
 
#include "mutex.h"
#include "ice.h"
#include "refcount.h"
#include "transports/transport.h"
#include "events/eventhandler.h"
#include "loggers/logger.h"
#include "plugins/plugin.h"
 
 
typedef struct janus_request janus_request;
 
typedef struct janus_session {
        guint64 session_id;
        GHashTable *ice_handles;
        gint64 last_activity;
        janus_request *source;
        volatile gint timedout;
        gint timeout;
        volatile gint transport_gone;
        janus_mutex mutex;
        volatile gint destroyed;
        janus_refcount ref;
} janus_session;
 
 
 
janus_session *janus_session_create(guint64 session_id);
janus_session *janus_session_find(guint64 session_id);
void janus_session_notify_event(janus_session *session, json_t *event);
gint janus_session_destroy(janus_session *session);
janus_ice_handle *janus_session_handles_find(janus_session *session, guint64 handle_id);
void janus_session_handles_insert(janus_session *session, janus_ice_handle *handle);
gint janus_session_handles_remove(janus_session *session, janus_ice_handle *handle);
void janus_session_handles_clear(janus_session *session);
json_t *janus_session_handles_list_json(janus_session *session);
 
 
 
struct janus_request {
        janus_transport *transport;
        janus_transport_session *instance;
        void *request_id;
        gboolean admin;
        json_t *message;
        json_error_t *error;
        volatile gint destroyed;
        janus_refcount ref;
};
janus_request *janus_request_new(janus_transport *transport, janus_transport_session *instance, void *request_id, gboolean admin, json_t *message, json_error_t *error);
void janus_request_destroy(janus_request *request);
int janus_process_incoming_request(janus_request *request);
int janus_process_incoming_admin_request(janus_request *request);
int janus_process_success(janus_request *request, json_t *payload);
int janus_process_error(janus_request *request, uint64_t session_id, const char *transaction, gint error, const char *format, ...) G_GNUC_PRINTF(5, 6);
 
 
 
void janus_transport_close(void *key, void *value, void *user_data);
void janus_transportso_close(void *key, void *value, void *user_data);
 
 
void janus_eventhandler_close(void *key, void *value, void *user_data);
void janus_eventhandlerso_close(void *key, void *value, void *user_data);
 
 
void janus_logger_close(void *key, void *value, void *user_data);
void janus_loggerso_close(void *key, void *value, void *user_data);
 
 
void janus_plugin_close(void *key, void *value, void *user_data);
void janus_pluginso_close(void *key, void *value, void *user_data);
janus_plugin *janus_plugin_find(const gchar *package);
 
gchar *janus_get_server_pem(void);
gchar *janus_get_server_key(void);
 
 
gchar *janus_get_local_ip(void);
gchar *janus_get_public_ip(guint index);
guint janus_get_public_ip_count(void);
void janus_add_public_ip(const char *ip);
gboolean janus_has_public_ipv4_ip(void);
gboolean janus_has_public_ipv6_ip(void);
 
gint janus_is_stopping(void);
 
gboolean janus_is_webrtc_encryption_enabled(void);
 
#endif