forks
/
arsd
mirror of https://github.com/adamdruppe/arsd.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:adamdruppe/arsd

This commit is contained in:
Adam D. Ruppe 2022-07-05 07:20:22 -04:00
parent f18ec0626b 75e2aad72c
commit 7cf46ec976
2 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
cgi.d
View File

@ -4314,7 +4314,7 @@ extern(Windows) private {
alias LPWSAOVERLAPPED = LPOVERLAPPED;
/+
alias LPFN_ACCEPTEX =
alias LPFN_ACCEPTEX =
BOOL
function(
SOCKET sListenSocket,
@ -4457,7 +4457,7 @@ private class PseudoblockingOverlappedSocket : Socket {
WSABUF[1] buffer;
OVERLAPPED overlapped;
override ptrdiff_t send(const(void)[] buf, SocketFlags flags) @trusted {
override ptrdiff_t send(scope const(void)[] buf, SocketFlags flags) @trusted {
overlapped = overlapped.init;
buffer[0].len = cast(DWORD) buf.length;
buffer[0].buf = cast(CHAR*) buf.ptr;
@ -4472,7 +4472,7 @@ private class PseudoblockingOverlappedSocket : Socket {
Fiber.yield();
return lastAnswer;
}
override ptrdiff_t receive(void[] buf, SocketFlags flags) @trusted {
override ptrdiff_t receive(scope void[] buf, SocketFlags flags) @trusted {
overlapped = overlapped.init;
buffer[0].len = cast(DWORD) buf.length;
buffer[0].buf = cast(CHAR*) buf.ptr;
@ -4493,16 +4493,16 @@ private class PseudoblockingOverlappedSocket : Socket {
}
// I might go back and implement these for udp things.
override ptrdiff_t receiveFrom(void[] buf, SocketFlags flags, ref Address from) @trusted {
override ptrdiff_t receiveFrom(scope void[] buf, SocketFlags flags, ref Address from) @trusted {
assert(0);
}
override ptrdiff_t receiveFrom(void[] buf, SocketFlags flags) @trusted {
override ptrdiff_t receiveFrom(scope void[] buf, SocketFlags flags) @trusted {
assert(0);
}
override ptrdiff_t sendTo(const(void)[] buf, SocketFlags flags, Address to) @trusted {
override ptrdiff_t sendTo(scope const(void)[] buf, SocketFlags flags, Address to) @trusted {
assert(0);
}
override ptrdiff_t sendTo(const(void)[] buf, SocketFlags flags) @trusted {
override ptrdiff_t sendTo(scope const(void)[] buf, SocketFlags flags) @trusted {
assert(0);
}
@ -5128,13 +5128,13 @@ private class FakeSocketForStdin : Socket {
private bool closed;
override ptrdiff_t receive(void[] buffer, std.socket.SocketFlags) @trusted {
override ptrdiff_t receive(scope void[] buffer, std.socket.SocketFlags) @trusted {
if(closed)
throw new Exception("Closed");
return stdin.rawRead(buffer).length;
}
override ptrdiff_t send(const void[] buffer, std.socket.SocketFlags) @trusted {
override ptrdiff_t send(const scope void[] buffer, std.socket.SocketFlags) @trusted {
if(closed)
throw new Exception("Closed");
stdout.rawWrite(buffer);
@ -5149,7 +5149,7 @@ private class FakeSocketForStdin : Socket {
// FIXME
}
override void setOption(SocketOptionLevel, SocketOption, void[]) {}
override void setOption(SocketOptionLevel, SocketOption, scope void[]) {}
override void setOption(SocketOptionLevel, SocketOption, Duration) {}
override @property @trusted Address remoteAddress() { return null; }

14
fibersocket.d
View File

@ -185,30 +185,30 @@ class FiberSocket : Socket {
}
return r;
}
/// Yielding override of the Phobos interface
override ptrdiff_t send(const(void)[] buf, SocketFlags flags) {
override ptrdiff_t send(scope const(void)[] buf, SocketFlags flags) {
return magic( () { return super.send(buf, flags); }, PendingOperation.write);
}
/// ditto
override ptrdiff_t receive(void[] buf, SocketFlags flags) {
override ptrdiff_t receive(scope void[] buf, SocketFlags flags) {
return magic( () { return super.receive(buf, flags); }, PendingOperation.read);
}
/// ditto
override ptrdiff_t receiveFrom(void[] buf, SocketFlags flags, ref Address from) @trusted {
override ptrdiff_t receiveFrom(scope void[] buf, SocketFlags flags, ref Address from) @trusted {
return magic( () { return super.receiveFrom(buf, flags, from); }, PendingOperation.read);
}
/// ditto
override ptrdiff_t receiveFrom(void[] buf, SocketFlags flags) @trusted {
override ptrdiff_t receiveFrom(scope void[] buf, SocketFlags flags) @trusted {
return magic( () { return super.receiveFrom(buf, flags); }, PendingOperation.read);
}
/// ditto
override ptrdiff_t sendTo(const(void)[] buf, SocketFlags flags, Address to) @trusted {
override ptrdiff_t sendTo(scope const(void)[] buf, SocketFlags flags, Address to) @trusted {
return magic( () { return super.sendTo(buf, flags, to); }, PendingOperation.write);
}
/// ditto
override ptrdiff_t sendTo(const(void)[] buf, SocketFlags flags) @trusted {
override ptrdiff_t sendTo(scope const(void)[] buf, SocketFlags flags) @trusted {
return magic( () { return super.sendTo(buf, flags); }, PendingOperation.write);
}