channel_internal.h File Reference

Internal channel functions for channel.c to use. More...

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	ast_channel_internal_alloc(destructor, assignedid, requestor)   __ast_channel_internal_alloc(destructor, assignedid, requestor, __FILE__, __LINE__, __PRETTY_FUNCTION__)

Functions
struct ast_channel *	__ast_channel_internal_alloc (void(*destructor)(void *obj), const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, const char *file, int line, const char *function)
struct ast_channel *	__ast_channel_internal_alloc_with_initializers (void(*destructor)(void *obj), const struct ast_assigned_ids *assignedids, const struct ast_channel *requestor, const struct ast_channel_initializers *initializers, const char *file, int line, const char *function)
void	ast_channel_close_storage (void)
void	ast_channel_internal_cleanup (struct ast_channel *chan)
enum ast_channel_error	ast_channel_internal_errno (void)
void	ast_channel_internal_errno_set (enum ast_channel_error error)
void	ast_channel_internal_finalize (struct ast_channel *chan)
int	ast_channel_internal_is_finalized (struct ast_channel *chan)
void	ast_channel_internal_set_stream_topology (struct ast_channel *chan, struct ast_stream_topology *topology)
void	ast_channel_internal_set_stream_topology_change_source (struct ast_channel *chan, void *change_source)
int	ast_channel_internal_setup_topics (struct ast_channel *chan)
void	ast_channel_internal_swap_stream_topology (struct ast_channel *chan1, struct ast_channel *chan2)
int	ast_channel_open_storage (void)

Variables
const struct ast_channelstorage_driver *	current_channel_storage_driver
	The current channel storage driver. More...
struct ast_channelstorage_instance *	current_channel_storage_instance
	The current channel storage instance. More...

Detailed Description

Internal channel functions for channel.c to use.

Definition in file channel_internal.h.

Macro Definition Documentation

ast_channel_internal_alloc

#define ast_channel_internal_alloc	(		destructor,
			assignedid,
			requestor
	)		__ast_channel_internal_alloc(destructor, assignedid, requestor, __FILE__, __LINE__, __PRETTY_FUNCTION__)

Definition at line 24 of file channel_internal.h.

Function Documentation

__ast_channel_internal_alloc()

struct ast_channel * __ast_channel_internal_alloc	(	void(*)(void *obj)	destructor,
		const struct ast_assigned_ids *	assignedids,
		const struct ast_channel *	requestor,
		const char *	file,
		int	line,
		const char *	function
	)

Definition at line 1267 of file channel_internal_api.c.

{
    return __ast_channel_internal_alloc_with_initializers(destructor, assignedids, requestor, NULL, file, line, function);
}

References __ast_channel_internal_alloc_with_initializers(), make_ari_stubs::file, and NULL.

Referenced by __ast_dummy_channel_alloc().

__ast_channel_internal_alloc_with_initializers()

struct ast_channel * __ast_channel_internal_alloc_with_initializers	(	void(*)(void *obj)	destructor,
		const struct ast_assigned_ids *	assignedids,
		const struct ast_channel *	requestor,
		const struct ast_channel_initializers *	initializers,
		const char *	file,
		int	line,
		const char *	function
	)

Definition at line 1190 of file channel_internal_api.c.

