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

Fix compilation errors in the socket wrapper.

Browse source
This commit is contained in:
Sönke Ludwig 2016-12-19 22:16:34 +01:00
parent cae451c4d7
commit e33d36eb46
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
source/eventcore/socket.d
View file

@ -14,7 +14,7 @@ StreamSocket connectStream(alias callback)(scope Address peer_address)
if (fd != StreamSocketFD.invalid) eventDriver.sockets.releaseRef(fd); if (fd != StreamSocketFD.invalid) eventDriver.sockets.releaseRef(fd);
} }
auto fd = eventDriver.sockets.connectStream(peer_address, &cb); auto fd = eventDriver.sockets.connectStream(peer_address, null, &cb);
enforce(fd != StreamSocketFD.invalid, "Failed to create socket."); enforce(fd != StreamSocketFD.invalid, "Failed to create socket.");
eventDriver.sockets.addRef(fd); eventDriver.sockets.addRef(fd);
return StreamSocket(fd); return StreamSocket(fd);
@ -126,6 +126,6 @@ void send(alias callback)(ref DatagramSocket socket, const(ubyte)[] buffer, IOMo
void cb(DatagramSocketFD fd, IOStatus status, size_t bytes_written, scope Address) @safe nothrow { void cb(DatagramSocketFD fd, IOStatus status, size_t bytes_written, scope Address) @safe nothrow {
callback(status, bytes_written); callback(status, bytes_written);
} }
eventDriver.sockets.send(socket.m_fd, buffer, mode, &cb, target_address); eventDriver.sockets.send(socket.m_fd, buffer, mode, target_address, &cb);
} }
void cancelSend(ref DatagramSocket socket) { eventDriver.sockets.cancelSend(socket.m_fd); } void cancelSend(ref DatagramSocket socket) { eventDriver.sockets.cancelSend(socket.m_fd); }