parking.c File Reference

Parking Core. More...

#include "asterisk.h"
#include "asterisk/_private.h"
#include "asterisk/astobj2.h"
#include "asterisk/pbx.h"
#include "asterisk/bridge.h"
#include "asterisk/parking.h"
#include "asterisk/channel.h"
#include "asterisk/module.h"

Include dependency graph for parking.c:

Go to the source code of this file.

Functions
static	AO2_GLOBAL_OBJ_STATIC (parking_provider)
	The container for the parking provider. More...
struct ast_parked_call_payload *	ast_parked_call_payload_create (enum ast_parked_call_event_type event_type, struct ast_channel_snapshot *parkee_snapshot, const char *parker_dial_string, struct ast_channel_snapshot *retriever_snapshot, const char *parkinglot, unsigned int parkingspace, unsigned long int timeout, unsigned long int duration)
	Constructor for parked_call_payload objects. More...
int	ast_parking_blind_transfer_park (struct ast_bridge_channel *parker, const char *context, const char *exten, transfer_channel_cb parked_channel_cb, struct transfer_channel_data *parked_channel_data)
	Perform a blind transfer to a parking extension. More...
int	ast_parking_is_exten_park (const char *context, const char *exten)
	Determine if the context/exten is a "parking" extension. More...
int	ast_parking_park_bridge_channel (struct ast_bridge_channel *parkee, const char *parkee_uuid, const char *parker_uuid, const char *app_data)
	Perform a direct park on a channel in a bridge. More...
int	ast_parking_park_call (struct ast_bridge_channel *parker, char *exten, size_t length)
	Park the bridge and/or callers that this channel is in. More...
int	ast_parking_provider_registered (void)
	Check whether a parking provider is registered. More...
int	ast_parking_register_bridge_features (struct ast_parking_bridge_feature_fn_table *fn_table)
	Register a parking provider. More...
int	ast_parking_stasis_init (void)
	initializes the rtp engine arrays More...
struct stasis_topic *	ast_parking_topic (void)
	accessor for the parking stasis topic More...
int	ast_parking_unregister_bridge_features (const char *module_name)
	Unregister the current parking provider. More...
static void	parked_call_payload_destructor (void *obj)
	Destructor for parked_call_payload objects. More...
static void	parking_stasis_cleanup (void)
	STASIS_MESSAGE_TYPE_DEFN (ast_parked_call_type)
	Message type for parked calls. More...

Variables
static struct stasis_topic *	parking_topic
	Topic for parking lots. More...

Detailed Description

Parking Core.

Author

Jonathan Rose jrose.nosp@m.@dig.nosp@m.ium.c.nosp@m.om

Definition in file parking.c.

Function Documentation

AO2_GLOBAL_OBJ_STATIC()

static AO2_GLOBAL_OBJ_STATIC ( parking_provider  )

static

The container for the parking provider.

ast_parked_call_payload_create()

struct ast_parked_call_payload * ast_parked_call_payload_create	(	enum ast_parked_call_event_type	event_type,
		struct ast_channel_snapshot *	parkee_snapshot,
		const char *	parker_dial_string,
		struct ast_channel_snapshot *	retriever_snapshot,
		const char *	parkinglot,
		unsigned int	parkingspace,
		unsigned long int	timeout,
		unsigned long int	duration
	)

Constructor for parked_call_payload objects.

Since

12

Parameters

event_type	What kind of parked call event is happening
parkee_snapshot	channel snapshot of the parkee
parker_dial_string	dialstring used when the call times out
retriever_snapshot	channel snapshot of the retriever (NULL allowed)
parkinglot	name of the parking lot where the parked call is parked
parkingspace	what numerical parking space the parked call is parked in
timeout	how long the parked call can remain at the point this snapshot is created before timing out
duration	how long the parked call has currently been parked

Return values

NULL	if the parked call payload can't be allocated

Returns

reference to a newly created parked call payload

Definition at line 82 of file parking.c.

{
    RAII_VAR(struct ast_parked_call_payload *, payload, NULL, ao2_cleanup);
 
    payload = ao2_alloc(sizeof(*payload), parked_call_payload_destructor);
    if (!payload) {
        return NULL;
    }
 
    if (ast_string_field_init(payload, 32)) {
        return NULL;
    }
 
    payload->event_type = event_type;
 
    ao2_ref(parkee_snapshot, +1);
    payload->parkee = parkee_snapshot;
 
    if (retriever_snapshot) {
        ao2_ref(retriever_snapshot, +1);
        payload->retriever = retriever_snapshot;
    }
 
    if (parkinglot) {
        ast_string_field_set(payload, parkinglot, parkinglot);
    }
 
    if (parker_dial_string) {
        ast_string_field_set(payload, parker_dial_string, parker_dial_string);
    }
 
    payload->parkingspace = parkingspace;
    payload->timeout = timeout;
    payload->duration = duration;
 
    /* Bump the ref count by one since RAII_VAR is going to eat one when we leave. */
    ao2_ref(payload, +1);
    return payload;
}

