src/socketengine.cpp

   1 /*       +------------------------------------+
   2  *       | Inspire Internet Relay Chat Daemon |
   3  *       +------------------------------------+
   4  *
   5  *  InspIRCd: (C) 2002-2008 InspIRCd Development Team
   6  * See: http://www.inspircd.org/wiki/index.php/Credits
   7  *
   8  * This program is free but copyrighted software; see
   9  *          the file COPYING for details.
  10  *
  11  * ---------------------------------------------------
  12  */
  13
  14 /* $Core: libIRCDsocketengine */
  15
  16 /*********        DEFAULTS       **********/
  17 /* $ExtraSources: socketengines/socketengine_select.cpp */
  18 /* $ExtraObjects: socketengine_select.o */
  19
  20 /* $If: USE_KQUEUE */
  21 /* $ExtraSources: socketengines/socketengine_kqueue.cpp */
  22 /* $ExtraObjects: socketengine_kqueue.o */
  23 /* $EndIf */
  24
  25 /* $If: USE_EPOLL */
  26 /* $ExtraSources: socketengines/socketengine_epoll.cpp */
  27 /* $ExtraObjects: socketengine_epoll.o */
  28 /* $EndIf */
  29
  30 /* $If: USE_PORTS */
  31 /* $ExtraSources: socketengines/socketengine_ports.cpp */
  32 /* $ExtraObjects: socketengine_ports.o */
  33 /* $EndIf */
  34
  35 #include "inspircd.h"
  36 #include "socketengine.h"
  37
  38 int EventHandler::GetFd()
  39 {
  40         return this->fd;
  41 }
  42
  43 void EventHandler::SetFd(int FD)
  44 {
  45         this->fd = FD;
  46 }
  47
  48 bool EventHandler::Readable()
  49 {
  50         return true;
  51 }
  52
  53 bool EventHandler::Writeable()
  54 {
  55         return false;
  56 }
  57
  58 void SocketEngine::WantWrite(EventHandler* eh)
  59 {
  60 }
  61
  62 SocketEngine::SocketEngine(InspIRCd* Instance) : ServerInstance(Instance)
  63 {
  64         TotalEvents = WriteEvents = ReadEvents = ErrorEvents = 0;
  65 }
  66
  67 SocketEngine::~SocketEngine()
  68 {
  69 }
  70
  71 bool SocketEngine::AddFd(EventHandler* eh)
  72 {
  73         return true;
  74 }
  75
  76 bool SocketEngine::HasFd(int fd)
  77 {
  78         if ((fd < 0) || (fd > MAX_DESCRIPTORS))
  79                 return false;
  80         return ref[fd];
  81 }
  82
  83 EventHandler* SocketEngine::GetRef(int fd)
  84 {
  85         if ((fd < 0) || (fd > MAX_DESCRIPTORS))
  86                 return 0;
  87         return ref[fd];
  88 }
  89
  90 bool SocketEngine::DelFd(EventHandler* eh, bool force)
  91 {
  92         return true;
  93 }
  94
  95 int SocketEngine::GetMaxFds()
  96 {
  97         return 0;
  98 }
  99
 100 int SocketEngine::GetRemainingFds()
 101 {
 102         return 0;
 103 }
 104
 105 int SocketEngine::DispatchEvents()
 106 {
 107         return 0;
 108 }
 109
 110 std::string SocketEngine::GetName()
 111 {
 112         return "misconfigured";
 113 }
 114
 115 bool SocketEngine::BoundsCheckFd(EventHandler* eh)
 116 {
 117         if (!eh)
 118                 return false;
 119         if ((eh->GetFd() < 0) || (eh->GetFd() > MAX_DESCRIPTORS))
 120                 return false;
 121         return true;
 122 }
 123
 124
 125 int SocketEngine::Accept(EventHandler* fd, sockaddr *addr, socklen_t *addrlen)
 126 {
 127         return accept(fd->GetFd(), addr, addrlen);
 128 }
 129
 130 int SocketEngine::Close(EventHandler* fd)
 131 {
 132 #ifdef WINDOWS
 133         return closesocket(fd->GetFd());
 134 #else
 135         return close(fd->GetFd());
 136 #endif
 137 }
 138
 139 int SocketEngine::Close(int fd)
 140 {
 141 #ifdef WINDOWS
 142         return closesocket(fd);
 143 #else
 144         return close(fd);
 145 #endif
 146 }
 147
 148 int SocketEngine::Blocking(int fd)
 149 {
 150 #ifdef WINDOWS
 151         unsigned long opt = 0;
 152         return ioctlsocket(fd, FIONBIO, &opt);
 153 #else
 154         int flags = fcntl(fd, F_GETFL, 0);
 155         return fcntl(fd, F_SETFL, flags ^ O_NONBLOCK);
 156 #endif
 157 }
 158
 159 int SocketEngine::NonBlocking(int fd)
 160 {
 161 #ifdef WINDOWS
 162         unsigned long opt = 1;
 163         return ioctlsocket(fd, FIONBIO, &opt);
 164 #else
 165         int flags = fcntl(fd, F_GETFL, 0);
 166         return fcntl(fd, F_SETFL, flags | O_NONBLOCK);
 167 #endif
 168 }
 169
 170 int SocketEngine::GetSockName(EventHandler* fd, sockaddr *name, socklen_t* namelen)
 171 {
 172         return getsockname(fd->GetFd(), name, namelen);
 173 }
 174
 175 int SocketEngine::RecvFrom(EventHandler* fd, void *buf, size_t len, int flags, sockaddr *from, socklen_t *fromlen)
 176 {
 177         return recvfrom(fd->GetFd(), (char*)buf, len, flags, from, fromlen);
 178 }
 179
 180 int SocketEngine::Send(EventHandler* fd, const void *buf, size_t len, int flags)
 181 {
 182         return send(fd->GetFd(), (const char*)buf, len, flags);
 183 }
 184
 185 int SocketEngine::Recv(EventHandler* fd, void *buf, size_t len, int flags)
 186 {
 187         return recv(fd->GetFd(), (char*)buf, len, flags);
 188 }
 189
 190 int SocketEngine::SendTo(EventHandler* fd, const void *buf, size_t len, int flags, const sockaddr *to, socklen_t tolen)
 191 {
 192         return sendto(fd->GetFd(), (const char*)buf, len, flags, to, tolen);
 193 }
 194
 195 int SocketEngine::Connect(EventHandler* fd, const sockaddr *serv_addr, socklen_t addrlen)
 196 {
 197         return connect(fd->GetFd(), serv_addr, addrlen);
 198 }
 199
 200 int SocketEngine::Shutdown(EventHandler* fd, int how)
 201 {
 202         return shutdown(fd->GetFd(), how);
 203 }
 204
 205 int SocketEngine::Bind(int fd, const sockaddr *my_addr, socklen_t addrlen)
 206 {
 207         return bind(fd, my_addr, addrlen);
 208 }
 209
 210 int SocketEngine::Listen(int sockfd, int backlog)
 211 {
 212         return listen(sockfd, backlog);
 213 }
 214
 215 int SocketEngine::Shutdown(int fd, int how)
 216 {
 217         return shutdown(fd, how);
 218 }
 219
 220 void SocketEngine::RecoverFromFork()
 221 {
 222 }
 223