Asterisk - The Open Source Telephony Project
21.4.1
|
Data Fields | |
enum stasis_subscription_message_formatters | accepted_formatters |
struct { | |
size_t current | |
char * elems | |
size_t max | |
} | accepted_message_types |
stasis_subscription_cb | callback |
void * | data |
enum stasis_subscription_message_filter | filter |
int | final_message_processed |
int | final_message_rxed |
ast_cond_t | join_cond |
struct ast_taskprocessor * | mailbox |
struct stasis_topic * | topic |
char * | uniqueid |
enum stasis_subscription_message_formatters accepted_formatters |
The message formatters this subscription is accepting
Definition at line 704 of file stasis.c.
Referenced by internal_stasis_subscribe(), and stasis_subscription_accept_formatters().
struct { ... } accepted_message_types |
The message types this subscription is accepting
Referenced by internal_stasis_subscribe(), stasis_subscription_accept_message_type(), stasis_subscription_decline_message_type(), and subscription_invoke().
stasis_subscription_cb callback |
Callback function for incoming message processing.
Definition at line 688 of file stasis.c.
Referenced by internal_stasis_subscribe(), and subscription_invoke().
void* data |
Data pointer to be handed to the callback.
Definition at line 690 of file stasis.c.
Referenced by internal_stasis_subscribe(), and subscription_invoke().
enum stasis_subscription_message_filter filter |
The message filter currently in use
Definition at line 706 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_subscription_accept_message_type(), stasis_subscription_set_filter(), and subscription_invoke().
int final_message_processed |
Flag set when final message for sub has been processed. Be sure join_lock is held before reading/setting.
Definition at line 699 of file stasis.c.
Referenced by stasis_subscription_join(), and subscription_invoke().
int final_message_rxed |
Flag set when final message for sub has been received. Be sure join_lock is held before reading/setting.
Definition at line 696 of file stasis.c.
Referenced by stasis_subscription_is_done(), and subscription_invoke().
ast_cond_t join_cond |
Condition for joining with subscription.
Definition at line 693 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_subscription_join(), and subscription_invoke().
struct ast_taskprocessor* mailbox |
Mailbox for processing incoming messages.
Definition at line 686 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_subscription_set_congestion_limits(), and stasis_unsubscribe().
struct stasis_topic* topic |
Topic subscribed to.
Definition at line 684 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_publish_sync(), stasis_subscription_accept_formatters(), stasis_subscription_accept_message_type(), stasis_subscription_decline_message_type(), stasis_subscription_is_subscribed(), stasis_subscription_set_filter(), and stasis_unsubscribe().
char* uniqueid |
Unique ID for this subscription
Definition at line 682 of file stasis.c.
Referenced by internal_stasis_subscribe(), and stasis_subscription_uniqueid().