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_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)

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 1410 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 1333 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, DIALED_CAUSES_BUCKETS, make_ari_stubs::file, ast_channel::linkedid, LOG_ERROR, NULL, pvt_cause_cmp_fn(), pvt_cause_hash_fn(), ast_channel_initializers::tenantid, tmp(), ast_assigned_ids::uniqueid, uniqueint, and ast_channel_initializers::version.

Referenced by __ast_channel_alloc_ap(), and __ast_channel_internal_alloc().

ast_channel_internal_cleanup()

void ast_channel_internal_cleanup

(

struct ast_channel *

chan

)

Definition at line 1500 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, ast_channel::fds, 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 1602 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 1592 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 1521 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 1526 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 659 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 667 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 1556 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 1657 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().