Asterisk - The Open Source Telephony Project
18.5.0
|
Data Fields | |
stasis_subscription_cb | callback |
void * | data |
int | final_message_processed |
int | final_message_rxed |
ast_cond_t | join_cond |
struct ast_taskprocessor * | mailbox |
struct stasis_topic * | topic |
char * | uniqueid |
stasis_subscription_cb callback |
Callback function for incoming message processing.
Definition at line 689 of file stasis.c.
Referenced by internal_stasis_subscribe(), jb_debug_output(), and subscription_invoke().
void* data |
Data pointer to be handed to the callback.
Definition at line 691 of file stasis.c.
Referenced by __do_deliver(), __schedule_action(), auth_reject(), auto_hangup(), dp_lookup_thread(), iax2_delete_from_sched(), iax2_process_thread(), iax2_process_thread_cleanup(), internal_stasis_subscribe(), jb_debug_output(), parse_dial_string(), send_apathetic_reply(), sub_cleanup(), subscription_invoke(), and transmit_frame().
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 700 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 697 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 694 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_subscription_join(), subscription_dtor(), and subscription_invoke().
struct ast_taskprocessor* mailbox |
Mailbox for processing incoming messages.
Definition at line 687 of file stasis.c.
Referenced by build_peer(), dispatch_message(), internal_stasis_subscribe(), stasis_subscription_set_congestion_limits(), stasis_unsubscribe(), and subscription_dtor().
struct stasis_topic* topic |
Topic subscribed to.
Definition at line 685 of file stasis.c.
Referenced by internal_stasis_subscribe(), stasis_publish_sync(), stasis_show_topic(), stasis_subscription_accept_formatters(), stasis_subscription_accept_message_type(), stasis_subscription_decline_message_type(), stasis_subscription_is_subscribed(), stasis_subscription_set_filter(), stasis_unsubscribe(), and subscription_dtor().
char* uniqueid |
Unique ID for this subscription
Definition at line 683 of file stasis.c.
Referenced by internal_stasis_subscribe(), send_subscription_subscribe(), send_subscription_unsubscribe(), stasis_show_topic(), stasis_subscription_statistics_create(), stasis_subscription_uniqueid(), and subscription_dtor().