Asterisk - The Open Source Telephony Project GIT-master-2de1a68
Functions
command.h File Reference

Internal API for the Stasis application commands. More...

#include "asterisk/stasis_app_impl.h"
Include dependency graph for command.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

void command_complete (struct stasis_app_command *command, int retval)
 
struct stasis_app_commandcommand_create (stasis_app_command_cb callback, void *data, command_data_destructor_fn data_destructor)
 
void command_invoke (struct stasis_app_command *command, struct stasis_app_control *control, struct ast_channel *chan)
 
int command_join (struct stasis_app_command *command)
 
struct ao2_containercommand_prestart_get_container (struct ast_channel *chan)
 Get the Stasis() prestart commands for a channel. More...
 
int command_prestart_queue_command (struct ast_channel *chan, stasis_app_command_cb command_fn, void *data, command_data_destructor_fn data_destructor)
 Queue a Stasis() prestart command for a channel. More...
 

Detailed Description

Internal API for the Stasis application commands.

Author
David M. Lee, II dlee@.nosp@m.digi.nosp@m.um.co.nosp@m.m
Since
12

Definition in file command.h.

Function Documentation

◆ command_complete()

void command_complete ( struct stasis_app_command command,
int  retval 
)

Definition at line 77 of file command.c.

78{
79 ast_mutex_lock(&command->lock);
80 command->is_done = 1;
81 command->retval = retval;
82 ast_cond_signal(&command->condition);
83 ast_mutex_unlock(&command->lock);
84}
static ENTRY retval
Definition: hsearch.c:50
#define ast_mutex_unlock(a)
Definition: lock.h:190
#define ast_mutex_lock(a)
Definition: lock.h:189
#define ast_cond_signal(cond)
Definition: lock.h:203
ast_cond_t condition
Definition: command.c:35
unsigned int is_done
Definition: command.c:40
ast_mutex_t lock
Definition: command.c:34

References ast_cond_signal, ast_mutex_lock, ast_mutex_unlock, stasis_app_command::condition, stasis_app_command::is_done, stasis_app_command::lock, stasis_app_command::retval, and retval.

Referenced by command_invoke(), control_flush_queue(), and exec_command_on_condition().

◆ command_create()

struct stasis_app_command * command_create ( stasis_app_command_cb  callback,
void *  data,
command_data_destructor_fn  data_destructor 
)

Definition at line 55 of file command.c.

57{
58 struct stasis_app_command *command;
59
60 command = ao2_alloc(sizeof(*command), command_dtor);
61 if (!command) {
62 if (data_destructor) {
64 }
65 return NULL;
66 }
67
68 ast_mutex_init(&command->lock);
69 ast_cond_init(&command->condition, 0);
70 command->callback = callback;
71 command->data = data;
73
74 return command;
75}
#define ao2_alloc(data_size, destructor_fn)
Definition: astobj2.h:409
static void command_dtor(void *obj)
Definition: command.c:43
#define ast_cond_init(cond, attr)
Definition: lock.h:201
#define ast_mutex_init(pmutex)
Definition: lock.h:186
#define NULL
Definition: resample.c:96
stasis_app_command_cb callback
Definition: command.c:36
command_data_destructor_fn data_destructor
Definition: command.c:38

References ao2_alloc, ast_cond_init, ast_mutex_init, stasis_app_command::callback, command_dtor(), stasis_app_command::condition, stasis_app_command::data, stasis_app_command::data_destructor, stasis_app_command::lock, and NULL.

Referenced by command_prestart_queue_command(), and exec_command_on_condition().

◆ command_invoke()

void command_invoke ( struct stasis_app_command command,
struct stasis_app_control control,
struct ast_channel chan 
)

Definition at line 101 of file command.c.

103{
104 int retval = command->callback(control, chan, command->data);
105 if (command->data_destructor) {
106 command->data_destructor(command->data);
107 command->data_destructor = NULL;
108 }
109 command_complete(command, retval);
110}
void command_complete(struct stasis_app_command *command, int retval)
Definition: command.c:77

References stasis_app_command::callback, command_complete(), stasis_app_command::data, stasis_app_command::data_destructor, NULL, and retval.

Referenced by control_dispatch_all(), and control_prestart_dispatch_all().

◆ command_join()

