Function stream_process

modules/event_stream/stream_send.c:712–735

void stream_process(int rank)
{
	/* suppress the E_CORE_LOG event for new logs while handling
	 * the event itself */
	suppress_proc_log_event();

	if (init_worker_reactor("event_stream Sender", RCT_PRIO_MAX) != 0) {
		LM_BUG("failed to init event_stream reactor");
		abort();
	}
	jsonrpc_init_reader();

	if (reactor_add_reader(stream_pipe[0], F_EV_JSONRPC_CMD, RCT_PRIO_ASYNC, NULL)<0){
		LM_CRIT("failed to add event_stream pipe to reactor\n");
		abort();
	}

	reactor_main_loop(STREAM_REACTOR_TIMEOUT, out_err, stream_cleanup_old());

out_err:
	destroy_io_wait(&_worker_io);
	reset_proc_log_event();
	abort();
}