/* +------------------------------------+ * | Inspire Internet Relay Chat Daemon | * +------------------------------------+ * * InspIRCd: (C) 2002-2009 InspIRCd Development Team * See: http://wiki.inspircd.org/Credits * * This program is free but copyrighted software; see * the file COPYING for details. * * --------------------------------------------------- */ #include "inspircd.h" #include "socket.h" #include "inspstring.h" #include "socketengine.h" BufferedSocket::BufferedSocket() { Timeout = NULL; state = I_ERROR; } BufferedSocket::BufferedSocket(int newfd) { Timeout = NULL; this->fd = newfd; this->state = I_CONNECTED; if (fd > -1) ServerInstance->SE->AddFd(this); } void BufferedSocket::DoConnect(const std::string &ipaddr, int aport, unsigned long maxtime, const std::string &connectbindip) { BufferedSocketError err = BeginConnect(ipaddr, aport, maxtime, connectbindip); if (err != I_ERR_NONE) { state = I_ERROR; SetError(strerror(errno)); OnError(err); } } BufferedSocketError BufferedSocket::BeginConnect(const std::string &ipaddr, int aport, unsigned long maxtime, const std::string &connectbindip) { irc::sockets::sockaddrs addr, bind; if (!irc::sockets::aptosa(ipaddr.c_str(), aport, &addr)) { ServerInstance->Logs->Log("SOCKET", DEBUG, "BUG: Hostname passed to BufferedSocket, rather than an IP address!"); return I_ERR_CONNECT; } bind.sa.sa_family = 0; if (!connectbindip.empty()) { if (!irc::sockets::aptosa(connectbindip.c_str(), 0, &bind)) { return I_ERR_BIND; } } return BeginConnect(addr, bind, maxtime); } static void IncreaseOSBuffers(int fd) { // attempt to increase socket sendq and recvq as high as its possible int sendbuf = 32768; int recvbuf = 32768; setsockopt(fd,SOL_SOCKET,SO_SNDBUF,(const char *)&sendbuf,sizeof(sendbuf)); setsockopt(fd,SOL_SOCKET,SO_RCVBUF,(const char *)&recvbuf,sizeof(recvbuf)); // on failure, do nothing. I'm a little sick of people trying to interpret this message as a result of why their incorrect setups don't work. } BufferedSocketError BufferedSocket::BeginConnect(const irc::sockets::sockaddrs& dest, const irc::sockets::sockaddrs& bind, unsigned long timeout) { if (fd < 0) fd = socket(dest.sa.sa_family, SOCK_STREAM, 0); if (fd < 0) return I_ERR_SOCKET; if (bind.sa.sa_family != 0) { if (ServerInstance->SE->Bind(fd, &bind.sa, sa_size(bind)) < 0) return I_ERR_BIND; } ServerInstance->SE->NonBlocking(fd); if (ServerInstance->SE->Connect(this, &dest.sa, sa_size(dest)) == -1) { if (errno != EINPROGRESS) return I_ERR_CONNECT; } this->state = I_CONNECTING; if (!ServerInstance->SE->AddFd(this, true)) return I_ERR_NOMOREFDS; this->Timeout = new SocketTimeout(this->GetFd(), this, timeout, ServerInstance->Time()); ServerInstance->Timers->AddTimer(this->Timeout); IncreaseOSBuffers(fd); ServerInstance->Logs->Log("SOCKET", DEBUG,"BufferedSocket::DoConnect success"); return I_ERR_NONE; } void StreamSocket::Close() { /* Save this, so we dont lose it, * otherise on failure, error messages * might be inaccurate. */ int save = errno; if (this->fd > -1) { if (IOHook) { try { IOHook->OnStreamSocketClose(this); } catch (CoreException& modexcept) { ServerInstance->Logs->Log("SOCKET", DEFAULT,"%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason()); } } ServerInstance->SE->Shutdown(this, 2); ServerInstance->SE->DelFd(this); ServerInstance->SE->Close(this); fd = -1; } errno = save; } void StreamSocket::cull() { Close(); } bool StreamSocket::GetNextLine(std::string& line, char delim) { std::string::size_type i = recvq.find(delim); if (i == std::string::npos) return false; line = recvq.substr(0, i - 1); // TODO is this the most efficient way to split? recvq = recvq.substr(i + 1); return true; } void StreamSocket::DoRead() { if (IOHook) { int rv = -1; try { rv = IOHook->OnStreamSocketRead(this, recvq); } catch (CoreException& modexcept) { ServerInstance->Logs->Log("SOCKET", DEFAULT, "%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason()); return; } if (rv > 0) OnDataReady(); if (rv < 0) SetError("Read Error"); // will not overwrite a better error message } else { char* ReadBuffer = ServerInstance->GetReadBuffer(); int n = recv(fd, ReadBuffer, ServerInstance->Config->NetBufferSize, 0); if (n > 0) { recvq.append(ReadBuffer, n); OnDataReady(); } else if (n == 0) { error = "Connection closed"; } else if (errno != EAGAIN && errno != EINTR) { error = strerror(errno); } } } void StreamSocket::DoWrite() { if (sendq.empty()) return; if (IOHook) { int rv = -1; try { while (!sendq.empty()) { std::string& front = sendq.front(); int itemlen = front.length(); rv = IOHook->OnStreamSocketWrite(this, front); if (rv > 0) { // consumed the entire string, and is ready for more sendq_len -= itemlen; sendq.pop_front(); } else if (rv == 0) { // socket has blocked. Stop trying to send data. // IOHook has requested unblock notification from the socketengine // Since it is possible that a partial write took place, adjust sendq_len sendq_len = sendq_len - itemlen + front.length(); return; } else { SetError("Write Error"); // will not overwrite a better error message return; } } } catch (CoreException& modexcept) { ServerInstance->Logs->Log("SOCKET", DEBUG,"%s threw an exception: %s", modexcept.GetSource(), modexcept.GetReason()); } } else { // Prepare a writev() call to write all buffers efficiently int bufcount = sendq.size(); // cap the number of buffers at IOV_MAX if (bufcount > IOV_MAX) bufcount = IOV_MAX; iovec* iovecs = new iovec[bufcount]; for(int i=0; i < bufcount; i++) { iovecs[i].iov_base = const_cast(sendq[i].data()); iovecs[i].iov_len = sendq[i].length(); } int rv = writev(fd, iovecs, bufcount); delete[] iovecs; if (rv == (int)sendq_len) { // it's our lucky day, everything got written out. Fast cleanup. sendq_len = 0; sendq.clear(); } else if (rv > 0) { // Partial write. Clean out strings from the sendq sendq_len -= rv; while (rv > 0 && !sendq.empty()) { std::string& front = sendq.front(); if (front.length() < (size_t)rv) { // this string got fully written out rv -= front.length(); sendq.pop_front(); } else { // stopped in the middle of this string front = front.substr(rv); rv = 0; } } } else if (rv == 0) { error = "Connection closed"; } else if (errno != EAGAIN && errno != EINTR) { error = strerror(errno); } if (sendq_len && error.empty()) ServerInstance->SE->WantWrite(this); } } void StreamSocket::WriteData(const std::string &data) { bool newWrite = sendq.empty() && !data.empty(); /* Append the data to the back of the queue ready for writing */ sendq.push_back(data); sendq_len += data.length(); if (newWrite) { // TODO perhaps we should try writing first, before asking SE about writes? // DoWrite(); ServerInstance->SE->WantWrite(this); } } void SocketTimeout::Tick(time_t) { ServerInstance->Logs->Log("SOCKET", DEBUG,"SocketTimeout::Tick"); if (ServerInstance->SE->GetRef(this->sfd) != this->sock) return; if (this->sock->state == I_CONNECTING) { // for connecting sockets, the timeout can occur // which causes termination of the connection after // the given number of seconds without a successful // connection. this->sock->OnTimeout(); this->sock->OnError(I_ERR_TIMEOUT); /* NOTE: We must set this AFTER DelFd, as we added * this socket whilst writeable. This means that we * must DELETE the socket whilst writeable too! */ this->sock->state = I_ERROR; ServerInstance->GlobalCulls.AddItem(sock); } this->sock->Timeout = NULL; } void BufferedSocket::OnConnected() { } void BufferedSocket::OnTimeout() { return; } void BufferedSocket::DoWrite() { if (state == I_CONNECTING) { state = I_CONNECTED; this->OnConnected(); if (GetIOHook()) GetIOHook()->OnStreamSocketConnect(this); } this->StreamSocket::DoWrite(); } BufferedSocket::~BufferedSocket() { this->Close(); if (Timeout) { ServerInstance->Timers->DelTimer(Timeout); Timeout = NULL; } } void StreamSocket::HandleEvent(EventType et, int errornum) { BufferedSocketError errcode = I_ERR_OTHER; switch (et) { case EVENT_ERROR: { SetError(strerror(errornum)); switch (errornum) { case ETIMEDOUT: errcode = I_ERR_TIMEOUT; break; case ECONNREFUSED: case 0: errcode = I_ERR_CONNECT; break; case EADDRINUSE: errcode = I_ERR_BIND; break; case EPIPE: case EIO: errcode = I_ERR_WRITE; break; } break; } case EVENT_READ: { DoRead(); break; } case EVENT_WRITE: { DoWrite(); break; } } if (!error.empty()) { ServerInstance->Logs->Log("SOCKET", DEBUG, "Error on FD %d - '%s'", fd, error.c_str()); OnError(errcode); ServerInstance->GlobalCulls.AddItem(this); } }