References ao2_alloc, ao2_cleanup, ao2_ref, ast_string_field_init, ast_string_field_set, ast_parked_call_payload::duration, ast_parked_call_payload::event_type, NULL, parked_call_payload_destructor(), ast_parked_call_payload::parker_dial_string, ast_parked_call_payload::parkinglot, ast_parked_call_payload::parkingspace, RAII_VAR, and ast_parked_call_payload::timeout.

Referenced by parked_call_payload_from_failure(), and parked_call_payload_from_parked_user().

ast_parking_blind_transfer_park()

int ast_parking_blind_transfer_park	(	struct ast_bridge_channel *	parker,
		const char *	context,
		const char *	exten,
		transfer_channel_cb	parked_channel_cb,
		struct transfer_channel_data *	parked_channel_data
	)

Perform a blind transfer to a parking extension.

Parameters

parker	The ast_bridge_channel object that is initiating the parking
context	The context to blind transfer to
exten	The extension to blind transfer to
parked_channel_cb	Execute the following function on the channel that gets parked
parked_channel_data	Data for the parked_channel_cb

Note

If the bridge parker is in has more than one other occupant, the entire bridge will be parked using a Local channel

This is safe to be called outside of the Bridging API Bridging API.

Return values

0	on success
non-zero	on error

Definition at line 143 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, table,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (!table || !table->parking_blind_transfer_park) {
        return -1;
    }
 
    if (table->module) {
        SCOPED_MODULE_USE(table->module);
        return table->parking_blind_transfer_park(parker, context, exten, parked_channel_cb, parked_channel_data);
    }
 
    return table->parking_blind_transfer_park(parker, context, exten, parked_channel_cb, parked_channel_data);
}

References ao2_cleanup, ao2_global_obj_ref, voicemailpwcheck::context, parking_provider, RAII_VAR, SCOPED_MODULE_USE, and table.

Referenced by __analog_ss_thread(), analog_ss_thread(), and try_parking().

ast_parking_is_exten_park()

int ast_parking_is_exten_park	(	const char *	context,
		const char *	exten
	)

Determine if the context/exten is a "parking" extension.

Return values

0	if the extension is not a parking extension
1	if the extension is a parking extension

Definition at line 179 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, table,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (!table || !table->parking_is_exten_park) {
        return -1;
    }
 
    if (table->module) {
        SCOPED_MODULE_USE(table->module);
        return table->parking_is_exten_park(context, exten);
    }
 
    return table->parking_is_exten_park(context, exten);
}

References ao2_cleanup, ao2_global_obj_ref, voicemailpwcheck::context, parking_provider, RAII_VAR, SCOPED_MODULE_USE, and table.

Referenced by __analog_ss_thread(), and analog_ss_thread().

ast_parking_park_bridge_channel()

int ast_parking_park_bridge_channel	(	struct ast_bridge_channel *	parkee,
		const char *	parkee_uuid,
		const char *	parker_uuid,
		const char *	app_data
	)

Perform a direct park on a channel in a bridge.

Parameters

parkee	The channel in the bridge to be parked.
parkee_uuid	The UUID of the channel being packed.
parker_uuid	The UUID of the channel performing the park.
app_data	Data to pass to the Park application

Note

This must be called within the context of the Bridging API Bridging API. External entities should not call this method directly, but should instead use the direct call parking method or the blind transfer method.

Return values

0	on success
non-zero	on error

Definition at line 126 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, table,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (!table || !table->parking_park_bridge_channel) {
        return -1;
    }
 
    if (table->module) {
        SCOPED_MODULE_USE(table->module);
        return table->parking_park_bridge_channel(parkee, parkee_uuid, parker_uuid, app_data);
    }
 
    return table->parking_park_bridge_channel(parkee, parkee_uuid, parker_uuid, app_data);
}

References ao2_cleanup, ao2_global_obj_ref, ast_parked_call_payload::parkee, parking_provider, RAII_VAR, SCOPED_MODULE_USE, and table.

Referenced by bridge_channel_park().

ast_parking_park_call()

int ast_parking_park_call	(	struct ast_bridge_channel *	parker,
		char *	exten,
		size_t	length
	)

Park the bridge and/or callers that this channel is in.

Parameters

	parker	The bridge_channel parking the bridge
[out]	exten	Optional. The parking exten to access the parking lot.
	length	Optional. If exten is specified, the size of the buffer.

Note

This is safe to be called outside of the Bridging API Bridging API.

The exten parameter was intended to return the extension the channel or bridge was parked at if the call succeeds. However, accessing that information is very difficult to do with the new asynchronous design. That information may not be available anywhere by the time this function currently returns.

Return values

0	on success
non-zero	on error

Definition at line 162 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, table,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (!table || !table->parking_park_call) {
        return -1;
    }
 
    if (table->module) {
        SCOPED_MODULE_USE(table->module);
        return table->parking_park_call(parker, exten, length);
    }
 
    return table->parking_park_call(parker, exten, length);
}

References ao2_cleanup, ao2_global_obj_ref, parking_provider, RAII_VAR, SCOPED_MODULE_USE, and table.

