anope/modules/socketengines/m_socketengine_select.cpp

#include "module.h"

class SocketEngineSelect : public SocketEngineBase
{
 private:
 	/* Max Read FD */
	int MaxFD;
	/* Read FDs */
	fd_set ReadFDs;
	/* Write FDs */
	fd_set WriteFDs;

 public:
	SocketEngineSelect()
	{
		MaxFD = 0;
		FD_ZERO(&ReadFDs);
		FD_ZERO(&WriteFDs);
	}

	~SocketEngineSelect()
	{
		FD_ZERO(&ReadFDs);
		FD_ZERO(&WriteFDs);
	}

	void AddSocket(Socket *s)
	{
		if (s->GetFD() > MaxFD)
			MaxFD = s->GetFD();
		FD_SET(s->GetFD(), &ReadFDs);
		Sockets.insert(std::make_pair(s->GetFD(), s));
	}

	void DelSocket(Socket *s)
	{
		if (s->GetFD() == MaxFD)
			--MaxFD;
		FD_CLR(s->GetFD(), &ReadFDs);
		FD_CLR(s->GetFD(), &WriteFDs);
		Sockets.erase(s->GetFD());
	}

	void MarkWritable(Socket *s)
	{
		if (s->HasFlag(SF_WRITABLE))
			return;
		FD_SET(s->GetFD(), &WriteFDs);
		s->SetFlag(SF_WRITABLE);
	}

	void ClearWritable(Socket *s)
	{
		if (!s->HasFlag(SF_WRITABLE))
			return;
		FD_CLR(s->GetFD(), &WriteFDs);
		s->UnsetFlag(SF_WRITABLE);
	}

	void Process()
	{
		fd_set rfdset = ReadFDs, wfdset = WriteFDs, efdset = ReadFDs;
		timeval tval;
		tval.tv_sec = Config->ReadTimeout;
		tval.tv_usec = 0;

		int sresult = select(MaxFD + 1, &rfdset, &wfdset, &efdset, &tval);
		Anope::CurTime = time(NULL);

		if (sresult == -1)
		{
			Log() << "SockEngine::Process(): error: " << Anope::LastError();
		}
		else if (sresult)
		{
			for (std::map<int, Socket *>::const_iterator it = Sockets.begin(), it_end = Sockets.end(); it != it_end; ++it)
			{
				Socket *s = it->second;

				if (s->HasFlag(SF_DEAD))
					continue;
				if (FD_ISSET(s->GetFD(), &efdset))
				{
					s->ProcessError();
					s->SetFlag(SF_DEAD);
					continue;
				}
				if (FD_ISSET(s->GetFD(), &rfdset) && !s->ProcessRead())
					s->SetFlag(SF_DEAD);
				if (FD_ISSET(s->GetFD(), &wfdset) && !s->ProcessWrite())
					s->SetFlag(SF_DEAD);
			}

			for (std::map<int, Socket *>::iterator it = Sockets.begin(), it_end = Sockets.end(); it != it_end; )
			{
				Socket *s = it->second;
				++it;

				if (s->HasFlag(SF_DEAD))
					delete s;
			}
		}
	}
};

class ModuleSocketEngineSelect : public Module
{
	SocketEngineSelect engine;

 public:
	ModuleSocketEngineSelect(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator)
	{
		this->SetAuthor("Anope");
		this->SetPermanent(true);
		this->SetType(SOCKETENGINE);

		SocketEngine = &engine;
	}

	~ModuleSocketEngineSelect()
	{
		SocketEngine = NULL;
	}
};

MODULE_INIT(ModuleSocketEngineSelect)