Function handle_io

modules/event_stream/stream_send.c:659–686

}

static int handle_io(struct fd_map *fm, int idx, int event_type)
{
	stream_send_t *jsonrpcs;
	struct stream_con *con;

	switch (fm->type) {
		case F_EV_JSONRPC_CMD:
			jsonrpcs = stream_receive();
			if (!jsonrpcs) {
				LM_ERR("invalid receive jsonrpc command\n");
				return -1;
			}

			handle_new_stream(jsonrpcs);
			break;
		case F_EV_JSONRPC_RPL:
			con = (struct stream_con *)fm->data;
			if (event_type == IO_WATCH_READ)
				handle_reply_jsonrpc(con);
			else
				handle_write_jsonrpc(con);
			break;
		default:
			LM_CRIT("unknown fd type %d in JSON-RPC handler\n", fm->type);
			return 0;
	}
	return 0;
}

static void stream_cleanup_old(void)
{