ast_parking_provider_registered()

int ast_parking_provider_registered

(

void

)

Check whether a parking provider is registered.

Return values

0	if there is no parking provider regsistered
1	if there is a parking provider regsistered

Definition at line 241 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, table,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    return !!table;
}

References ao2_cleanup, ao2_global_obj_ref, parking_provider, RAII_VAR, and table.

Referenced by __analog_ss_thread(), analog_ss_thread(), bridge_channel_park(), and try_parking().

ast_parking_register_bridge_features()

int ast_parking_register_bridge_features

(

struct ast_parking_bridge_feature_fn_table *

fn_table

)

Register a parking provider.

Parameters

fn_table

The ast_parking_bridge_feature_fn_table to register

Return values

0	on success
-1	on error

Definition at line 196 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, wrapper,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (fn_table->module_version != PARKING_MODULE_VERSION) {
        ast_log(AST_LOG_WARNING, "Parking module provided incorrect parking module "
            "version: %u (expected: %d)\n", fn_table->module_version, PARKING_MODULE_VERSION);
        return -1;
    }
 
    if (wrapper) {
        ast_log(AST_LOG_WARNING, "Parking provider already registered by %s!\n",
            wrapper->module_name);
        return -1;
    }
 
    wrapper = ao2_alloc(sizeof(*wrapper), NULL);
    if (!wrapper) {
        return -1;
    }
    *wrapper = *fn_table;
 
    ao2_global_obj_replace_unref(parking_provider, wrapper);
    return 0;
}

References ao2_alloc, ao2_cleanup, ao2_global_obj_ref, ao2_global_obj_replace_unref, ast_log, AST_LOG_WARNING, ast_parking_bridge_feature_fn_table::module_version, NULL, PARKING_MODULE_VERSION, parking_provider, and RAII_VAR.

Referenced by load_parking_bridge_features().

ast_parking_stasis_init()

int ast_parking_stasis_init

(

void

)

initializes the rtp engine arrays

Since

12.0.0

Definition at line 53 of file parking.c.

{
    if (STASIS_MESSAGE_TYPE_INIT(ast_parked_call_type)) {
        return -1;
    }
 
    parking_topic = stasis_topic_create("parking:all");
    if (!parking_topic) {
        return -1;
    }
    ast_register_cleanup(parking_stasis_cleanup);
    return 0;
}

References ast_parked_call_type(), ast_register_cleanup(), parking_stasis_cleanup(), parking_topic, STASIS_MESSAGE_TYPE_INIT, and stasis_topic_create().

Referenced by asterisk_daemon().

ast_parking_unregister_bridge_features()

int ast_parking_unregister_bridge_features

(

const char *

module_name

)

Unregister the current parking provider.

Parameters

module_name

The module name of the provider to unregister

Return values

0	if the parking provider module_name was unregsistered
-1	on error

Definition at line 223 of file parking.c.

{
    RAII_VAR(struct ast_parking_bridge_feature_fn_table *, wrapper,
        ao2_global_obj_ref(parking_provider), ao2_cleanup);
 
    if (!wrapper) {
        return -1;
    }
 
    if (strcmp(wrapper->module_name, module_name)) {
        ast_log(AST_LOG_WARNING, "%s has not registered the parking provider\n", module_name);
        return -1;
    }
 
    ao2_global_obj_release(parking_provider);
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, ao2_global_obj_release, ast_log, AST_LOG_WARNING, parking_provider, and RAII_VAR.

Referenced by unload_parking_bridge_features().

parked_call_payload_destructor()

static void parked_call_payload_destructor ( void *  obj )

static

Destructor for parked_call_payload objects.

Definition at line 73 of file parking.c.

{
    struct ast_parked_call_payload *park_obj = obj;
 
    ao2_cleanup(park_obj->parkee);
    ao2_cleanup(park_obj->retriever);
    ast_string_field_free_memory(park_obj);
}

References ao2_cleanup, ast_string_field_free_memory, ast_parked_call_payload::parkee, and ast_parked_call_payload::retriever.

Referenced by ast_parked_call_payload_create().

parking_stasis_cleanup()

static void parking_stasis_cleanup ( void  )

static

Definition at line 46 of file parking.c.

{
    STASIS_MESSAGE_TYPE_CLEANUP(ast_parked_call_type);
    ao2_cleanup(parking_topic);
    parking_topic = NULL;
}

References ao2_cleanup, ast_parked_call_type(), NULL, parking_topic, and STASIS_MESSAGE_TYPE_CLEANUP.

Referenced by ast_parking_stasis_init().

STASIS_MESSAGE_TYPE_DEFN()

STASIS_MESSAGE_TYPE_DEFN

(

ast_parked_call_type

)

Message type for parked calls.

Variable Documentation

parking_topic

struct stasis_topic* parking_topic

static

Topic for parking lots.

Definition at line 41 of file parking.c.

Referenced by ast_parking_stasis_init(), ast_parking_topic(), and parking_stasis_cleanup().