Function cmdInterfaceThreadInit

src/stdinreader.cpp:1357–1434

}

void cmdInterfaceThreadInit()
{
	if (wz_command_interface() == WZ_Command_Interface::None)
	{
		return;
	}

#if defined(HAVE_SYS_EVENTFD_H)
	if (quitSignalEventFd == -1)
	{
		int flags = 0;
# if defined(EFD_CLOEXEC)
		flags = EFD_CLOEXEC;
# endif
		quitSignalEventFd = eventfd(0, flags);
	}
#elif defined(HAVE_UNISTD_H)
	if (quitSignalPipeFds[0] == -1 && quitSignalPipeFds[1] == -1)
	{
		int result = -1;
# if defined(HAVE_PIPE2) && defined(O_CLOEXEC)
		result = pipe2(quitSignalPipeFds, O_CLOEXEC);
# else
		result = pipe(quitSignalPipeFds);
# endif
		if (result == -1)
		{
			quitSignalPipeFds[0] = -1;
			quitSignalPipeFds[1] = -1;
		}
	}
#endif

	// initialize output queue (if used)
	if (wz_command_interface() != WZ_Command_Interface::StdIn_Interface)
	{
		cmdInterfaceOutputQueue = std::make_unique<moodycamel::BlockingReaderWriterQueue<CmdInterfaceMessageBuffer>>(1024);
		latestWriteBuffer.reserve(maxReserveMessageBufferSize);
	}

	switch (wz_command_interface())
	{
		case WZ_Command_Interface::StdIn_Interface:
			readFd = STDIN_FILENO;
			readFdIsSocket = false;
			writeFd = STDERR_FILENO;
			writeFdIsNonBlocking = false;
			break;
		case WZ_Command_Interface::Unix_Socket:
			// sets readFd, writeFd, etc as appropriate
			if (!cmdInterfaceCreateUnixSocket(wz_cmd_interface_param))
			{
				// failed (and logged a failure to stderr)
				return;
			}
			break;
		default:
			return;