debian-packages/eventcore
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Remove log noise for listening TCP sockets.

Browse source
This commit is contained in:
Sönke Ludwig 2017-07-14 12:35:17 +02:00
parent db28d6e6c9
commit 9518ec4dce
No known key found for this signature in database
GPG key ID: D95E8DB493EE314C
1 changed files with 0 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
source/eventcore/drivers/posix/sockets.d
View file

@ -129,7 +129,6 @@ final class PosixEventDriverSockets(Loop : PosixEventLoop) : EventDriverSockets
alias listenStream = EventDriverSockets.listenStream; alias listenStream = EventDriverSockets.listenStream;
final override StreamListenSocketFD listenStream(scope Address address, StreamListenOptions options, AcceptCallback on_accept) final override StreamListenSocketFD listenStream(scope Address address, StreamListenOptions options, AcceptCallback on_accept)
{ {
log("Listen stream");
auto sockfd = createSocket(address.addressFamily, SOCK_STREAM); auto sockfd = createSocket(address.addressFamily, SOCK_STREAM);
if (sockfd == -1) return StreamListenSocketFD.invalid; if (sockfd == -1) return StreamListenSocketFD.invalid;
@ -141,28 +140,23 @@ final class PosixEventDriverSockets(Loop : PosixEventLoop) : EventDriverSockets
int tmp_reuse = 1; int tmp_reuse = 1;
// FIXME: error handling! // FIXME: error handling!
if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &tmp_reuse, tmp_reuse.sizeof) != 0) { if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &tmp_reuse, tmp_reuse.sizeof) != 0) {
log("setsockopt SO_REUSEADDR failed.");
invalidateSocket(); invalidateSocket();
return; return;
} }
version (Windows) {} else { version (Windows) {} else {
if ((options & StreamListenOptions.reusePort) && setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &tmp_reuse, tmp_reuse.sizeof) != 0) { if ((options & StreamListenOptions.reusePort) && setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &tmp_reuse, tmp_reuse.sizeof) != 0) {
log("setsockopt SO_REUSEPORT failed.");
invalidateSocket(); invalidateSocket();
return; return;
} }
} }
if (bind(sockfd, address.name, address.nameLen) != 0) { if (bind(sockfd, address.name, address.nameLen) != 0) {
log("bind failed.");
invalidateSocket(); invalidateSocket();
return; return;
} }
if (listen(sockfd, 128) != 0) { if (listen(sockfd, 128) != 0) {
log("listen failed.");
invalidateSocket(); invalidateSocket();
return; return;
} }
log("Success!");
} (); } ();
if (sock == StreamListenSocketFD.invalid) if (sock == StreamListenSocketFD.invalid)
@ -178,7 +172,6 @@ final class PosixEventDriverSockets(Loop : PosixEventLoop) : EventDriverSockets
final override void waitForConnections(StreamListenSocketFD sock, AcceptCallback on_accept) final override void waitForConnections(StreamListenSocketFD sock, AcceptCallback on_accept)
{ {
log("wait for conn");
m_loop.registerFD(sock, EventMask.read); m_loop.registerFD(sock, EventMask.read);
m_loop.m_fds[sock].streamListen.acceptCallback = on_accept; m_loop.m_fds[sock].streamListen.acceptCallback = on_accept;
m_loop.setNotifyCallback!(EventType.read)(sock, &onAccept); m_loop.setNotifyCallback!(EventType.read)(sock, &onAccept);