Core Library

Collaboration diagram for Core Library:

Modules
	Bitpacking
	Buffer Routines
	Caller Identity / Dialplan
	Channel Functions
	Config File Parser
	Media Bugs
	Port Allocation
	Startup/Shutdown
	Read/Write Locking
	State Handlers
	Memory Pooling/Allocation
	Session Creation / Management
	Hash Functions
	Timer Functions
	Codec Functions
	Database Functions
	File Functions
	ASR/TTS Functions
	Directory Service Functions
	Misc
	Eventing Engine
	IVR Library
	LIMIT code
	Loadable Module Functions
	Logger Routines
	NAT code
	Audio Resample Functions
	RTP (RealTime Transport Protocol)
	Scheduler
	STUN code
	VAD code with optional libfvad
	XML Library Functions

Functions
int	switch_core_test_flag (int flag)
void	switch_core_memory_pool_tag (switch_memory_pool_t *pool, const char *tag)
void	switch_core_pool_stats (switch_stream_handle_t *stream)
switch_status_t	switch_core_perform_new_memory_pool (_Out_ switch_memory_pool_t **pool, _In_z_ const char *file, _In_z_ const char *func, _In_ int line)
switch_core_session_t *	switch_core_session_request_xml (switch_endpoint_interface_t *endpoint_interface, switch_memory_pool_t **pool, switch_xml_t xml)

Detailed Description

Function Documentation

switch_core_memory_pool_tag()

void switch_core_memory_pool_tag	(	switch_memory_pool_t *	pool,
		const char *	tag
	)

Definition at line 331 of file switch_core_memory.c.

Referenced by switch_core_session_thread().

{
        fspr_pool_tag(pool, tag);
}

switch_core_perform_new_memory_pool()

switch_status_t switch_core_perform_new_memory_pool	(	_Out_ switch_memory_pool_t **	pool,
		_In_z_ const char *	file,
		_In_z_ const char *	func,
		_In_ int	line
	)

switch_core_pool_stats()

void switch_core_pool_stats

(

switch_stream_handle_t *

stream

)

Definition at line 376 of file switch_core_memory.c.

References switch_runtime::memory_pool, runtime, and switch_stream_handle::write_function.

{
#if APR_POOL_DEBUG
        if (runtime.memory_pool) {
                fspr_pool_walk_tree_debug(runtime.memory_pool, switch_core_pool_stats_callback, (void *)stream);
        }
#else
        if (stream) {
                stream->write_function(stream, "Unable to get core pool statictics. Please rebuild FreeSWITCH with --enable-pool-debug");
        } else {
                printf("Unable to get core pool statictics. Please rebuild FreeSWITCH with --enable-pool-debug");
        }
#endif
}

switch_core_session_request_xml()

switch_core_session_t* switch_core_session_request_xml	(	switch_endpoint_interface_t *	endpoint_interface,
		switch_memory_pool_t **	pool,
		switch_xml_t	xml
	)

Definition at line 2148 of file switch_core_session.c.

