自学教程：C++ switch_event_fire函数代码示例

SWITCH_DECLARE(switch_status_t) switch_nat_add_mapping_internal(switch_port_t port, switch_nat_ip_proto_t proto, switch_port_t * external_port,																switch_bool_t sticky, switch_bool_t publish){	switch_status_t status = SWITCH_STATUS_FALSE;	switch_event_t *event = NULL;	switch (nat_globals.nat_type) {	case SWITCH_NAT_TYPE_PMP:		status = switch_nat_add_mapping_pmp(port, proto, external_port);		break;	case SWITCH_NAT_TYPE_UPNP:		if ((status = switch_nat_add_mapping_upnp(port, proto)) == SWITCH_STATUS_SUCCESS) {			if (external_port) {				*external_port = port;			}		}		break;	default:		break;	}	if (publish && status == SWITCH_STATUS_SUCCESS) {		switch_event_create(&event, SWITCH_EVENT_NAT);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "op", "add");		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "port", "%d", port);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "proto", "%d", proto);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sticky", (sticky ? "true" : "false"));		switch_event_fire(&event);	}	return status;}

static void do_rotate(cdr_fd_t *fd){	switch_time_exp_t tm;	char date[80] = "";	switch_size_t retsize;	char *p;	close(fd->fd);	fd->fd = -1;	if (globals.rotate) {		switch_time_exp_lt(&tm, switch_micro_time_now());		switch_strftime_nocheck(date, &retsize, sizeof(date), "%Y-%m-%d-%H-%M-%S", &tm);		p = switch_mprintf("%s.%s", fd->path, date);		assert(p);		switch_file_rename(fd->path, p, globals.pool);		free(p);	}	do_reopen(fd);	if (fd->fd < 0) {		switch_event_t *event;		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Error opening %s/n", fd->path);		if (switch_event_create(&event, SWITCH_EVENT_TRAP) == SWITCH_STATUS_SUCCESS) {			switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Critical-Error", "Error opening cdr file %s/n", fd->path);			switch_event_fire(&event);		}	} else {		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "%s CDR logfile %s/n", globals.rotate ? "Rotated" : "Re-opened", fd->path);	}}

void conference_loop_energy_dn(conference_member_t *member, caller_control_action_t *action){	char msg[512], str[30] = "", *p;	switch_event_t *event;	if (member == NULL)		return;	member->energy_level -= 200;	if (member->energy_level < 0) {		member->energy_level = 0;	}	if (test_eflag(member->conference, EFLAG_ENERGY_LEVEL) &&		switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {		conference_member_add_event_data(member, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "energy-level");		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "New-Level", "%d", member->energy_level);		switch_event_fire(&event);	}	//switch_snprintf(msg, sizeof(msg), "Energy level %d", member->energy_level);	//conference_member_say(member, msg, 0);	switch_snprintf(str, sizeof(str), "%d", abs(member->energy_level) / 200);	for (p = str; p && *p; p++) {		switch_snprintf(msg, sizeof(msg), "digits/%c.wav", *p);		conference_member_play_file(member, msg, 0, SWITCH_TRUE);	}}

SWITCH_DECLARE(bool) Event::fire(void){	this_check(false);	if (!mine) {		switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Not My event!/n");		return false;	}	if (event) {		switch_event_t *new_event;		if (switch_event_dup(&new_event, event) == SWITCH_STATUS_SUCCESS) {			if (switch_event_fire(&new_event) != SWITCH_STATUS_SUCCESS) {				switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Failed to fire the event!/n");				switch_event_destroy(&new_event);				return false;			}			return true;		} else {			switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Failed to dup the event!/n");		}	} else {		switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Trying to fire an event that does not exist!/n");	}	return false;}

void conference_loop_volume_listen_dn(conference_member_t *member, caller_control_action_t *action){	char msg[512];	switch_event_t *event;	if (member == NULL)		return;	member->volume_in_level--;	switch_normalize_volume(member->volume_in_level);	if (test_eflag(member->conference, EFLAG_GAIN_LEVEL) &&		switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {		conference_member_add_event_data(member, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "gain-level");		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "New-Level", "%d", member->volume_in_level);		switch_event_fire(&event);	}	//switch_snprintf(msg, sizeof(msg), "Gain level %d", member->volume_in_level);	//conference_member_say(member, msg, 0);	if (member->volume_in_level < 0) {		switch_snprintf(msg, sizeof(msg), "currency/negative.wav", member->volume_in_level);		conference_member_play_file(member, msg, 0, SWITCH_TRUE);	}	switch_snprintf(msg, sizeof(msg), "digits/%d.wav", abs(member->volume_in_level));	conference_member_play_file(member, msg, 0, SWITCH_TRUE);}

bool WSClientParser::ws_disconnect() {	switch_status_t status = SWITCH_STATUS_FALSE;	switch_event_t *event;	if ( (status = switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, WS_EVENT_MAINT)) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "User", mpUser);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Domain", mpDomain);		status = switch_event_fire(&event);	}	if( status != SWITCH_STATUS_SUCCESS ) {		switch_log_printf(				SWITCH_CHANNEL_UUID_LOG(this->uuid),				SWITCH_LOG_ERROR,				"WSClientParser::ws_disconnect( "				"[Send event Fail], "				"this : %p, "				"user : '%s', "				"domain : '%s' "				") /n",				this,				mpUser,				mpDomain				);	}	return status == SWITCH_STATUS_SUCCESS;}

SWITCH_DECLARE(switch_status_t) switch_core_session_set_video_write_codec(switch_core_session_t *session, switch_codec_t *codec){	switch_event_t *event;	switch_channel_t *channel = switch_core_session_get_channel(session);	char tmp[30];	switch_status_t status = SWITCH_STATUS_SUCCESS;	if (!codec || !codec->implementation || !switch_core_codec_ready(codec)) {		if (session->video_write_codec) {			session->video_write_codec = NULL;			status = SWITCH_STATUS_SUCCESS;			goto end;		}		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "Cannot set NULL codec!/n");		status = SWITCH_STATUS_FALSE;		goto end;	}	if (switch_event_create(&event, SWITCH_EVENT_CODEC) == SWITCH_STATUS_SUCCESS) {		switch_channel_event_set_data(session->channel, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "channel-video-write-codec-name", codec->implementation->iananame);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "channel-video-write-codec-rate", "%d", codec->implementation->actual_samples_per_second);		switch_event_fire(&event);	}	switch_channel_set_variable(channel, "video_write_codec", codec->implementation->iananame);	switch_snprintf(tmp, sizeof(tmp), "%d", codec->implementation->actual_samples_per_second);	switch_channel_set_variable(channel, "video_write_rate", tmp);	session->video_write_codec = codec;	session->video_write_impl = *codec->implementation;  end:	return status;}

static void *torture_thread(switch_thread_t *thread, void *obj){	int y = 0;	int z = 0;	switch_core_thread_session_t *ts = obj;	switch_event_t *event;	z = THREADS++;	while (THREADS > 0) {		int x;		for (x = 0; x < 1; x++) {			if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, MY_EVENT_COOL) == SWITCH_STATUS_SUCCESS) {				switch_event_add_header(event, "event_info", "hello world %d %d", z, y++);				switch_event_fire(&event);			}		}		switch_yield(100000);	}	if (ts->pool) {		switch_memory_pool_t *pool = ts->pool;		switch_core_destroy_memory_pool(&pool);	}	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Thread Ended/n");}

static void send_report(switch_event_t *event, const char * Status) {	switch_event_t *report = NULL;	switch_event_header_t *header;	if (switch_event_create_subclass(&report, SWITCH_EVENT_CUSTOM, MY_EVENT_DELIVERY_REPORT) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header_string(report, SWITCH_STACK_BOTTOM, "Status", Status);		for (header = event->headers; header; header = header->next) {			if (!strcmp(header->name, "Event-Subclass")) {				continue;			}			if (!strcmp(header->name, "Event-Name")) {				continue;			}	        if (header->idx) {	            int i;	            for (i = 0; i < header->idx; i++) {	                switch_event_add_header_string(report, SWITCH_STACK_PUSH, header->name, header->array[i]);	            }	        } else {	            switch_event_add_header_string(report, SWITCH_STACK_BOTTOM, header->name, header->value);	        }		}		switch_event_fire(&report);	}}

void conference_loop_exec_app(conference_member_t *member, caller_control_action_t *action){	char *app = NULL;	char *arg = "";	char *argv[2] = { 0 };	int argc;	char *mydata = NULL;	switch_event_t *event = NULL;	switch_channel_t *channel = NULL;	if (!action->expanded_data) return;	if (test_eflag(member->conference, EFLAG_DTMF) && switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {		conference_member_add_event_data(member, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "execute_app");		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Application", action->expanded_data);		switch_event_fire(&event);	}	mydata = strdup(action->expanded_data);	switch_assert(mydata);	if ((argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))))) {		if (argc > 0) {			app = argv[0];		}		if (argc > 1) {			arg = argv[1];		}	} else {		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_ERROR, "Empty execute app string [%s]/n",						  (char *) action->expanded_data);		goto done;	}	if (!app) {		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_ERROR, "Unable to find application./n");		goto done;	}	switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_INFO, "Execute app: %s, %s/n", app, arg);	channel = switch_core_session_get_channel(member->session);	switch_channel_set_app_flag(channel, CF_APP_TAGGED);	switch_core_session_set_read_codec(member->session, NULL);	switch_core_session_execute_application(member->session, app, arg);	switch_core_session_set_read_codec(member->session, &member->read_codec);	switch_channel_clear_app_flag(channel, CF_APP_TAGGED); done:	switch_safe_free(mydata);	return;}

/** * Process a buffer of audio data for call progress tones * * @param bug the session's media bug  * @param user_data the detector * @param type the type of data available from the bug * @return SWITCH_TRUE */static switch_bool_t callprogress_detector_process_buffer(switch_media_bug_t *bug, void *user_data, switch_abc_type_t type){	uint8_t data[SWITCH_RECOMMENDED_BUFFER_SIZE];	switch_frame_t frame = { 0 };	tone_detector_t *detector = (tone_detector_t *)user_data;	switch_core_session_t *session = switch_core_media_bug_get_session(bug);	switch_channel_t *channel = switch_core_session_get_channel(session);	frame.data = data;	frame.buflen = SWITCH_RECOMMENDED_BUFFER_SIZE;	switch(type) {	case SWITCH_ABC_TYPE_INIT:		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "(%s) initializing tone detector/n", switch_channel_get_name(channel));		tone_detector_init(detector);		break;	case SWITCH_ABC_TYPE_READ:	{		const char *detected_tone = NULL;		if (!detector->spandsp_detector) {			switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "(%s) detector is destroyed/n", switch_channel_get_name(channel));			return SWITCH_FALSE;		}		if (switch_core_media_bug_read(bug, &frame, SWITCH_TRUE) != SWITCH_STATUS_SUCCESS) {			switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "(%s) error reading frame/n", switch_channel_get_name(channel));			return SWITCH_FALSE;		}		tone_detector_process_buffer(detector, frame.data, frame.samples, &detected_tone);		if (detected_tone) {			switch_event_t *event = NULL;			switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "(%s) DETECTED TONE: %s/n", switch_channel_get_name(channel), detected_tone);			if (switch_event_create(&event, SWITCH_EVENT_DETECTED_TONE) == SWITCH_STATUS_SUCCESS) {				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Detected-Tone", detected_tone);				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Unique-ID", switch_core_session_get_uuid(session));				switch_event_fire(&event);			}		}		break;	}	case SWITCH_ABC_TYPE_WRITE:		break;	case SWITCH_ABC_TYPE_WRITE_REPLACE:		break;	case SWITCH_ABC_TYPE_READ_REPLACE:		break;	case SWITCH_ABC_TYPE_READ_PING:		break;	case SWITCH_ABC_TYPE_CLOSE:		if (detector->spandsp_detector) {			switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "(%s) destroying tone detector/n", switch_channel_get_name(channel));			tone_detector_destroy(detector);		}		break;	}	return SWITCH_TRUE;}

static switch_status_t skinny_api_cmd_profile_device_send_data(const char *profile_name, const char *device_name, const char *message_type, char *params, const char *body, switch_stream_handle_t *stream){	skinny_profile_t *profile;	if ((profile = skinny_find_profile(profile_name))) {		listener_t *listener = NULL;		skinny_profile_find_listener_by_device_name(profile, device_name, &listener);		if(listener) {			switch_event_t *event = NULL;			char *argv[64] = { 0 };			int argc = 0;			int x = 0;			/* skinny::user_to_device event */			skinny_device_event(listener, &event, SWITCH_EVENT_CUSTOM, SKINNY_EVENT_USER_TO_DEVICE);			switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Message-Id-String", "%s", message_type);			argc = switch_separate_string(params, ';', argv, (sizeof(argv) / sizeof(argv[0])));			for (x = 0; x < argc; x++) {				char *var_name, *var_value = NULL;				var_name = argv[x];				if (var_name && (var_value = strchr(var_name, '='))) {					*var_value++ = '/0';				}				if (zstr(var_name)) {					stream->write_function(stream, "-ERR No variable specified/n");				} else {					char *tmp = switch_mprintf("Skinny-UserToDevice-%s", var_name);					switch_event_add_header(event, SWITCH_STACK_BOTTOM, tmp, "%s", var_value);					switch_safe_free(tmp);					/*					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Application-Id", "%d", request->data.extended_data.application_id);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Line-Instance", "%d", request->data.extended_data.line_instance);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Call-Id", "%d", request->data.extended_data.call_id);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Transaction-Id", "%d", request->data.extended_data.transaction_id);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Data-Length", "%d", request->data.extended_data.data_length);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Sequence-Flag", "%d", request->data.extended_data.sequence_flag);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Display-Priority", "%d", request->data.extended_data.display_priority);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Conference-Id", "%d", request->data.extended_data.conference_id);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-App-Instance-Id", "%d", request->data.extended_data.app_instance_id);					   switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Skinny-UserToDevice-Routing-Id", "%d", request->data.extended_data.routing_id);					 */				}			}			switch_event_add_body(event, "%s", body);			switch_event_fire(&event);			stream->write_function(stream, "+OK/n");		} else {			stream->write_function(stream, "Listener not found!/n");		}	} else {		stream->write_function(stream, "Profile not found!/n");	}	return SWITCH_STATUS_SUCCESS;}

void conference_loop_event(conference_member_t *member, caller_control_action_t *action){	switch_event_t *event;	if (test_eflag(member->conference, EFLAG_DTMF) && switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {		conference_member_add_event_data(member, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "dtmf");		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "DTMF-Key", action->binded_dtmf);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Data", action->expanded_data);		switch_event_fire(&event);	}}

void stop_all_websockets(){	switch_event_t *event;	if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, "websocket::stophook") != SWITCH_STATUS_SUCCESS) {		switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Failed to create event!/n");	}	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "stop", "now");	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "stopping all websockets .../n");	if (switch_event_fire(&event) != SWITCH_STATUS_SUCCESS) {		switch_log_printf(SWITCH_CHANNEL_LOG,SWITCH_LOG_ERROR, "Failed to fire the event!/n");		switch_event_destroy(&event);	}}

SWITCH_DECLARE(uint32_t) switch_scheduler_add_task(time_t task_runtime,												   switch_scheduler_func_t func,												   const char *desc, const char *group, uint32_t cmd_id, void *cmd_arg, switch_scheduler_flag_t flags){	switch_scheduler_task_container_t *container, *tp;	switch_event_t *event;	switch_time_t now = switch_epoch_time_now(NULL);	switch_mutex_lock(globals.task_mutex);	switch_zmalloc(container, sizeof(*container));	switch_assert(func);	if (task_runtime < now) {		container->task.repeat = (uint32_t)task_runtime;		task_runtime += now;	}	container->func = func;	container->task.created = switch_epoch_time_now(NULL);	container->task.runtime = task_runtime;	container->task.group = strdup(group ? group : "none");	container->task.cmd_id = cmd_id;	container->task.cmd_arg = cmd_arg;	container->flags = flags;	container->desc = strdup(desc ? desc : "none");	for (tp = globals.task_list; tp && tp->next; tp = tp->next);	if (tp) {		tp->next = container;	} else {		globals.task_list = container;	}	for (container->task.task_id = 0; !container->task.task_id; container->task.task_id = ++globals.task_id);	switch_mutex_unlock(globals.task_mutex);	tp = container;	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Added task %u %s (%s) to run at %" SWITCH_INT64_T_FMT "/n",					  tp->task.task_id, tp->desc, switch_str_nil(tp->task.group), tp->task.runtime);	if (switch_event_create(&event, SWITCH_EVENT_ADD_SCHEDULE) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Task-ID", "%u", tp->task.task_id);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Task-Desc", tp->desc);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Task-Group", switch_str_nil(tp->task.group));		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Task-Runtime", "%" SWITCH_INT64_T_FMT, tp->task.runtime);		switch_event_fire(&event);	}	return container->task.task_id;}

cc_status_t cc_agent_get(const char *key, const char *agent, char *ret_result, size_t ret_result_size){	cc_status_t result = CC_STATUS_SUCCESS;	char *sql;	switch_event_t *event;	char res[256];	/* Check to see if agent already exists */	sql = switch_mprintf("SELECT count(*) FROM agents WHERE name = '%q'", agent);	cc_execute_sql2str(NULL, NULL, sql, res, sizeof(res));	switch_safe_free(sql);	if (atoi(res) == 0) {		result = CC_STATUS_AGENT_NOT_FOUND;		goto done;	}	if (!strcasecmp(key, "status") || !strcasecmp(key, "state") || !strcasecmp(key, "uuid") ) { 		/* Check to see if agent already exists */		sql = switch_mprintf("SELECT %q FROM agents WHERE name = '%q'", key, agent);		cc_execute_sql2str(NULL, NULL, sql, res, sizeof(res));		switch_safe_free(sql);		switch_snprintf(ret_result, ret_result_size, "%s", res);		result = CC_STATUS_SUCCESS;		if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CALLCENTER_EVENT) == SWITCH_STATUS_SUCCESS) {			char tmpname[256];			if (!strcasecmp(key, "uuid")) {				switch_snprintf(tmpname, sizeof(tmpname), "CC-Agent-UUID");				} else {				switch_snprintf(tmpname, sizeof(tmpname), "CC-Agent-%c%s", (char) switch_toupper(key[0]), key+1);			}			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "CC-Agent", agent);			switch_event_add_header(event, SWITCH_STACK_BOTTOM, "CC-Action", "agent-%s-get", key);			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, tmpname, res);			switch_event_fire(&event);		}	} else {		result = CC_STATUS_INVALID_KEY;		goto done;	}done:   	if (result == CC_STATUS_SUCCESS) {		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Get Info Agent %s %s = %s/n", agent, key, res);	}	return result;}

/* * chiedo alla patch tutte le chiamate. Probabilmente ritorna una una insert con tutte le chiamate da inserire. * usata all'avvio di un nuovo nodo che deve ricostrurie lo stato delle chiamate in corso alla sua accensione. */void utils_send_request_all(char *profile_name){    switch_event_t *event = NULL;    if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, "sofia::recovery_recv") == SWITCH_STATUS_SUCCESS) {        switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "profile_name", profile_name);        switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "request_all","true");        switch_event_fire(&event);        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "request_all sent to sofia/n");    } else {        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "request_all not sent to sofia/n");    }}

SWITCH_DECLARE(void) switch_console_printf(switch_text_channel_t channel, const char *file, const char *func, int line, const char *fmt, ...){	char *data = NULL;	int ret = 0;	va_list ap;	FILE *handle = switch_core_data_channel(channel);	const char *filep = switch_cut_path(file);	char date[80] = "";	switch_size_t retsize;	switch_time_exp_t tm;	switch_event_t *event;	va_start(ap, fmt);	ret = switch_vasprintf(&data, fmt, ap);	va_end(ap);	if (ret == -1) {		fprintf(stderr, "Memory Error/n");		goto done;	}	if (channel == SWITCH_CHANNEL_ID_LOG_CLEAN) {		fprintf(handle, "%s", data);		goto done;	}	switch_time_exp_lt(&tm, switch_micro_time_now());	switch_strftime_nocheck(date, &retsize, sizeof(date), "%Y-%m-%d %T", &tm);	if (channel == SWITCH_CHANNEL_ID_LOG) {		fprintf(handle, "[%d] %s %s:%d %s() %s", (int) getpid(), date, filep, line, func, data);		goto done;	}	if (channel == SWITCH_CHANNEL_ID_EVENT &&		switch_event_running() == SWITCH_STATUS_SUCCESS && switch_event_create(&event, SWITCH_EVENT_LOG) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Log-Data", data);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Log-File", filep);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Log-Function", func);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Log-Line", "%d", line);		switch_event_fire(&event);	}  done:	if (data) {		free(data);	}	fflush(handle);}

static void ctdm_report_alarms(ftdm_channel_t *channel){	switch_event_t *event = NULL;	ftdm_alarm_flag_t alarmflag = 0;	if (switch_event_create(&event, SWITCH_EVENT_TRAP) != SWITCH_STATUS_SUCCESS) {		ftdm_log(FTDM_LOG_ERROR, "failed to create alarms events/n");		return;	}		if (ftdm_channel_get_alarms(channel, &alarmflag) != FTDM_SUCCESS) {		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to retrieve alarms %s:%d/n", ftdm_channel_get_span_name(channel), ftdm_channel_get_id(channel));		return;	}	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "span-name", "%s", ftdm_channel_get_span_name(channel));	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "span-number", "%d", ftdm_channel_get_span_id(channel));	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "chan-number", "%d", ftdm_channel_get_id(channel));		if (alarmflag) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "condition", "ftdm-alarm-trap");	} else {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "condition", "ftdm-alarm-clear");	}	if (alarmflag & FTDM_ALARM_RED) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "red");	}	if (alarmflag & FTDM_ALARM_YELLOW) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "yellow");	}	if (alarmflag & FTDM_ALARM_RAI) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "rai");	}	if (alarmflag & FTDM_ALARM_BLUE) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "blue");	}	if (alarmflag & FTDM_ALARM_AIS) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "ais");	}	if (alarmflag & FTDM_ALARM_GENERAL) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm", "general");	}	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Reporting [%s] alarms for %s:%d/n", 			(alarmflag?"ftdm-alarm-trap":"ftdm-alarm-clear"), ftdm_channel_get_span_name(channel), ftdm_channel_get_id(channel));	switch_event_fire(&event);	return;}

void conference_loop_lock_toggle(conference_member_t *member, caller_control_action_t *action){	switch_event_t *event;	if (member == NULL)		return;	if (conference_utils_test_flag(member->conference, CFLAG_WAIT_MOD) && !conference_utils_member_test_flag(member, MFLAG_MOD) )		return;	if (!conference_utils_test_flag(member->conference, CFLAG_LOCKED)) {		if (member->conference->is_locked_sound) {			conference_file_play(member->conference, member->conference->is_locked_sound, CONF_DEFAULT_LEADIN, NULL, 0);		}		conference_utils_set_flag_locked(member->conference, CFLAG_LOCKED);		if (test_eflag(member->conference, EFLAG_LOCK) &&			switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {			conference_event_add_data(member->conference, event);			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "lock");			switch_event_fire(&event);		}	} else {		if (member->conference->is_unlocked_sound) {			conference_file_play(member->conference, member->conference->is_unlocked_sound, CONF_DEFAULT_LEADIN, NULL, 0);		}		conference_utils_clear_flag_locked(member->conference, CFLAG_LOCKED);		if (test_eflag(member->conference, EFLAG_UNLOCK) &&			switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {			conference_event_add_data(member->conference, event);			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "unlock");			switch_event_fire(&event);		}	}}

void BoardE1::onLinkStatus(K3L_EVENT *e){    DBG(FUNC, D("Link %02hu on board %02hu changed") % e->AddInfo % e->DeviceId);    /* Fire a custom event about this */    switch_event_t * event;    if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, KHOMP_EVENT_MAINT) == SWITCH_STATUS_SUCCESS)    {        //khomp_add_event_board_data(e->AddInfo, event);        Board::khomp_add_event_board_data(K3LAPI::target(Globals::k3lapi, K3LAPI::target::LINK, e->DeviceId, e->AddInfo), event);        switch_event_add_header(event, SWITCH_STACK_BOTTOM, "EV_LINK_STATUS", "%d", e->AddInfo);        switch_event_fire(&event);    }}

SWITCH_DECLARE(void) switch_limit_fire_event(const char *backend, const char *realm, const char *key, uint32_t usage, uint32_t rate, uint32_t max, uint32_t ratemax){	switch_event_t *event;	if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, LIMIT_EVENT_USAGE) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "backend", backend);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "realm", realm);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "key", key);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "usage", "%d", usage);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "rate", "%d", rate);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "max", "%d", max);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "ratemax", "%d", ratemax);		switch_event_fire(&event);	}}

void conference_loop_transfer(conference_member_t *member, caller_control_action_t *action){	char *exten = NULL;	char *dialplan = "XML";	char *context = "default";	char *argv[3] = { 0 };	int argc;	char *mydata = NULL;	switch_event_t *event;	if (test_eflag(member->conference, EFLAG_DTMF) && switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, CONF_EVENT_MAINT) == SWITCH_STATUS_SUCCESS) {		conference_member_add_event_data(member, event);		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action", "transfer");		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Dialplan", action->expanded_data);		switch_event_fire(&event);	}	conference_utils_member_clear_flag_locked(member, MFLAG_RUNNING);	if ((mydata = switch_core_session_strdup(member->session, action->expanded_data))) {		if ((argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))))) {			if (argc > 0) {				exten = argv[0];			}			if (argc > 1) {				dialplan = argv[1];			}			if (argc > 2) {				context = argv[2];			}		} else {			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_ERROR, "Empty transfer string [%s]/n", (char *) action->expanded_data);			goto done;		}	} else {		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_ERROR, "Unable to allocate memory to duplicate transfer data./n");		goto done;	}	switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(member->session), SWITCH_LOG_INFO, "Transfering to: %s, %s, %s/n", exten, dialplan, context);	switch_ivr_session_transfer(member->session, exten, dialplan, context); done:	return;}

/** * Process a buffer of audio data for call progress tones * * @param bug the session's media bug  * @param user_data the detector * @param type the type of data available from the bug * @return SWITCH_TRUE */static switch_bool_t callprogress_detector_process_buffer(switch_media_bug_t *bug, void *user_data, switch_abc_type_t type){	tone_detector_t *detector = (tone_detector_t *)user_data;	switch_core_session_t *session = detector->session;	switch(type) {	case SWITCH_ABC_TYPE_INIT:		switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_INFO, "initializing tone detector/n");		tone_detector_init(detector);		break;	case SWITCH_ABC_TYPE_READ_REPLACE:	{		switch_frame_t *frame;		const char *detected_tone = NULL;		if (!detector->spandsp_detector) {			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_INFO, "detector is destroyed/n");			return SWITCH_FALSE;		}		if (!(frame = switch_core_media_bug_get_read_replace_frame(bug))) {			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_INFO, "error reading frame/n");			return SWITCH_FALSE;		}		tone_detector_process_buffer(detector, frame->data, frame->samples, &detected_tone);		if (detected_tone) {			switch_event_t *event = NULL;			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_INFO, "DETECTED TONE: %s/n", detected_tone);			if (switch_event_create(&event, SWITCH_EVENT_DETECTED_TONE) == SWITCH_STATUS_SUCCESS) {				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Detected-Tone", detected_tone);				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Unique-ID", switch_core_session_get_uuid(session));				switch_event_fire(&event);			}		}		break;	}	case SWITCH_ABC_TYPE_CLOSE:		if (detector->spandsp_detector) {			switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_INFO, "destroying tone detector/n");			tone_detector_destroy(detector);		}		break;	default:		break;	}	return SWITCH_TRUE;}

static void switch_core_media_bug_destroy(switch_media_bug_t *bug){	switch_event_t *event = NULL;	if (bug->raw_read_buffer) {		switch_buffer_destroy(&bug->raw_read_buffer);	}	if (bug->raw_write_buffer) {		switch_buffer_destroy(&bug->raw_write_buffer);	}	if (switch_event_create(&event, SWITCH_EVENT_MEDIA_BUG_STOP) == SWITCH_STATUS_SUCCESS) {		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Media-Bug-Function", "%s", bug->function);		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Media-Bug-Target", "%s", bug->target);		if (bug->session) switch_channel_event_set_data(bug->session->channel, event);		switch_event_fire(&event);	}}