stasis_subscription Struct Reference

Collaboration diagram for stasis_subscription:

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

Detailed Description

Definition at line 747 of file stasis.c.

Field Documentation

accepted_formatters

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]

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().

callback

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().

current

size_t current

Definition at line 769 of file stasis.c.

data

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().

elems

char* elems

Definition at line 769 of file stasis.c.

filter

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().

final_message_processed

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().

final_message_rxed

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().

join_cond

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().

mailbox

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().

max

size_t max

Definition at line 769 of file stasis.c.

topic

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().

uniqueid

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().

---

The documentation for this struct was generated from the following file:

• stasis.c