Http server d (#375)

Author: cyrusmsk

bench/algorithm/binarytrees/1.d

@@ -1,6 +1,8 @@
 @safe:
 import std;
 
+extern(C) __gshared string[] rt_options = [ "gcopt=minPoolSize:300" ];
+
 const MIN_DEPTH = 4;
 
 class Node {

bench/algorithm/http-server/1.d

@@ -0,0 +1,35 @@
+import std;
+import arsd.cgi;
+
+static void startServer(RequestServer s) {
+    s.serve!(postFunc, Cgi, defaultMaxContentLength);
+}
+
+void postFunc(Cgi cgi) {
+    cgi.setResponseContentType("text/plain");
+    cgi.write(cgi.post["value"]);
+
+}
+
+int reqSend(Tuple!(string, int) val) {
+    while (true) {
+        auto content = std.net.curl.post(val[0], ["value" : val[1].to!string]);
+        return content.to!int;
+    }
+}
+
+int main(string[] args)
+{
+    int n = args.length > 1 ? args[1].to!int : 10;
+    auto rnd = Random(unpredictableSeed);
+    auto port = uniform(30000, 40000, rnd);
+    string api = "127.0.0.1:"~to!string(port)~"/";
+    RequestServer server = RequestServer("127.0.0.1", cast(ushort) port);
+    server.useFork = false;
+    auto tid = spawn(&startServer, server);
+    auto init = iota(1,n + 1,1).map!(a => tuple(api, a));
+    auto res = taskPool.amap!reqSend(init, n);
+    writeln(res.sum);
+    server.stop();
+    return 0;
+}

bench/algorithm/http-server/2.d

@@ -0,0 +1,38 @@
+import std;
+import arsd.cgi;
+
+static void startServer(RequestServer s) {
+    s.serve!(postFunc, Cgi, defaultMaxContentLength);
+}
+
+void postFunc(Cgi cgi) {
+    cgi.setResponseContentType("text/plain");
+    auto p = parseJSON(cgi.postBody);
+    cgi.write(p["value"].to!string);
+
+}
+
+int reqSend(Tuple!(string, int) val) {
+    auto client = HTTP();
+    client.addRequestHeader("Content-Type: appliation/json", "Content-Type: appliation/json");
+    while (true) {
+        auto content = std.net.curl.post(val[0], (JSONValue(["value" : val[1]])).toString, client);
+        return content.to!int;
+    }
+}
+
+int main(string[] args)
+{
+    int n = args.length > 1 ? args[1].to!int : 10;
+    auto rnd = Random(unpredictableSeed);
+    auto port = uniform(30000, 40000, rnd);
+    string api = "127.0.0.1:"~to!string(port)~"/";
+    RequestServer server = RequestServer("127.0.0.1", cast(ushort) port);
+    server.useFork = false;
+    auto tid = spawn(&startServer, server);
+    auto init = iota(1,n + 1,1).map!(a => tuple(api, a));
+    auto res = taskPool.amap!reqSend(init, n);
+    writeln(res.sum);
+    server.stop();
+    return 0;
+}

bench/algorithm/merkletrees/1.d

@@ -1,6 +1,8 @@
 @safe:
 import std;
 
+extern(C) __gshared string[] rt_options = [ "gcopt=minPoolSize:300" ];
+
 const MIN_DEPTH = 4;
 
 class Node {

bench/bench_d.yaml

@@ -56,7 +56,11 @@ problems:
       - 1-m.d
   - name: json-serde
     source:
-      # - 2.d
+      - 2.d
+  - name: http-server
+    source:
+      - 1.d
+      - 2.d
 compiler_version_command:
 compiler_version_regex:
 runtime_version_parameter:

bench/include/d/dub.json

@@ -3,12 +3,13 @@
 		"root"
 	],
 	"copyright": "Copyright © 2021, root",
-	"dependencies": {
-		"intel-intrinsics": {
-			"version": "5691bf9de94b1c08244c45e6c3659fb0c150e82c",
-			"repository": "git+https://github.com/AuburnSounds/intel-intrinsics.git"
-		}
-	},
+    "dependencies": {
+        "asdf": "~>0.7.15",
+        "intel-intrinsics": "1.11.1",
+        "mir-algorithm": {"version": "468377999b43fe370c2f59a40257183475f04c55", "repository": "git+https://github.com/cyrusmsk/mir-algorithm.git", "default": true},
+        "arsd-official:cgi": "~>10.9.8"
+    },
+    "subConfigurations": {"arsd-official:cgi": "embedded_httpd_hybrid"},
 	"description": "A minimal D application.",
 	"license": "MIT",
 	"name": "app",