| Asterisk - The Open Source Telephony Project GIT-master-27fb039
    | 

| 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 771 of file stasis.c.
Referenced by dispatch_message(), internal_stasis_subscribe(), and stasis_subscription_accept_formatters().
| struct { ... } accepted_message_types | 
The message types this subscription is accepting
Referenced by dispatch_message(), internal_stasis_subscribe(), stasis_subscription_accept_message_type(), stasis_subscription_decline_message_type(), subscription_dtor(), and subscription_invoke().
| stasis_subscription_cb callback | 
Callback function for incoming message processing.
Definition at line 755 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 757 of file stasis.c.
Referenced by __stasis_subscribe(), __stasis_subscribe_pool(), ao2_weakproxy_subscribe(), ao2_weakproxy_unsubscribe(), internal_stasis_subscribe(), process_opcode(), sub_cleanup(), and subscription_invoke().
| enum stasis_subscription_message_filter filter | 
The message filter currently in use
Definition at line 773 of file stasis.c.
Referenced by dispatch_message(), 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 766 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 763 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 760 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 753 of file stasis.c.
Referenced by 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 751 of file stasis.c.
Referenced by __stasis_subscribe(), __stasis_subscribe_pool(), internal_stasis_subscribe(), publish_msg(), stasis_publish(), stasis_publish_sync(), stasis_show_topic(), stasis_state_subscribe_pool(), stasis_state_subscriber_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 749 of file stasis.c.
Referenced by internal_stasis_subscribe(), send_subscription_subscribe(), send_subscription_unsubscribe(), stasis_show_topic(), stasis_subscription_uniqueid(), and subscription_dtor().