Method Init

src/engine/shared/fifo.cpp:14–80

#include <cstdlib>

void CFifo::Init(IConsole *pConsole, const char *pFifoFile, int Flag)
{
	m_File = -1;

	m_pConsole = pConsole;
	m_IsInit = true;
	if(pFifoFile[0] == '\0')
		return;

	str_copy(m_aFilename, pFifoFile);
	m_Flag = Flag;

	bool IsFifo;
	if(mkfifo(m_aFilename, 0600) == 0)
	{
		struct stat Attribute;
		if(stat(m_aFilename, &Attribute) == 0)
		{
			IsFifo = S_ISFIFO(Attribute.st_mode);
		}
		else
		{
			log_warn("fifo", "Failed to stat fifo '%s' (%d '%s')", m_aFilename, errno, strerror(errno));
			IsFifo = false;
		}
	}
	else
	{
		log_warn("fifo", "Failed to create fifo '%s' (%d '%s')", m_aFilename, errno, strerror(errno));
		IsFifo = false;
	}
	if(!IsFifo)
	{
		log_warn("fifo", "File '%s' is not a fifo, removing", m_aFilename);
		if(fs_remove(m_aFilename) != 0)
		{
			log_error("fifo", "Failed to remove non-fifo '%s'", m_aFilename); // details logged in fs_remove
			return;
		}
		if(mkfifo(m_aFilename, 0600) != 0)
		{
			log_error("fifo", "Failed to create fifo '%s' (%d '%s')", m_aFilename, errno, strerror(errno));
			return;
		}
		struct stat Attribute;
		if(stat(m_aFilename, &Attribute) != 0)
		{
			log_error("fifo", "Failed to stat fifo '%s' (%d '%s')", m_aFilename, errno, strerror(errno));
			return;
		}
		if(!S_ISFIFO(Attribute.st_mode))
		{
			log_error("fifo", "File '%s' is not a fifo", m_aFilename);
			return;
		}
	}

	m_File = open(m_aFilename, O_RDONLY | O_NONBLOCK);