};
-ListenSocket::ListenSocket(InspIRCd* Instance, int sockfd, insp_sockaddr client, insp_sockaddr server, int port, char* addr) : ServerInstance(Instance)
+ListenSocket::ListenSocket(InspIRCd* Instance, int sockfd, insp_sockaddr client, insp_sockaddr server, int port, char* addr) : ServerInstance(Instance), desc("plaintext")
{
this->SetFd(sockfd);
- Instance->Log(DEBUG,"Binding to port %s:%d",addr,port);
if (!Instance->BindSocket(this->fd,client,server,port,addr))
- {
- Instance->Log(DEBUG,"Binding failed!");
this->fd = -1;
- }
}
ListenSocket::~ListenSocket()
insp_sockaddr client;
socklen_t length;
int incomingSockfd, in_port;
-
- ServerInstance->Log(DEBUG,"Handle ListenSocket event");
-
uslen = sizeof(sock_us);
length = sizeof(client);
incomingSockfd = accept (this->GetFd(),(struct sockaddr*)&client, &length);
#else
in_port = ntohs(sock_us.sin_port);
#endif
- ServerInstance->Log(DEBUG,"Accepted socket %d",incomingSockfd);
NonBlocking(incomingSockfd);
if (ServerInstance->Config->GetIOHook(in_port))
{
}
ServerInstance->stats->statsAccept++;
#ifdef IPV6
- ServerInstance->Log(DEBUG,"Add ipv6 client");
userrec::AddClient(ServerInstance, incomingSockfd, in_port, false, client.sin6_addr);
#else
- ServerInstance->Log(DEBUG,"Add ipv4 client");
userrec::AddClient(ServerInstance, incomingSockfd, in_port, false, client.sin_addr);
#endif
- ServerInstance->Log(DEBUG,"Adding client on port %d fd=%d",in_port,incomingSockfd);
}
else
{
- ServerInstance->Log(DEBUG,"Accept failed on fd %d: %s",incomingSockfd,strerror(errno));
shutdown(incomingSockfd,2);
close(incomingSockfd);
ServerInstance->stats->statsRefused++;
*addr = 0;
if ((*addr) && (insp_aton(addr,&addy) < 1))
- {
- this->Log(DEBUG,"Invalid IP '%s' given to BindSocket()", addr);
return false;;
- }
#ifdef IPV6
server.sin6_family = AF_FAMILY;
}
else
{
- this->Log(DEBUG,"Bound port %s:%d",*addr ? addr : "*",port);
if (listen(sockfd, Config->MaxConn) == -1)
{
this->Log(DEFAULT,"ERROR in listen(): %s",strerror(errno));
ports_found = 0;
int InitialPortCount = stats->BoundPortCount;
- this->Log(DEBUG,"Initial port count: %d",InitialPortCount);
for (int count = 0; count < Config->ConfValueEnum(Config->config_data, "bind"); count++)
{
strlcpy(Config->addrs[clientportcount+InitialPortCount],Addr,256);
clientportcount++;
- this->Log(DEBUG,"NEW binding %s:%d [%s] from config",Addr, portno, Type);
}
}
}
int fd = OpenTCPSocket();
if (fd == ERROR)
{
- this->Log(DEBUG,"Bad fd %d binding port [%s:%d]",fd,Config->addrs[count],Config->ports[count]);
failed_ports.push_back(std::make_pair(Config->addrs[count],Config->ports[count]));
}
else
}
return InitialPortCount + BoundPortCount;
}
- else
- {
- this->Log(DEBUG,"There is nothing new to bind!");
- }
return InitialPortCount;
}
}
int fd = OpenTCPSocket();
if (fd == ERROR)
{
- this->Log(DEBUG,"Bad fd %d binding port [%s:%d]",fd,Config->addrs[count],Config->ports[count]);
failed_ports.push_back(std::make_pair(Config->addrs[count],Config->ports[count]));
}
else