summaryrefslogtreecommitdiff
path: root/src/listensocket.cpp
diff options
context:
space:
mode:
authordanieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7>2009-09-02 00:49:15 +0000
committerdanieldg <danieldg@e03df62e-2008-0410-955e-edbf42e46eb7>2009-09-02 00:49:15 +0000
commit347dcb9ef44e19e2e2613ee7e8c7d5fbb0aca4ca (patch)
tree870f6d58f03829c35724665d3313ed6ab017e828 /src/listensocket.cpp
parent24731c63b6320be22f7b3220236271fa7476b975 (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.cpp35
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);
+ }
}
}