diff options
author | danieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7> | 2009-09-02 00:49:15 +0000 |
---|---|---|
committer | danieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7> | 2009-09-02 00:49:15 +0000 |
commit | 347dcb9ef44e19e2e2613ee7e8c7d5fbb0aca4ca (patch) | |
tree | 870f6d58f03829c35724665d3313ed6ab017e828 /src/listensocket.cpp | |
parent | 24731c63b6320be22f7b3220236271fa7476b975 (diff) |
Remove duplicated address conversion from InspIRCd::BindSocket, fix FD leak in listensocket
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@11632 e03df62e-2008-0410-955e-edbf42e46eb7
Diffstat (limited to 'src/listensocket.cpp')
-rw-r--r-- | src/listensocket.cpp | 35 |
1 files changed, 25 insertions, 10 deletions
diff --git a/src/listensocket.cpp b/src/listensocket.cpp index df252f18b..823cb9eca 100644 --- a/src/listensocket.cpp +++ b/src/listensocket.cpp @@ -26,24 +26,39 @@ ListenSocketBase::ListenSocketBase(InspIRCd* Instance, int port, const std::stri irc::sockets::sockaddrs bind_to; // canonicalize address if it is defined - if (irc::sockets::aptosa(addr.c_str(), port, &bind_to)) - { - irc::sockets::satoap(&bind_to, bind_addr, bind_port); - bind_desc = irc::sockets::satouser(&bind_to); - } - else + if (!irc::sockets::aptosa(addr.c_str(), port, &bind_to)) { + // malformed address bind_addr = addr; bind_port = port; bind_desc = addr + ":" + ConvToStr(port); + this->fd = -1; + } + else + { + irc::sockets::satoap(&bind_to, bind_addr, bind_port); + bind_desc = irc::sockets::satouser(&bind_to); + + this->fd = irc::sockets::OpenTCPSocket(bind_addr.c_str()); } - this->SetFd(irc::sockets::OpenTCPSocket(bind_addr.c_str())); - if (this->GetFd() > -1) + if (this->fd > -1) { - if (!Instance->BindSocket(this->fd,port,bind_addr.c_str())) + int rv = Instance->SE->Bind(this->fd, &bind_to.sa, sizeof(bind_to)); + if (rv >= 0) + rv = Instance->SE->Listen(this->fd, Instance->Config->MaxConn); + + if (rv < 0) + { + Instance->SE->Shutdown(this, 2); + Instance->SE->Close(this); this->fd = -1; - Instance->SE->AddFd(this); + } + else + { + Instance->SE->NonBlocking(this->fd); + Instance->SE->AddFd(this); + } } } |