Structure that collects messages from a topic. More...
#include <stasis_test.h>
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 |
Condition to signal state changes
Definition at line 48 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().
◆ 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
| ast_mutex_t lock |
Condition mutex.
Definition at line 46 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().
◆ 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:
