src/socketengine.cpp

   1 /*       +------------------------------------+
   2  *       | Inspire Internet Relay Chat Daemon |
   3  *       +------------------------------------+
   4  *
   5  *  InspIRCd: (C) 2002-2007 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 #include "inspircd.h"
  17 #include "socketengine.h"
  18
  19 int EventHandler::GetFd()
  20 {
  21         return this->fd;
  22 }
  23
  24 void EventHandler::SetFd(int FD)
  25 {
  26         this->fd = FD;
  27 }
  28
  29 bool EventHandler::Readable()
  30 {
  31         return true;
  32 }
  33
  34 bool EventHandler::Writeable()
  35 {
  36         return false;
  37 }
  38
  39 void SocketEngine::WantWrite(EventHandler* eh)
  40 {
  41 }
  42
  43 SocketEngine::SocketEngine(InspIRCd* Instance) : ServerInstance(Instance)
  44 {
  45         memset(ref, 0, sizeof(ref));
  46 }
  47
  48 SocketEngine::~SocketEngine()
  49 {
  50 }
  51
  52 bool SocketEngine::AddFd(EventHandler* eh)
  53 {
  54         return true;
  55 }
  56
  57 bool SocketEngine::HasFd(int fd)
  58 {
  59         if ((fd < 0) || (fd > MAX_DESCRIPTORS))
  60                 return false;
  61         return ref[fd];
  62 }
  63
  64 EventHandler* SocketEngine::GetRef(int fd)
  65 {
  66         if ((fd < 0) || (fd > MAX_DESCRIPTORS))
  67                 return 0;
  68         return ref[fd];
  69 }
  70
  71 bool SocketEngine::DelFd(EventHandler* eh, bool force)
  72 {
  73         return true;
  74 }
  75
  76 int SocketEngine::GetMaxFds()
  77 {
  78         return 0;
  79 }
  80
  81 int SocketEngine::GetRemainingFds()
  82 {
  83         return 0;
  84 }
  85
  86 int SocketEngine::DispatchEvents()
  87 {
  88         return 0;
  89 }
  90
  91 std::string SocketEngine::GetName()
  92 {
  93         return "misconfigured";
  94 }
  95
  96 bool SocketEngine::BoundsCheckFd(EventHandler* eh)
  97 {
  98         if (!eh)
  99                 return false;
 100         if ((eh->GetFd() < 0) || (eh->GetFd() > MAX_DESCRIPTORS))
 101                 return false;
 102         return true;
 103 }
 104
 105 #ifdef WINDOWS
 106
 107 int SocketEngine::Accept(EventHandler* fd, sockaddr *addr, socklen_t *addrlen) { return -1; }
 108 int SocketEngine::Close(int fd) { return -1; }
 109 int SocketEngine::Close(EventHandler* fd) { return -1; }
 110 int SocketEngine::Blocking(int fd) { return -1; }
 111 int SocketEngine::NonBlocking(int fd) { return -1; }
 112 int SocketEngine::GetSockName(EventHandler* fd, sockaddr *name, socklen_t* namelen) { return -1; }
 113 int SocketEngine::RecvFrom(EventHandler* fd, void *buf, size_t len, int flags, sockaddr *from, socklen_t *fromlen) { return -1; }
 114
 115 #else
 116
 117 int SocketEngine::Accept(EventHandler* fd, sockaddr *addr, socklen_t *addrlen)
 118 {
 119         return accept(fd->GetFd(), addr, addrlen);
 120 }
 121
 122 int SocketEngine::Close(EventHandler* fd)
 123 {
 124         return close(fd->GetFd());
 125 }
 126
 127 int SocketEngine::Close(int fd)
 128 {
 129         return close(fd);
 130 }
 131
 132 int SocketEngine::Blocking(int fd)
 133 {
 134         int flags = fcntl(fd, F_GETFL, 0);
 135         return fcntl(fd, F_SETFL, flags ^ O_NONBLOCK);
 136 }
 137
 138 int SocketEngine::NonBlocking(int fd)
 139 {
 140         int flags = fcntl(fd, F_GETFL, 0);
 141         return fcntl(fd, F_SETFL, flags | O_NONBLOCK);
 142 }
 143
 144 int SocketEngine::GetSockName(EventHandler* fd, sockaddr *name, socklen_t* namelen)
 145 {
 146         return getsockname(fd->GetFd(), name, namelen);
 147 }
 148
 149 int SocketEngine::RecvFrom(EventHandler* fd, void *buf, size_t len, int flags, sockaddr *from, socklen_t *fromlen)
 150 {
 151         return recvfrom(fd->GetFd(), buf, len, flags, from, fromlen);
 152 }
 153
 154 #endif
 155
 156 int SocketEngine::Send(EventHandler* fd, const void *buf, size_t len, int flags)
 157 {
 158         return send(fd->GetFd(), (const char*)buf, len, flags);
 159 }
 160
 161 int SocketEngine::Recv(EventHandler* fd, void *buf, size_t len, int flags)
 162 {
 163         return recv(fd->GetFd(), (char*)buf, len, flags);
 164 }
 165
 166 int SocketEngine::SendTo(EventHandler* fd, const void *buf, size_t len, int flags, const sockaddr *to, socklen_t tolen)
 167 {
 168         return sendto(fd->GetFd(), (const char*)buf, len, flags, to, tolen);
 169 }
 170
 171 int SocketEngine::Connect(EventHandler* fd, const sockaddr *serv_addr, socklen_t addrlen)
 172 {
 173         return connect(fd->GetFd(), serv_addr, addrlen);
 174 }
 175
 176 int SocketEngine::Shutdown(EventHandler* fd, int how)
 177 {
 178         return shutdown(fd->GetFd(), how);
 179 }
 180
 181 int SocketEngine::Bind(int fd, const sockaddr *my_addr, socklen_t addrlen)
 182 {
 183         return bind(fd, my_addr, addrlen);
 184 }
 185
 186 int SocketEngine::Listen(int sockfd, int backlog)
 187 {
 188         return listen(sockfd, backlog);
 189 }
 190
 191 int SocketEngine::Shutdown(int fd, int how)
 192 {
 193         return shutdown(fd, how);
 194 }
 195
 196 void SocketEngine::RecoverFromFork()
 197 {
 198 }
 199