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

Merge pull request #107 from vibe-d/disable_so_addr

Browse source 
Add `StreamListenOptions.reuseAddress`.
This commit is contained in:
Leonid Kramer 2019-04-01 20:38:29 +02:00 committed by GitHub
parent b11936e4bc 891eed3d62
commit 1bbe244196
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 18 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
source/eventcore/driver.d
View file

@ -876,8 +876,13 @@ enum ConnectionState {
}
enum StreamListenOptions {
defaults = 0,
none = 0,
/// Applies the `SO_REUSEPORT` flag
reusePort = 1<<0,
/// Avoids applying the `SO_REUSEADDR` flag
reuseAddress = 1<<1,
///
defaults = reuseAddress,
}
enum StreamSocketOption {

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

@ -221,10 +221,12 @@ final class PosixEventDriverSockets(Loop : PosixEventLoop) : EventDriverSockets
() @trusted {
int tmp_reuse = 1;
// FIXME: error handling!
if ((options & StreamListenOptions.reusePort) && setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &tmp_reuse, tmp_reuse.sizeof) != 0) {
if (options & StreamListenOptions.reuseAddress) {
if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &tmp_reuse, tmp_reuse.sizeof) != 0) {
invalidateSocket();
return;
}
}
version (Windows) {} else {
if ((options & StreamListenOptions.reusePort) && setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &tmp_reuse, tmp_reuse.sizeof) != 0) {
invalidateSocket();

4
source/eventcore/drivers/winapi/sockets.d
View file

@ -42,7 +42,7 @@ final class WinAPIEventDriverSockets : EventDriverSockets {
package bool checkForLeakedHandles()
{
if (m_socketCount == 0) return false;
print("Warning: Socket handles leaked at driver shutdown.");
print("Warning: %s socket handles leaked at driver shutdown.", m_socketCount);
return true;
}
@ -155,11 +155,13 @@ final class WinAPIEventDriverSockets : EventDriverSockets {
void invalidateSocket() @nogc @trusted nothrow { closesocket(fd); fd = INVALID_SOCKET; }
() @trusted {
if (options & StreamListenOptions.reuseAddress) {
int tmp_reuse = 1;
if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &tmp_reuse, tmp_reuse.sizeof) != 0) {
invalidateSocket();
return;
}
}
// FIXME: should SO_EXCLUSIVEADDRUSE be used of StreamListenOptions.reuseAddress isn't set?