{
    struct ast_channel *tmp;
 
    tmp = __ao2_alloc(sizeof(*tmp), destructor,
        AO2_ALLOC_OPT_LOCK_MUTEX, "", file, line, function);
 
    if (!tmp) {
        return NULL;
    }
 
    if ((ast_string_field_init(tmp, 128))) {
        return ast_channel_unref(tmp);
    }
 
    tmp->dialed_causes = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
        DIALED_CAUSES_BUCKETS, pvt_cause_hash_fn, NULL, pvt_cause_cmp_fn);
    if (!tmp->dialed_causes) {
        return ast_channel_unref(tmp);
    }
 
    /* Check initializers validity here for early abort. Unfortunately, we can't do much here because
     * tenant ID is part of linked ID, which would overwrite it further down. */
    if (initializers) {
        if (initializers->version == 0) {
            ast_log(LOG_ERROR, "Channel initializers must have a non-zero version.\n");
            return ast_channel_unref(tmp);
        } else if (initializers->version != AST_CHANNEL_INITIALIZERS_VERSION) {
            ast_log(LOG_ERROR, "ABI mismatch for ast_channel_initializers. "
                "Please ensure all modules were compiled for "
                "this version of Asterisk.\n");
            return ast_channel_unref(tmp);
        }
    }
 
    /* set the creation time in the uniqueid */
    tmp->uniqueid.creation_time = time(NULL);
    tmp->uniqueid.creation_unique = ast_atomic_fetchadd_int(&uniqueint, 1);
 
    /* use provided id or default to historical {system-}time.# format */
    if (assignedids && !ast_strlen_zero(assignedids->uniqueid)) {
        ast_copy_string(tmp->uniqueid.unique_id, assignedids->uniqueid, sizeof(tmp->uniqueid.unique_id));
    } else if (ast_strlen_zero(ast_config_AST_SYSTEM_NAME)) {
        snprintf(tmp->uniqueid.unique_id, sizeof(tmp->uniqueid.unique_id), "%li.%d",
            (long)(tmp->uniqueid.creation_time),
            tmp->uniqueid.creation_unique);
    } else {
        snprintf(tmp->uniqueid.unique_id, sizeof(tmp->uniqueid.unique_id), "%s-%li.%d",
            ast_config_AST_SYSTEM_NAME,
            (long)(tmp->uniqueid.creation_time),
            tmp->uniqueid.creation_unique);
    }
 
    /* copy linked id from parent channel if known */
    if (requestor) {
        tmp->linkedid = requestor->linkedid;
    } else {
        tmp->linkedid = tmp->uniqueid;
    }
 
    /* Things like tenant ID need to be set here, otherwise they would be overwritten by
     * things like inheriting linked ID above. */
    if (initializers) {
        ast_copy_string(tmp->linkedid.tenant_id, initializers->tenantid, sizeof(tmp->linkedid.tenant_id));
    }
 
    AST_VECTOR_INIT(&tmp->fds, AST_MAX_FDS);
 
    /* Force all channel snapshot segments to be created on first use, so we don't have to check if
     * an old snapshot exists.
     */
    ast_set_flag(&tmp->snapshot_segment_flags, AST_FLAGS_ALL);
 
    return tmp;
}

References __ao2_alloc(), AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_hash, ast_atomic_fetchadd_int(), AST_CHANNEL_INITIALIZERS_VERSION, ast_channel_unref, ast_config_AST_SYSTEM_NAME, ast_copy_string(), AST_FLAGS_ALL, ast_log, AST_MAX_FDS, ast_set_flag, ast_string_field_init, ast_strlen_zero(), AST_VECTOR_INIT, ast_channel_id::creation_time, ast_channel_id::creation_unique, ast_channel::dialed_causes, DIALED_CAUSES_BUCKETS, make_ari_stubs::file, ast_channel::linkedid, LOG_ERROR, NULL, pvt_cause_cmp_fn(), pvt_cause_hash_fn(), ast_channel::snapshot_segment_flags, ast_channel_id::tenant_id, ast_channel_initializers::tenantid, ast_channel_id::unique_id, ast_assigned_ids::uniqueid, ast_channel::uniqueid, uniqueint, and ast_channel_initializers::version.

Referenced by __ast_channel_alloc_ap(), and __ast_channel_internal_alloc().

ast_channel_close_storage()

void ast_channel_close_storage

(

void

)

Definition at line 7939 of file channel.c.

{
    ast_channelstorage_close(current_channel_storage_instance);
}

References ast_channelstorage_close(), and current_channel_storage_instance.

ast_channel_internal_cleanup()

void ast_channel_internal_cleanup

(

struct ast_channel *

chan

)

Definition at line 1364 of file channel_internal_api.c.