References switch_channel_timetable::answered, switch_caller_profile::callee_id_name, switch_caller_profile::callee_id_number, CC_FLAG_MAX, CF_ACCEPT_CNG, CF_ATTENDED_TRANSFER, CF_BLOCK_BROADCAST_UNTIL_MEDIA, CF_BLOCK_STATE, CF_BREAK, CF_BRIDGE_NOWRITE, CF_BRIDGED, CF_BROADCAST, CF_BROADCAST_DROP_MEDIA, CF_BYPASS_MEDIA_AFTER_BRIDGE, CF_CNG_PLC, CF_CONSUME_ON_ORIGINATE, CF_CONTROLLED, CF_DIALPLAN, CF_DISABLE_RINGBACK, CF_DIVERT_EVENTS, CF_EARLY_HANGUP, CF_EARLY_OK, CF_EVENT_LOCK, CF_EVENT_LOCK_PRI, CF_EVENT_PARSE, CF_FLAG_MAX, CF_FS_RTP, CF_GEN_RINGBACK, CF_HOLD, CF_INNER_BRIDGE, CF_JITTERBUFFER, CF_JITTERBUFFER_PLC, CF_LAZY_ATTENDED_TRANSFER, CF_LEG_HOLDING, CF_MEDIA_ACK, CF_MEDIA_BRIDGE_TTL, CF_MEDIA_SET, CF_NOT_READY, CF_ORIGINATING, CF_ORIGINATOR, CF_PARK, CF_PASSTHRU_PTIME_MISMATCH, CF_PAUSE_BUGS, CF_RECOVERED, CF_RECOVERING, CF_RECOVERING_BRIDGE, CF_REDIRECT, CF_REPORTING, CF_REQ_MEDIA, CF_RESET, CF_SERVICE, CF_SIGNAL_BRIDGE_TTL, CF_SIGNAL_DATA, CF_SIMPLIFY, CF_STOP_BROADCAST, CF_SUSPEND, CF_TAGGED, CF_THREAD_SLEEPING, CF_TIMESTAMP_SET, CF_TRACKED, CF_TRANSFER, CF_UNICAST, CF_VIDEO_DECODED_READ, CF_VIDEO_READY, CF_WINNER, CF_XFER_ZOMBIE, switch_xml::child, switch_channel_timetable::created, switch_channel_timetable::hungup, switch_xml::name, parse_array(), switch_channel_timetable::profile_created, switch_channel_timetable::progress, switch_channel_timetable::progress_media, switch_channel_timetable::resurrected, switch_xml::sibling, SOF_NO_LIMITS, SWITCH_CALL_DIRECTION_INBOUND, SWITCH_CALL_DIRECTION_OUTBOUND, switch_caller_profile_new(), switch_channel_get_caller_profile(), switch_channel_set_caller_profile(), switch_channel_set_cap_value(), switch_channel_set_flag, switch_channel_set_flag_value(), switch_channel_set_name(), switch_channel_set_originatee_caller_profile(), switch_channel_set_originator_caller_profile(), switch_channel_set_variable, switch_core_session_alloc, switch_core_session_destroy, switch_core_session_get_channel(), switch_core_session_get_pool(), switch_core_session_request_uuid(), switch_core_session_strdup, switch_time_now(), switch_url_decode(), switch_xml_child(), switch_caller_profile::times, switch_channel_timetable::transferred, switch_xml::txt, and xml_find_var().

Referenced by recover_callback().

