#include <switch_cpp.h>

Collaboration diagram for EventConsumer:

Public Member Functions
	EventConsumer (const char event_name=NULL, const char subclass_name="", int len=5000)

	~ EventConsumer ()

int	bind (const char event_name, const char subclass_name="")

Event *	pop (int block=0, int timeout=0)

void	cleanup ()

Data Fields
switch_queue_t *	events

switch_event_types_t	e_event_id

char *	e_callback

char *	e_subclass_name

char *	e_cb_arg

switch_event_node_t *	enodes [SWITCH_EVENT_ALL+1]

uint32_t	node_index

Protected Attributes
switch_memory_pool_t *	pool

int	ready

Detailed Description

Definition at line 183 of file switch_cpp.h.

Constructor & Destructor Documentation

◆ EventConsumer()

EventConsumer::EventConsumer	(	const char *	event_name = `NULL`,
		const char *	subclass_name = `""`,
		int	len = `5000`
	)

Definition at line 54 of file switch_cpp.cpp.

References bind(), events, node_index, pool, ready, switch_core_new_memory_pool, switch_queue_create(), and zstr.

 {
 
         switch_core_new_memory_pool(&pool);
         switch_queue_create(&events, len, pool);
         node_index = 0;
         ready = 1;
 
         if (!zstr(event_name)) {
                 bind(event_name, subclass_name);
         }
 }

◆ ~ EventConsumer()

EventConsumer::~ EventConsumer ( )

Member Function Documentation

◆ bind()

int EventConsumer::bind	(	const char *	event_name,
		const char *	subclass_name = `""`
	)

Definition at line 67 of file switch_cpp.cpp.

References enodes, event_handler(), node_index, ready, SWITCH_CHANNEL_LOG, SWITCH_EVENT_ALL, switch_event_bind_removable(), SWITCH_EVENT_CUSTOM, SWITCH_LOG_DEBUG, SWITCH_LOG_ERROR, switch_log_printf(), SWITCH_LOG_WARNING, switch_name_event(), SWITCH_STATUS_SUCCESS, switch_str_nil, and zstr.

Referenced by EventConsumer().

 {
         switch_event_types_t event_id = SWITCH_EVENT_CUSTOM;
 
         if (!ready) {
                 return 0;
         }
 
         if (switch_name_event(event_name, &event_id) != SWITCH_STATUS_SUCCESS) {
                 switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Can't bind to %s, event not found\n", event_name);
                 return 0;
         }
 
         if (zstr(subclass_name)) {
                 subclass_name = NULL;
         }
 
         if (node_index <= SWITCH_EVENT_ALL &&
                 switch_event_bind_removable(__FILE__, event_id, subclass_name, event_handler, this, &enodes[node_index]) == SWITCH_STATUS_SUCCESS) {
                 switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "bound to %s %s\n", event_name, switch_str_nil(subclass_name));
                 node_index++;
                 return 1;
         }
 
         switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind to %s %s\n", event_name, switch_str_nil(subclass_name));
         return 0;
 }

◆ cleanup()

void EventConsumer::cleanup ( )

Definition at line 126 of file switch_cpp.cpp.

References enodes, events, node_index, pool, pop(), ready, switch_core_destroy_memory_pool, SWITCH_DECLARE_CONSTRUCTOR, switch_event_destroy(), switch_event_unbind(), switch_queue_interrupt_all(), switch_queue_trypop(), and SWITCH_STATUS_SUCCESS.

 {
 
         uint32_t i;
         void *pop;
 
         if (!ready) {
                 return;
         }
 
         ready = 0;
 
         for (i = 0; i < node_index; i++) {
                 switch_event_unbind(&enodes[i]);
         }
 
         node_index = 0;
 
         switch_queue_interrupt_all(events);
 
         while(switch_queue_trypop(events, &pop) == SWITCH_STATUS_SUCCESS) {
                 switch_event_t *event = (switch_event_t *) pop;
                 switch_event_destroy(&event);
         }
 
 
         switch_core_destroy_memory_pool(&pool);
 
 }

◆ pop()

Event * EventConsumer::pop	(	int	block = `0`,
		int	timeout = `0`
	)

Definition at line 96 of file switch_cpp.cpp.

References events, ready, switch_queue_pop(), switch_queue_pop_timeout(), and switch_queue_trypop().

Referenced by cleanup().

 {
         void *pop = NULL;
         Event *ret = NULL;
         switch_event_t *event;
         switch_status_t res;
 
         if (!ready) {
                 return NULL;
         }
 
         if (block) {
                 if (timeout > 0) {
                         res = switch_queue_pop_timeout(events, &pop, (switch_interval_time_t) timeout * 1000); // millisec rather than microsec
                 } else {
                         res = switch_queue_pop(events, &pop);
                 }
         } else {
                 res = switch_queue_trypop(events, &pop);
         }
 
         (void)res;
 
         if ((event = (switch_event_t *) pop)) {
                 ret = new Event(event, 1);
         }
 
         return ret;
 }

Field Documentation

◆ e_callback

char* EventConsumer::e_callback

Definition at line 190 of file switch_cpp.h.

◆ e_cb_arg

char* EventConsumer::e_cb_arg

Definition at line 192 of file switch_cpp.h.

◆ e_event_id

switch_event_types_t EventConsumer::e_event_id

Definition at line 189 of file switch_cpp.h.

◆ e_subclass_name

char* EventConsumer::e_subclass_name

Definition at line 191 of file switch_cpp.h.

◆ enodes

switch_event_node_t* EventConsumer::enodes[SWITCH_EVENT_ALL+1]

Definition at line 193 of file switch_cpp.h.

Referenced by bind(), and cleanup().

◆ events

switch_queue_t* EventConsumer::events

Definition at line 188 of file switch_cpp.h.

Referenced by cleanup(), event_handler(), EventConsumer(), and pop().

◆ node_index

uint32_t EventConsumer::node_index

Definition at line 194 of file switch_cpp.h.

Referenced by bind(), cleanup(), and EventConsumer().

◆ pool

switch_memory_pool_t* EventConsumer::pool

protected

Definition at line 185 of file switch_cpp.h.

Referenced by cleanup(), EventConsumer(), and IVRMenu::IVRMenu().

◆ ready

int EventConsumer::ready