{
    if (chan->dialed_causes) {
        ao2_t_ref(chan->dialed_causes, -1,
            "done with dialed causes since the channel is going away");
        chan->dialed_causes = NULL;
    }
 
    ast_string_field_free_memory(chan);
 
    chan->channel_forward = stasis_forward_cancel(chan->channel_forward);
    chan->endpoint_forward = stasis_forward_cancel(chan->endpoint_forward);
 
    ao2_cleanup(chan->topic);
    chan->topic = NULL;
 
    ast_channel_internal_set_stream_topology(chan, NULL);
 
    AST_VECTOR_FREE(&chan->fds);
}

References ao2_cleanup, ao2_t_ref, ast_channel_internal_set_stream_topology(), ast_string_field_free_memory, AST_VECTOR_FREE, ast_channel::channel_forward, ast_channel::dialed_causes, ast_channel::endpoint_forward, NULL, stasis_forward_cancel(), and ast_channel::topic.

Referenced by ast_channel_destructor(), and ast_dummy_channel_destructor().

ast_channel_internal_errno()

enum ast_channel_error ast_channel_internal_errno

(

void

)

Definition at line 1466 of file channel_internal_api.c.

{
    enum ast_channel_error *error_code = ast_threadstorage_get(&channel_errno, sizeof(*error_code));
    if (!error_code) {
        return AST_CHANNEL_ERROR_UNKNOWN;
    }
 
    return *error_code;
}

References AST_CHANNEL_ERROR_UNKNOWN, ast_threadstorage_get(), and channel_errno.

Referenced by ast_channel_errno().

ast_channel_internal_errno_set()

void ast_channel_internal_errno_set

(

enum ast_channel_error

error

)

Definition at line 1456 of file channel_internal_api.c.

{
    enum ast_channel_error *error_code = ast_threadstorage_get(&channel_errno, sizeof(*error_code));
    if (!error_code) {
        return;
    }
 
    *error_code = error;
}

References ast_threadstorage_get(), channel_errno, and error().

Referenced by __ast_channel_alloc_ap().

ast_channel_internal_finalize()

void ast_channel_internal_finalize

(

struct ast_channel *

chan

)

Definition at line 1385 of file channel_internal_api.c.

{
    chan->finalized = 1;
}

References ast_channel::finalized.

Referenced by __ast_channel_alloc_ap().

ast_channel_internal_is_finalized()

int ast_channel_internal_is_finalized

(

struct ast_channel *

chan

)

Definition at line 1390 of file channel_internal_api.c.

{
    return chan->finalized;
}

References ast_channel::finalized.

Referenced by ast_channel_destructor().

ast_channel_internal_set_stream_topology()

void ast_channel_internal_set_stream_topology	(	struct ast_channel *	chan,
		struct ast_stream_topology *	topology
	)

Definition at line 516 of file channel_internal_api.c.

{
    ast_stream_topology_free(chan->stream_topology);
    chan->stream_topology = topology;
    channel_set_default_streams(chan);
}

References ast_stream_topology_free(), channel_set_default_streams(), and ast_channel::stream_topology.

Referenced by __ast_channel_alloc_ap(), ast_channel_internal_cleanup(), ast_channel_nativeformats_set(), and ast_channel_set_stream_topology().

ast_channel_internal_set_stream_topology_change_source()

void ast_channel_internal_set_stream_topology_change_source	(	struct ast_channel *	chan,
		void *	change_source
	)

Definition at line 524 of file channel_internal_api.c.

{
    chan->stream_topology_change_source = change_source;
}

References ast_channel::stream_topology_change_source.

Referenced by ast_channel_request_stream_topology_change(), and ast_channel_stream_topology_changed_externally().

ast_channel_internal_setup_topics()

int ast_channel_internal_setup_topics

(

struct ast_channel *

chan

)

Definition at line 1420 of file channel_internal_api.c.

{
    char *topic_name;
    int ret;
    ast_assert(chan->topic == NULL);
 
    if (ast_strlen_zero(chan->uniqueid.unique_id)) {
        static int dummy_id;
        ret = ast_asprintf(&topic_name, "channel:dummy-%d", ast_atomic_fetchadd_int(&dummy_id, +1));
    } else {
        ret = ast_asprintf(&topic_name, "channel:%s", chan->uniqueid.unique_id);
    }
 
    if (ret < 0) {
        return -1;
    }
 
    chan->topic = stasis_topic_create(topic_name);
    ast_free(topic_name);
    if (!chan->topic) {
        return -1;
    }
 
    chan->channel_forward = stasis_forward_all(ast_channel_topic(chan),
        ast_channel_topic_all());
    if (!chan->channel_forward) {
        ao2_ref(chan->topic, -1);
        chan->topic = NULL;
        return -1;
    }
 
    return 0;
}

References ao2_ref, ast_asprintf, ast_assert, ast_atomic_fetchadd_int(), ast_channel_topic(), ast_channel_topic_all(), ast_free, ast_strlen_zero(), ast_channel::channel_forward, NULL, stasis_forward_all(), stasis_topic_create(), ast_channel::topic, ast_channel_id::unique_id, and ast_channel::uniqueid.

Referenced by __ast_channel_alloc_ap(), and __ast_dummy_channel_alloc().

ast_channel_internal_swap_stream_topology()

void ast_channel_internal_swap_stream_topology	(	struct ast_channel *	chan1,
		struct ast_channel *	chan2
	)

Definition at line 1521 of file channel_internal_api.c.

{
    struct ast_stream_topology *tmp_topology;
 
    ast_assert(chan1 != NULL && chan2 != NULL);
 
    tmp_topology = chan1->stream_topology;
    chan1->stream_topology = chan2->stream_topology;
    chan2->stream_topology = tmp_topology;
 
    channel_set_default_streams(chan1);
    channel_set_default_streams(chan2);
}

References ast_assert, channel_set_default_streams(), NULL, and ast_channel::stream_topology.

Referenced by channel_do_masquerade().

ast_channel_open_storage()

int ast_channel_open_storage

(

void

)

Definition at line 7957 of file channel.c.

{
    if (!current_channel_storage_driver) {
        int rc = internal_channel_set_current_storage_driver(AST_CHANNELSTORAGE_DEFAULT_TYPE);
        if (rc) {
            ast_log(LOG_ERROR, "No channel storage backends available\n");
            return -1;
        }
    }
 
    current_channel_storage_instance =
        ast_channelstorage_open(current_channel_storage_driver, "channels");
    if (!current_channel_storage_instance) {
        ast_log(LOG_ERROR, "Failed to open channel storage driver '%s'\n",
            current_channel_storage_driver->driver_name);
        return -1;
    }
 
    return 0;
}

References AST_CHANNELSTORAGE_DEFAULT_TYPE, ast_channelstorage_open(), ast_log, current_channel_storage_driver, current_channel_storage_instance, ast_channelstorage_driver::driver_name, internal_channel_set_current_storage_driver(), and LOG_ERROR.

Referenced by ast_channels_init().

Variable Documentation

current_channel_storage_driver

const struct ast_channelstorage_driver* current_channel_storage_driver

extern

The current channel storage driver.

Definition at line 55 of file channel_internal_api.c.

Referenced by ast_channel_get_current_storage_driver_name(), ast_channel_open_storage(), and internal_channel_set_current_storage_driver().

current_channel_storage_instance

struct ast_channelstorage_instance* current_channel_storage_instance

extern

The current channel storage instance.

Definition at line 57 of file channel_internal_api.c.

Referenced by __ast_channel_alloc_ap(), ast_active_channels(), ast_change_name(), ast_channel_callback(), ast_channel_close_storage(), ast_channel_get_by_exten(), ast_channel_get_by_name(), ast_channel_get_by_name_prefix(), ast_channel_get_by_uniqueid(), ast_channel_iterator_all_new(), ast_channel_iterator_by_exten_new(), ast_channel_iterator_by_name_new(), ast_channel_iterator_destroy(), ast_channel_iterator_next(), ast_channel_open_storage(), ast_channel_unlink(), channel_do_masquerade(), channels_shutdown(), and do_ids_conflict().