66 static switch_status_t api_get_node_option(ei_node_t *ei_node, switch_stream_handle_t *stream, char…  in api_get_node_option()  argument
71 		stream->write_function(stream, "+OK %i", ei_node->event_stream_framing);  in api_get_node_option()
75 		stream->write_function(stream, "+OK %i", ei_node->event_stream_keepalive);  in api_get_node_option()
79 		stream->write_function(stream, "+OK %s", ei_node->legacy ? "true" : "false");  in api_get_node_option()
91 static switch_status_t api_set_node_option(ei_node_t *ei_node, switch_stream_handle_t *stream, char…  in api_set_node_option()  argument
103 			ei_node->event_stream_framing = val;  in api_set_node_option()
110 		ei_node->event_stream_keepalive = val;  in api_set_node_option()
114 		ei_node->legacy = switch_true(value);  in api_set_node_option()
115 		stream->write_function(stream, "+OK %s", ei_node->legacy ? "true" : "false");  in api_set_node_option()
132 	ei_node_t *ei_node;  in api_erlang_status()  local
148 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_status()
149 	if (!ei_node) {  in api_erlang_status()
153 		while(ei_node != NULL) {  in api_erlang_status()
156 			delta = (switch_micro_time_now() - ei_node->created_time) / 1000000;  in api_erlang_status()
163 …		   ,ei_node->peer_nodename, ei_node->remote_ip, ei_node->remote_port, year, day, hour, min, sec);  in api_erlang_status()
164 			ei_node = ei_node->next;  in api_erlang_status()
205 	ei_node_t *ei_node;  in api_erlang_nodes_list()  local
208 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_nodes_list()
209 	while(ei_node != NULL) {  in api_erlang_nodes_list()
210 		stream->write_function(stream, "%s (%s)\n", ei_node->peer_nodename, ei_node->remote_ip);  in api_erlang_nodes_list()
211 		ei_node = ei_node->next;  in api_erlang_nodes_list()
219 	ei_node_t *ei_node;  in api_erlang_nodes_count()  local
223 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_nodes_count()
224 	while(ei_node != NULL) {  in api_erlang_nodes_count()
226 		ei_node = ei_node->next;  in api_erlang_nodes_count()
238 	ei_node_t *ei_node;  in api_complete_erlang_node()  local
241 	ei_node = kazoo_globals.ei_nodes;  in api_complete_erlang_node()
242 	while(ei_node != NULL) {  in api_complete_erlang_node()
243 		switch_console_push_match(&my_matches, ei_node->peer_nodename);  in api_complete_erlang_node()
244 		ei_node = ei_node->next;  in api_complete_erlang_node()
319 static switch_status_t handle_node_api_event_streams(ei_node_t *ei_node, switch_stream_handle_t *st…  in handle_node_api_event_streams()  argument
322 	switch_mutex_lock(ei_node->event_streams_mutex);  in handle_node_api_event_streams()
323 	event_stream = ei_node->event_streams;  in handle_node_api_event_streams()
328 	switch_mutex_unlock(ei_node->event_streams_mutex);  in handle_node_api_event_streams()
333 static switch_status_t handle_node_api_command(ei_node_t *ei_node, switch_stream_handle_t *stream, …  in handle_node_api_command()  argument
338 …stream->write_function(stream, "Disconnecting erlang node %s at managers request\n", ei_node->peer…  in handle_node_api_command()
339 		switch_clear_flag(ei_node, LFLAG_RUNNING);  in handle_node_api_command()
342 		delta = (switch_micro_time_now() - ei_node->created_time) / 1000000;  in handle_node_api_command()
350 …stream->write_function(stream, "Local Address    %s:%d\n", ei_node->local_ip, ei_node->local_port);  in handle_node_api_command()
351 …stream->write_function(stream, "Remote Address   %s:%d\n", ei_node->remote_ip, ei_node->remote_por…  in handle_node_api_command()
354 		handle_node_api_event_streams(ei_node, stream);  in handle_node_api_command()
357 		handle_api_command_streams(ei_node, stream);  in handle_node_api_command()
367 	ei_node_t *ei_node;  in api_erlang_node_command()  local
370 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_node_command()
371 	while(ei_node != NULL) {  in api_erlang_node_command()
372 		int length = strlen(ei_node->peer_nodename);  in api_erlang_node_command()
374 		if (!strncmp(ei_node->peer_nodename, nodename, length)) {  in api_erlang_node_command()
375 			handle_node_api_command(ei_node, stream, command);  in api_erlang_node_command()
380 		ei_node = ei_node->next;  in api_erlang_node_command()
387 static switch_status_t handle_node_api_command_arg(ei_node_t *ei_node, switch_stream_handle_t *stre…  in handle_node_api_command_arg()  argument
391 		return api_get_node_option(ei_node, stream, arg);  in handle_node_api_command_arg()
400 static switch_status_t handle_node_api_command_args(ei_node_t *ei_node, switch_stream_handle_t *str…  in handle_node_api_command_args()  argument
404 		return api_set_node_option(ei_node, stream, argv[0], argv[1]);  in handle_node_api_command_args()
414 	ei_node_t *ei_node;  in api_erlang_node_command_arg()  local
418 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_node_command_arg()
419 	while(ei_node != NULL) {  in api_erlang_node_command_arg()
420 		int length = strlen(ei_node->peer_nodename);  in api_erlang_node_command_arg()
422 		if (!strncmp(ei_node->peer_nodename, nodename, length)) {  in api_erlang_node_command_arg()
423 			ret = handle_node_api_command_arg(ei_node, stream, command, arg);  in api_erlang_node_command_arg()
428 		ei_node = ei_node->next;  in api_erlang_node_command_arg()
436 	ei_node_t *ei_node;  in api_erlang_node_command_args()  local
440 	ei_node = kazoo_globals.ei_nodes;  in api_erlang_node_command_args()
441 	while(ei_node != NULL) {  in api_erlang_node_command_args()
442 		int length = strlen(ei_node->peer_nodename);  in api_erlang_node_command_args()
444 		if (!strncmp(ei_node->peer_nodename, nodename, length)) {  in api_erlang_node_command_args()
445 			ret = handle_node_api_command_args(ei_node, stream, command, argc, argv);  in api_erlang_node_command_args()
450 		ei_node = ei_node->next;  in api_erlang_node_command_args()