Asterisk - The Open Source Telephony Project  18.5.0
Data Fields
stasis_message_sink Struct Reference

Structure that collects messages from a topic. More...

#include <stasis_test.h>

Collaboration diagram for stasis_message_sink:
Collaboration graph
[legend]

Data Fields

ast_cond_t cond
 
int is_done:1
 
ast_mutex_t lock
 
size_t max_messages
 
struct stasis_message ** messages
 
size_t num_messages
 

Detailed Description

Structure that collects messages from a topic.

Definition at line 44 of file stasis_test.h.

Field Documentation

◆ cond

ast_cond_t cond

◆ is_done

int is_done

Boolean flag to be set when unsubscribe is received

Definition at line 55 of file stasis_test.h.

Referenced by message_sink_cb(), and stasis_message_sink_dtor().

◆ lock

◆ max_messages

size_t max_messages

Maximum number of messages messages field can hold without realloc

Definition at line 51 of file stasis_test.h.

Referenced by message_sink_cb(), and stasis_message_sink_dtor().

◆ messages

struct stasis_message** messages

Ordered array of messages received

Definition at line 57 of file stasis_test.h.

Referenced by message_sink_cb(), stasis_message_sink_dtor(), and stasis_message_sink_wait_for().

◆ num_messages

size_t num_messages

Current number of messages in messages field.

Definition at line 53 of file stasis_test.h.

Referenced by message_sink_cb(), stasis_message_sink_dtor(), stasis_message_sink_should_stay(), stasis_message_sink_wait_for(), and stasis_message_sink_wait_for_count().


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