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

fixes

This commit is contained in:
Adam D. Ruppe 2022-07-05 07:20:20 -04:00
parent 7660d2429a
commit f18ec0626b
1 changed files with 32 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
cgi.d
View File

@ -338,7 +338,7 @@ void main() {
Copyright: Copyright:
cgi.d copyright 2008-2021, Adam D. Ruppe. Provided under the Boost Software License. cgi.d copyright 2008-2022, Adam D. Ruppe. Provided under the Boost Software License.
Yes, this file is old, and yes, it is still actively maintained and used. Yes, this file is old, and yes, it is still actively maintained and used.
+/ +/
@ -2197,6 +2197,17 @@ class Cgi {
customHeaders ~= h; customHeaders ~= h;
} }
/++
I named the original function `header` after PHP, but this pattern more fits
the rest of the Cgi object.
Either name are allowed.
History:
Alias added June 17, 2022.
+/
alias setResponseHeader = header;
private string[] customHeaders; private string[] customHeaders;
private bool websocketMode; private bool websocketMode;
@ -7969,7 +7980,7 @@ final class EventSourceServerImplementation : EventSourceServer, EventIoServer {
int typeLength; int typeLength;
char[32] typeBuffer = 0; char[32] typeBuffer = 0;
int messageLength; int messageLength;
char[2048] messageBuffer = 0; char[2048 * 4] messageBuffer = 0; // this is an arbitrary limit, it needs to fit comfortably in stack (including in a fiber) and be a single send on the kernel side cuz of the impl... i think this is ok for a unix socket.
int _lifetime; int _lifetime;
char[] message() return { char[] message() return {
@ -8242,7 +8253,7 @@ void runAddonServer(EIS)(string localListenerName, EIS eis) if(is(EIS : EventIoS
cloexec(ns); cloexec(ns);
makeNonBlocking(ns); makeNonBlocking(ns);
auto niop = allocateIoOp(ns, IoOp.ReadSocketHandle, 4096, &eis.handleLocalConnectionData); auto niop = allocateIoOp(ns, IoOp.ReadSocketHandle, 4096 * 4, &eis.handleLocalConnectionData);
niop.closeHandler = &eis.handleLocalConnectionClose; niop.closeHandler = &eis.handleLocalConnectionClose;
niop.completeHandler = &eis.handleLocalConnectionComplete; niop.completeHandler = &eis.handleLocalConnectionComplete;
scope(failure) freeIoOp(niop); scope(failure) freeIoOp(niop);
@ -9700,30 +9711,34 @@ struct MultipleResponses(T...) {
--- ---
auto valueToTest = your_test_function(); auto valueToTest = your_test_function();
valueToTest.visit!( valueToTest.visit(
(Redirection) { assert(0); }, // got a redirection instead of a string, fail the test (Redirection r) { assert(0); }, // got a redirection instead of a string, fail the test
(string s) { assert(s == "test"); } // right value, go ahead and test it. (string s) { assert(s == "test"); } // right value, go ahead and test it.
); );
--- ---
History:
Was horribly broken until June 16, 2022. Ironically, I wrote it for tests but never actually tested it.
It tried to use alias lambdas before, but runtime delegates work much better so I changed it.
+/ +/
void visit(Handlers...)() { void visit(Handlers...)(Handlers handlers) {
template findHandler(type, HandlersToCheck...) { template findHandler(type, int count, HandlersToCheck...) {
static if(HandlersToCheck.length == 0) static if(HandlersToCheck.length == 0)
alias findHandler = void; enum findHandler = -1;
else { else {
static if(is(typeof(HandlersToCheck[0](type.init)))) static if(is(typeof(HandlersToCheck[0].init(type.init))))
alias findHandler = handler; enum findHandler = count;
else else
alias findHandler = findHandler!(type, HandlersToCheck[1 .. $]); enum findHandler = findHandler!(type, count + 1, HandlersToCheck[1 .. $]);
} }
} }
foreach(index, type; T) { foreach(index, type; T) {
alias handler = findHandler!(type, Handlers); enum handlerIndex = findHandler!(type, 0, Handlers);
static if(is(handler == void)) static if(handlerIndex == -1)
static assert(0, "Type " ~ type.stringof ~ " was not handled by visitor"); static assert(0, "Type " ~ type.stringof ~ " was not handled by visitor");
else { else {
if(index == contains) if(index == this.contains)
handler(payload[index]); handlers[handlerIndex](this.payload[index]);
} }
} }
} }
@ -11195,11 +11210,11 @@ bool apiDispatcher()(Cgi cgi) {
version(linux) version(linux)
private extern(C) int eventfd (uint initval, int flags) nothrow @trusted @nogc; private extern(C) int eventfd (uint initval, int flags) nothrow @trusted @nogc;
/* /*
Copyright: Adam D. Ruppe, 2008 - 2021 Copyright: Adam D. Ruppe, 2008 - 2022
License: [http://www.boost.org/LICENSE_1_0.txt|Boost License 1.0]. License: [http://www.boost.org/LICENSE_1_0.txt|Boost License 1.0].
Authors: Adam D. Ruppe Authors: Adam D. Ruppe
Copyright Adam D. Ruppe 2008 - 2021. Copyright Adam D. Ruppe 2008 - 2022.
Distributed under the Boost Software License, Version 1.0. Distributed under the Boost Software License, Version 1.0.
(See accompanying file LICENSE_1_0.txt or copy at (See accompanying file LICENSE_1_0.txt or copy at
http://www.boost.org/LICENSE_1_0.txt) http://www.boost.org/LICENSE_1_0.txt)