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

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

Definition at line 320 of file switch_core_memory.c.

Referenced by switch_core_session_thread().

{
        apr_pool_tag(pool, tag);
}

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
	)

Definition at line 1991 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;
}

int switch_core_test_flag

(

int

flag

)

Definition at line 1800 of file switch_core.c.

References switch_test_flag.

Referenced by 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);
}