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"


#define JANUS_BUFSIZE   8192

typedef struct janus_request janus_request;

typedef struct janus_session {
        guint64 session_id;
        GHashTable *ice_handles;
        gint64 last_activity;
        janus_request *source;
        volatile 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;
        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);
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(void);
void janus_set_public_ip(const char *ip);
gint janus_is_stopping(void);

gboolean janus_is_webrtc_encryption_enabled(void);

#endif