Method run_output_thread

src/device/console_server.cpp:583–623

}

s32 ConsoleServer::run_output_thread()
{
	while (1) {
		_output_mutex.lock();
		while (array::size(*_output_write) == 0 && !_thread_exit)
			_output_condition.wait(_output_mutex);

		if (_thread_exit) {
			_output_mutex.unlock();
			break;
		}

		Buffer *temp = _output_read;
		_output_read = _output_write;
		_output_write = temp;
		_output_mutex.unlock();

		FileBuffer fb(*_output_read);
		BinaryReader br(fb);
		while (!fb.end_of_file()) {
			// Read client, message size and message.
			u32 client_id;
			u32 msg_len;
			br.read(client_id);
			br.read(msg_len);
			const char *msg = array::begin(*_output_read) + fb.position();
			br.skip(msg_len);

			// Lookup socket by its ID.
			TCPSocket socket;
			if (console_server_internal::get_socket_by_id(&socket, *this, client_id) != true)
				continue;

			socket.write(msg - 4, msg_len + 4);
		}

		array::clear(*_output_read);
	}

	return 0;
}

namespace console_server_globals
{