{
        switch_core_session_t *session;
        switch_channel_t *channel;
        switch_xml_t tag, tag2, tag3, vars, callflow;
        switch_call_direction_t direction = SWITCH_CALL_DIRECTION_OUTBOUND;
        char *flag_str = NULL, *cap_str = NULL, *direction_s = NULL, *uuid = NULL;
        uint32_t flags[CF_FLAG_MAX] = { 0 };
        uint32_t caps[CC_FLAG_MAX] = { 0 };
        int i;

        vars = switch_xml_child(xml, "variables");
        uuid = xml_find_var(vars, "uuid");

        if ((tag = switch_xml_child(xml, "channel_data"))) {
                direction_s = xml_find_var(tag, "direction");
                direction = !strcmp(direction_s, "outbound") ? SWITCH_CALL_DIRECTION_OUTBOUND : SWITCH_CALL_DIRECTION_INBOUND;
                flag_str = xml_find_var(tag, "flags");
                cap_str = xml_find_var(tag, "caps");
        }

        parse_array(flag_str, flags, CF_FLAG_MAX);
        parse_array(cap_str, caps, CC_FLAG_MAX);

        flags[CF_RECOVERING] = 0;
        flags[CF_RECOVERING_BRIDGE] = 0;
        flags[CF_TRACKED] = 0;
        flags[CF_TRANSFER] = 0;
        flags[CF_ACCEPT_CNG] = 0;
        flags[CF_REDIRECT] = 0;
        flags[CF_BRIDGED] = 0;
        flags[CF_HOLD] = 0;
        flags[CF_SERVICE] = 0;
        flags[CF_TAGGED] = 0;
        flags[CF_WINNER] = 0;
        flags[CF_EARLY_OK] = 0;
        flags[CF_CONTROLLED] = 0;
        flags[CF_SUSPEND] = 0;
        flags[CF_EVENT_PARSE] = 0;
        flags[CF_GEN_RINGBACK] = 0;
        flags[CF_BREAK] = 0;
        flags[CF_BROADCAST] = 0;
        flags[CF_UNICAST] = 0;
        flags[CF_EVENT_LOCK] = 0;
        flags[CF_EVENT_LOCK_PRI] = 0;
        flags[CF_RESET] = 0;
        flags[CF_ORIGINATING] = 0;
        flags[CF_STOP_BROADCAST] = 0;
        flags[CF_INNER_BRIDGE] = 0;
        flags[CF_REQ_MEDIA] = 0;
        flags[CF_PAUSE_BUGS] = 0;
        flags[CF_DIVERT_EVENTS] = 0;
        flags[CF_BLOCK_STATE] = 0;
        flags[CF_FS_RTP] = 0;
        flags[CF_REPORTING] = 0;
        flags[CF_PARK] = 0;
        flags[CF_TIMESTAMP_SET] = 0;
        flags[CF_ORIGINATOR] = 0;
        flags[CF_XFER_ZOMBIE] = 0;
        flags[CF_MEDIA_ACK] = 0;
        flags[CF_THREAD_SLEEPING] = 0;
        flags[CF_DISABLE_RINGBACK] = 0;
        flags[CF_NOT_READY] = 0;
        flags[CF_SIGNAL_BRIDGE_TTL] = 0;
        flags[CF_MEDIA_BRIDGE_TTL] = 0;
        flags[CF_BYPASS_MEDIA_AFTER_BRIDGE] = 0;
        flags[CF_LEG_HOLDING] = 0;
        flags[CF_BROADCAST_DROP_MEDIA] = 0;
        flags[CF_EARLY_HANGUP] = 0;
        flags[CF_MEDIA_SET] = 0;
        flags[CF_CONSUME_ON_ORIGINATE] = 0;
        flags[CF_PASSTHRU_PTIME_MISMATCH] = 0;
        flags[CF_BRIDGE_NOWRITE] = 0;
        flags[CF_RECOVERED] = 0;
        flags[CF_JITTERBUFFER] = 0;
        flags[CF_JITTERBUFFER_PLC] = 0;
        flags[CF_DIALPLAN] = 0;
        flags[CF_BLOCK_BROADCAST_UNTIL_MEDIA] = 0;
        flags[CF_CNG_PLC] = 0;
        flags[CF_ATTENDED_TRANSFER] = 0;
        flags[CF_LAZY_ATTENDED_TRANSFER] = 0;
        flags[CF_SIGNAL_DATA] = 0;
        flags[CF_SIMPLIFY] = 0;
        flags[CF_VIDEO_READY] = 0;
        flags[CF_VIDEO_DECODED_READ] = 0;

        if (!(session = switch_core_session_request_uuid(endpoint_interface, direction, SOF_NO_LIMITS, pool, uuid))) {
                return NULL;
        }

        channel = switch_core_session_get_channel(session);

        for (i = 0; i < CF_FLAG_MAX; i++) {
                if (flags[i]) {
                        switch_channel_set_flag_value(channel, i, flags[i]);
                }
        }

        for (i = 0; i < CC_FLAG_MAX; i++) {
                if (caps[i]) {
                        switch_channel_set_cap_value(channel, i, caps[i]);
                }
        }

        if ((tag2 = switch_xml_child(xml, "variables"))) {
                for (tag = tag2->child; tag; tag = tag->sibling) {
                        if (tag->name && tag->txt) {
                                char *p = strdup(tag->txt);
                                char *val = p;
                                switch_url_decode(val);
                                switch_channel_set_variable(channel, tag->name, val);
                                if (!strcasecmp(tag->name, "channel_name")) {
                                        switch_channel_set_name(channel, val);
                                }
                                free(p);
                        }
                }
        }

        if ((callflow = switch_xml_child(xml, "callflow"))) {
                if ((tag2 = switch_xml_child(callflow, "caller_profile"))) {
                        switch_caller_profile_t *caller_profile;
                        char *tmp;

                        caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session),
                                                                                                           xml_find_var(tag2, "username"),
                                                                                                           xml_find_var(tag2, "dialplan"),
                                                                                                           xml_find_var(tag2, "caller_id_name"),
                                                                                                           xml_find_var(tag2, "caller_id_number"),
                                                                                                           xml_find_var(tag2, "network_addr"),
                                                                                                           xml_find_var(tag2, "ani"),
                                                                                                           xml_find_var(tag2, "aniii"),
                                                                                                           xml_find_var(tag2, "rdnis"),
                                                                                                           xml_find_var(tag2, "source"),
                                                                                                           xml_find_var(tag2, "context"), xml_find_var(tag2, "destination_number"));

                        if ((tmp = xml_find_var(tag2, "callee_id_name"))) {
                                caller_profile->callee_id_name = switch_core_session_strdup(session, tmp);
                        }

                        if ((tmp = xml_find_var(tag2, "callee_id_number"))) {
                                caller_profile->callee_id_number = switch_core_session_strdup(session, tmp);
                        }

                        if ((tag3 = switch_xml_child(callflow, "times"))) {
                                caller_profile->times = (switch_channel_timetable_t *) switch_core_session_alloc(session, sizeof(*caller_profile->times));

                                caller_profile->times->resurrected = switch_time_now();

                                for (tag3 = tag3->child; tag3; tag3 = tag3->sibling) {
                                        int64_t v;

                                        if (tag3->name && tag3->txt) {
                                                v = atoll(tag3->txt);
                                                if (!strcmp(tag3->name, "created_time")) {
                                                        caller_profile->times->created = v;
                                                } else if (!strcmp(tag3->name, "profile_created_time")) {
                                                        caller_profile->times->profile_created = v;
                                                } else if (!strcmp(tag3->name, "progress_time")) {
                                                        caller_profile->times->progress = v;
                                                } else if (!strcmp(tag3->name, "progress_media_time")) {
                                                        caller_profile->times->progress_media = v;
                                                } else if (!strcmp(tag3->name, "answered_time")) {
                                                        caller_profile->times->answered = v;
                                                } else if (!strcmp(tag3->name, "hangup_time")) {
                                                        caller_profile->times->hungup = v;
                                                } else if (!strcmp(tag3->name, "transfer_time")) {
                                                        caller_profile->times->transferred = v;
                                                }
                                        }

                                }
                        }

                        switch_channel_set_caller_profile(channel, caller_profile);
                        if ((tag = switch_xml_child(tag2, "originator")) && (tag = tag->child)) {
                                caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session),
                                                                                                                   xml_find_var(tag, "username"),
                                                                                                                   xml_find_var(tag, "dialplan"),
                                                                                                                   xml_find_var(tag, "caller_id_name"),
                                                                                                                   xml_find_var(tag, "caller_id_number"),
                                                                                                                   xml_find_var(tag, "network_addr"),
                                                                                                                   xml_find_var(tag, "ani"),
                                                                                                                   xml_find_var(tag, "aniii"),
                                                                                                                   xml_find_var(tag, "rdnis"),
                                                                                                                   xml_find_var(tag, "source"),
                                                                                                                   xml_find_var(tag, "context"), xml_find_var(tag, "destination_number"));

                                switch_channel_set_originator_caller_profile(channel, caller_profile);
                        }

                        if ((tag = switch_xml_child(tag2, "originatee")) && (tag = tag->child)) {
                                caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session),
                                                                                                                   xml_find_var(tag, "username"),
                                                                                                                   xml_find_var(tag, "dialplan"),
                                                                                                                   xml_find_var(tag, "caller_id_name"),
                                                                                                                   xml_find_var(tag, "caller_id_number"),
                                                                                                                   xml_find_var(tag, "network_addr"),
                                                                                                                   xml_find_var(tag, "ani"),
                                                                                                                   xml_find_var(tag, "aniii"),
                                                                                                                   xml_find_var(tag, "rdnis"),
                                                                                                                   xml_find_var(tag, "source"),
                                                                                                                   xml_find_var(tag, "context"), xml_find_var(tag, "destination_number"));

                                switch_channel_set_originatee_caller_profile(channel, caller_profile);
                        }

                }


                switch_channel_set_flag(channel, CF_RECOVERED);
        }


        if (!channel || !switch_channel_get_caller_profile(channel)) {
                if (session) {
                        switch_core_session_destroy(&session);
                }
        }


        return session;
}

switch_core_test_flag()

int switch_core_test_flag

(

int

flag

)

Definition at line 1792 of file switch_core.c.

References switch_test_flag.

Referenced by ecd_deliver(), switch_caller_profile_new(), switch_channel_expand_variables_check(), switch_core_session_exec(), switch_event_expand_headers_check(), switch_event_init(), and switch_event_shutdown().

{
        return switch_test_flag((&runtime), flag);
}