aboutsummaryrefslogtreecommitdiffstats
path: root/src/socketengines/socketengine_poll.cpp
diff options
context:
space:
mode:
authorGravatar Sadie Powell2021-03-05 08:19:21 +0000
committerGravatar Sadie Powell2021-03-05 08:20:49 +0000
commitf644b58a0102b83284b19f510f594f3943d0f0e8 (patch)
tree94c22270d629c03ab6fe36adc480adba535e0d3d /src/socketengines/socketengine_poll.cpp
parentImplement support for other SHA2 hash types. (diff)
Remove unnecessary prefix from socketengine source files.
Diffstat (limited to 'src/socketengines/socketengine_poll.cpp')
-rw-r--r--src/socketengines/socketengine_poll.cpp217
1 files changed, 0 insertions, 217 deletions
diff --git a/src/socketengines/socketengine_poll.cpp b/src/socketengines/socketengine_poll.cpp
deleted file mode 100644
index 992a69aae..000000000
--- a/src/socketengines/socketengine_poll.cpp
+++ /dev/null
@@ -1,217 +0,0 @@
-/*
- * InspIRCd -- Internet Relay Chat Daemon
- *
- * Copyright (C) 2014-2015 Attila Molnar <attilamolnar@hush.com>
- * Copyright (C) 2014, 2017 Adam <Adam@anope.org>
- * Copyright (C) 2013, 2016-2017 Sadie Powell <sadie@witchery.services>
- * Copyright (C) 2012 Robby <robby@chatbelgie.be>
- * Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
- * Copyright (C) 2009 Uli Schlachter <psychon@inspircd.org>
- * Copyright (C) 2008 Robin Burchell <robin+git@viroteck.net>
- *
- * This file is part of InspIRCd. InspIRCd is free software: you can
- * redistribute it and/or modify it under the terms of the GNU General Public
- * License as published by the Free Software Foundation, version 2.
- *
- * This program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
- * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
- * details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
-
-
-#include "inspircd.h"
-
-#include <sys/poll.h>
-#include <sys/resource.h>
-
-/** A specialisation of the SocketEngine class, designed to use poll().
- */
-namespace
-{
- /** These are used by poll() to hold socket events
- */
- std::vector<struct pollfd> events(16);
- /** This vector maps fds to an index in the events array.
- */
- std::vector<int> fd_mappings(16, -1);
-}
-
-void SocketEngine::Init()
-{
- LookupMaxFds();
-}
-
-void SocketEngine::Deinit()
-{
-}
-
-void SocketEngine::RecoverFromFork()
-{
-}
-
-static int mask_to_poll(int event_mask)
-{
- int rv = 0;
- if (event_mask & (FD_WANT_POLL_READ | FD_WANT_FAST_READ))
- rv |= POLLIN;
- if (event_mask & (FD_WANT_POLL_WRITE | FD_WANT_FAST_WRITE | FD_WANT_SINGLE_WRITE))
- rv |= POLLOUT;
- return rv;
-}
-
-bool SocketEngine::AddFd(EventHandler* eh, int event_mask)
-{
- int fd = eh->GetFd();
- if (fd < 0)
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "AddFd out of range: (fd: %d)", fd);
- return false;
- }
-
- if (static_cast<unsigned int>(fd) < fd_mappings.size() && fd_mappings[fd] != -1)
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "Attempt to add duplicate fd: %d", fd);
- return false;
- }
-
- unsigned int index = CurrentSetSize;
-
- if (!SocketEngine::AddFdRef(eh))
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "Attempt to add duplicate fd: %d", fd);
- return false;
- }
-
- while (static_cast<unsigned int>(fd) >= fd_mappings.size())
- fd_mappings.resize(fd_mappings.size() * 2, -1);
- fd_mappings[fd] = index;
-
- ResizeDouble(events);
- events[index].fd = fd;
- events[index].events = mask_to_poll(event_mask);
-
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "New file descriptor: %d (%d; index %d)", fd, events[index].events, index);
- eh->SetEventMask(event_mask);
- return true;
-}
-
-void SocketEngine::OnSetEvent(EventHandler* eh, int old_mask, int new_mask)
-{
- int fd = eh->GetFd();
- if (fd < 0 || static_cast<unsigned int>(fd) >= fd_mappings.size() || fd_mappings[fd] == -1)
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "SetEvents() on unknown fd: %d", eh->GetFd());
- return;
- }
-
- events[fd_mappings[fd]].events = mask_to_poll(new_mask);
-}
-
-void SocketEngine::DelFd(EventHandler* eh)
-{
- int fd = eh->GetFd();
- if (fd < 0)
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "DelFd out of range: (fd: %d)", fd);
- return;
- }
-
- if (static_cast<unsigned int>(fd) >= fd_mappings.size() || fd_mappings[fd] == -1)
- {
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "DelFd() on unknown fd: %d", fd);
- return;
- }
-
- unsigned int index = fd_mappings[fd];
- unsigned int last_index = CurrentSetSize - 1;
- int last_fd = events[last_index].fd;
-
- if (index != last_index)
- {
- // We need to move the last fd we got into this gap (gaps are evil!)
-
- // So update the mapping for the last fd to its new position
- fd_mappings[last_fd] = index;
-
- // move last_fd from last_index into index
- events[index].fd = last_fd;
- events[index].events = events[last_index].events;
- }
-
- // Now remove all data for the last fd we got into out list.
- // Above code made sure this always is right
- fd_mappings[fd] = -1;
- events[last_index].fd = 0;
- events[last_index].events = 0;
-
- SocketEngine::DelFdRef(eh);
-
- ServerInstance->Logs.Log("SOCKET", LOG_DEBUG, "Remove file descriptor: %d (index: %d) "
- "(Filled gap with: %d (index: %d))", fd, index, last_fd, last_index);
-}
-
-int SocketEngine::DispatchEvents()
-{
- int i = poll(&events[0], CurrentSetSize, 1000);
- int processed = 0;
- ServerInstance->UpdateTime();
-
- for (size_t index = 0; index < CurrentSetSize && processed < i; index++)
- {
- struct pollfd& pfd = events[index];
-
- // Copy these in case the vector gets resized and pfd invalidated
- const int fd = pfd.fd;
- const short revents = pfd.revents;
-
- if (revents)
- processed++;
-
- EventHandler* eh = GetRef(fd);
- if (!eh)
- continue;
-
- if (revents & POLLHUP)
- {
- eh->OnEventHandlerError(0);
- continue;
- }
-
- if (revents & POLLERR)
- {
- // Get error number
- socklen_t codesize = sizeof(int);
- int errcode;
- if (getsockopt(fd, SOL_SOCKET, SO_ERROR, &errcode, &codesize) < 0)
- errcode = errno;
- eh->OnEventHandlerError(errcode);
- continue;
- }
-
- if (revents & POLLIN)
- {
- eh->SetEventMask(eh->GetEventMask() & ~FD_READ_WILL_BLOCK);
- eh->OnEventHandlerRead();
- if (eh != GetRef(fd))
- // whoops, deleted out from under us
- continue;
- }
-
- if (revents & POLLOUT)
- {
- int mask = eh->GetEventMask();
- mask &= ~(FD_WRITE_WILL_BLOCK | FD_WANT_SINGLE_WRITE);
- eh->SetEventMask(mask);
-
- // The vector could've been resized, reference can be invalid by now; don't use it
- events[index].events = mask_to_poll(mask);
- eh->OnEventHandlerWrite();
- }
- }
-
- return i;
-}