int command_join ( struct stasis_app_command command)

Definition at line 86 of file command.c.

87{
88 int ret;
89
90 ast_mutex_lock(&command->lock);
91 while (!command->is_done) {
92 ast_cond_wait(&command->condition, &command->lock);
93 }
94
95 ret = command->retval;
96 ast_mutex_unlock(&command->lock);
97
98 return ret;
99}
#define ast_cond_wait(cond, mutex)
Definition: lock.h:205

References ast_cond_wait, ast_mutex_lock, ast_mutex_unlock, stasis_app_command::condition, stasis_app_command::is_done, stasis_app_command::lock, and stasis_app_command::retval.

Referenced by app_send_command_on_condition().

◆ command_prestart_get_container()

struct ao2_container * command_prestart_get_container ( struct ast_channel chan)

Get the Stasis() prestart commands for a channel.

Precondition
chan must be locked
Parameters
chanThe channel from which to get prestart commands
Returns
The command prestart container for chan (must be ao2_cleanup()'d)

Definition at line 160 of file command.c.

161{
163
164 if (!datastore) {
165 return NULL;
166 }
167
168 return ao2_bump(datastore->data);
169}
#define ao2_bump(obj)
Bump refcount on an AO2 object by one, returning the object.
Definition: astobj2.h:480
struct ast_datastore * ast_channel_datastore_find(struct ast_channel *chan, const struct ast_datastore_info *info, const char *uid)
Find a datastore on a channel.
Definition: channel.c:2399
static const struct ast_datastore_info command_queue_prestart
Definition: command.c:118
Structure for a data store object.
Definition: datastore.h:64
void * data
Definition: datastore.h:66

References ao2_bump, ast_channel_datastore_find(), command_queue_prestart, ast_datastore::data, and NULL.

Referenced by control_prestart_dispatch_all().

◆ command_prestart_queue_command()

int command_prestart_queue_command ( struct ast_channel chan,
stasis_app_command_cb  command_fn,
void *  data,
command_data_destructor_fn  data_destructor 
)

Queue a Stasis() prestart command for a channel.

Precondition
chan must be locked
Parameters
chanThe channel on which to queue the prestart command
command_fnThe callback to call for the command
dataThe data to pass to the command callback
data_destructorOptional function which will be called on the data in either the event of command completion or failure to schedule or complete the command
Return values
zeroon success
non-zeroon failure

Definition at line 123 of file command.c.

125{
126 struct ast_datastore *datastore;
127 struct ao2_container *command_queue;
128 RAII_VAR(struct stasis_app_command *, command,
129 command_create(command_fn, data, data_destructor), ao2_cleanup);
130
131 if (!command) {
132 return -1;
133 }
134
136 if (datastore) {
137 command_queue = datastore->data;
138 ao2_link(command_queue, command);
139 return 0;
140 }
141
143 if (!command_queue) {
144 return -1;
145 }
146
148 if (!datastore) {
149 ao2_cleanup(command_queue);
150 return -1;
151 }
152 ast_channel_datastore_add(chan, datastore);
153
154 datastore->data = command_queue;
155 ao2_link(command_queue, command);
156
157 return 0;
158}
#define ao2_link(container, obj)
Add an object to a container.
Definition: astobj2.h:1532
@ AO2_ALLOC_OPT_LOCK_MUTEX
Definition: astobj2.h:363
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
#define ao2_container_alloc_list(ao2_options, container_options, sort_fn, cmp_fn)
Allocate and initialize a list container.
Definition: astobj2.h:1327
int ast_channel_datastore_add(struct ast_channel *chan, struct ast_datastore *datastore)
Add a datastore to a channel.
Definition: channel.c:2385
struct stasis_app_command * command_create(stasis_app_command_cb callback, void *data, command_data_destructor_fn data_destructor)
Definition: command.c:55
#define ast_datastore_alloc(info, uid)
Definition: datastore.h:85
Generic container type.
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
Definition: utils.h:941

References AO2_ALLOC_OPT_LOCK_MUTEX, ao2_cleanup, ao2_container_alloc_list, ao2_link, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_datastore_alloc, command_create(), command_queue_prestart, ast_datastore::data, NULL, and RAII_VAR.

Referenced by bridge_stasis_queue_join_action().