Auto-convert to D2

sociomantic-tsunami · Oct 1, 2019 · 32460bb · 32460bb
1 parent 20d8c8f
commit 32460bb
Show file tree

Hide file tree

Showing 354 changed files with 2,730 additions and 2,730 deletions.
diff --git a/.D2-ready b/.D2-ready
@@ -1 +1 @@
-Enables D2 testing in Jenkins
+ONLY
diff --git a/integrationtest/flexiblefilequeue/main.d b/integrationtest/flexiblefilequeue/main.d
@@ -25,7 +25,7 @@ public void main ()
     auto test_dir = DirectorySandbox.create(["flexiblefilequeue"]);
     scope (exit) test_dir.remove();
 
-    const istring test_file = "testfile";
+    static immutable istring test_file = "testfile";
 
 
     static void pushItems (FlexibleFileQueue queue, size_t size)

diff --git a/integrationtest/httpserver/main.d b/integrationtest/httpserver/main.d
@@ -35,7 +35,7 @@ import core.stdc.errno;
 import core.stdc.stdlib;
 
 /// The payload of the HTTP response.
-const response_payload = "Hello World!";
+static immutable response_payload = "Hello World!";
 
 /// The server address, initialised in `main` and used by both the server and
 /// the client.
@@ -47,7 +47,7 @@ class TestHttpHandler: TaskHttpConnectionHandler
 {
     import ocean.io.Stdout;
 
-    public this ( FinalizeDg finalizer )
+    public this ( scope FinalizeDg finalizer )
     {
         super(finalizer, HttpMethod.Get);
     }
@@ -171,7 +171,7 @@ static class ResponseParser
     char[] response;
     /// The token that denotes the end of the HTTP header and the beginning of
     /// the payload.
-    const end_of_header_token = "\r\n\r\n";
+    static immutable end_of_header_token = "\r\n\r\n";
     /// true if `end_of_header_token` has been fond in `response`.
     bool have_payload;
     /// The index in `response` after `end_of_header_token`.

diff --git a/integrationtest/selectlistener/UnixServer.d b/integrationtest/selectlistener/UnixServer.d
@@ -99,7 +99,7 @@ private class UnixConnectionHandler: IFiberConnectionHandler
 
     ***************************************************************************/
 
-    public this ( FinalizeDg finalize_dg, EpollSelectDispatcher epoll )
+    public this ( scope FinalizeDg finalize_dg, EpollSelectDispatcher epoll )
     {
         super(epoll, new UnixSocket, finalize_dg);
 

diff --git a/integrationtest/signalfd/main.d b/integrationtest/signalfd/main.d
@@ -67,7 +67,7 @@ private class SignalFDTest
 
     ***************************************************************************/
 
-    private const max_signal = 32;
+    private static immutable max_signal = 32;
 
 
     /***************************************************************************
@@ -431,7 +431,7 @@ private class SignalFDTest
         while (ret == -1 && errno == EINTR);
         enforce (ret == 0);
 
-        const int timeout_ms = 100; // just in case
+        static immutable int timeout_ms = 100; // just in case
         epoll_event_t[1] fired_events;
         auto epoll_res = epoll.wait(fired_events, timeout_ms);
 

diff --git a/integrationtest/unixsocket/main.d b/integrationtest/unixsocket/main.d
@@ -41,9 +41,9 @@ import core.thread;
 
 import ocean.text.util.StringC;
 
-const istring CLIENT_STRING = "Hello from the client";
+static immutable istring CLIENT_STRING = "Hello from the client";
 
-const istring SERVER_STRING = "Hello from the server";
+static immutable istring SERVER_STRING = "Hello from the server";
 
 int runClient ( sockaddr_un* socket_address )
 {

diff --git a/src/ocean/LibFeatures.d b/src/ocean/LibFeatures.d
@@ -17,26 +17,26 @@
 
 module ocean.LibFeatures;
 
-const has_features_4_2  = true;
-const has_features_4_1  = true;
-const has_features_4_0  = true;
-const has_features_3_9  = true;
-const has_features_3_8  = true;
-const has_features_3_7  = true;
-const has_features_3_6  = true;
-const has_features_3_5  = true;
-const has_features_3_4  = true;
-const has_features_3_3  = true;
-const has_features_3_2  = true;
-const has_features_3_1  = true;
-const has_features_3_0  = true;
-const has_features_2_10 = true;
-const has_features_2_9  = true;
-const has_features_2_8  = true;
-const has_features_2_7  = true;
-const has_features_2_6  = true;
-const has_features_2_5  = true;
-const has_features_2_4  = true;
-const has_features_2_3  = true;
-const has_features_2_1  = true;
-const has_features_2_0  = true;
+static immutable has_features_4_2  = true;
+static immutable has_features_4_1  = true;
+static immutable has_features_4_0  = true;
+static immutable has_features_3_9  = true;
+static immutable has_features_3_8  = true;
+static immutable has_features_3_7  = true;
+static immutable has_features_3_6  = true;
+static immutable has_features_3_5  = true;
+static immutable has_features_3_4  = true;
+static immutable has_features_3_3  = true;
+static immutable has_features_3_2  = true;
+static immutable has_features_3_1  = true;
+static immutable has_features_3_0  = true;
+static immutable has_features_2_10 = true;
+static immutable has_features_2_9  = true;
+static immutable has_features_2_8  = true;
+static immutable has_features_2_7  = true;
+static immutable has_features_2_6  = true;
+static immutable has_features_2_5  = true;
+static immutable has_features_2_4  = true;
+static immutable has_features_2_3  = true;
+static immutable has_features_2_1  = true;
+static immutable has_features_2_0  = true;
diff --git a/src/ocean/application/components/PidLock.d b/src/ocean/application/components/PidLock.d
@@ -70,7 +70,7 @@ public struct PidLock
 
     public void parseConfig ( ConfigParser config )
     {
-        this.pidlock_path = config.get("PidLock", "path", "").dup;
+        (&this).pidlock_path = config.get("PidLock", "path", "").dup;
     }
 
     /***************************************************************************
@@ -84,12 +84,12 @@ public struct PidLock
 
     public void lock ( )
     {
-        if (this.pidlock_path.length)
+        if ((&this).pidlock_path.length)
         {
             istring msg =
-                idup("Couldn't lock the pid lock file '" ~ this.pidlock_path
+                idup("Couldn't lock the pid lock file '" ~ (&this).pidlock_path
                  ~ "'. Probably another instance of the application is running.");
-            enforce(this.tryLockPidFile(), msg);
+            enforce((&this).tryLockPidFile(), msg);
         }
     }
 
@@ -104,14 +104,14 @@ public struct PidLock
 
     public void unlock ( )
     {
-        if (!this.is_locked)
+        if (!(&this).is_locked)
         {
             return;
         }
 
         // releases the lock and closes the lock file
-        this.enforcePosix!(close)(this.lock_fd);
-        this.enforcePosix!(unlink)(StringC.toCString(this.pidlock_path));
+        (&this).enforcePosix!(close)((&this).lock_fd);
+        (&this).enforcePosix!(unlink)(StringC.toCString((&this).pidlock_path));
     }
 
     /***************************************************************************
@@ -134,11 +134,11 @@ public struct PidLock
 
     private bool tryLockPidFile ( )
     {
-        this.lock_fd = this.enforcePosix!(open)(StringC.toCString(this.pidlock_path),
+        (&this).lock_fd = (&this).enforcePosix!(open)(StringC.toCString((&this).pidlock_path),
                 O_RDWR | O_CREAT, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
 
         // TODO these will be available in tango v1.6.0
-        const F_SETLK = 6;
+        enum F_SETLK = 6;
 
         // Lock the pidfile
         flock fl;
@@ -147,7 +147,7 @@ public struct PidLock
         fl.l_start = 0;
         fl.l_len = 0;
 
-        if (fcntl(this.lock_fd, F_SETLK, &fl) == -1)
+        if (fcntl((&this).lock_fd, F_SETLK, &fl) == -1)
         {
             // Region already locked, can't acquire a lock
             if (errno == EAGAIN || errno == EACCES)
@@ -161,14 +161,14 @@ public struct PidLock
         }
 
         // Clear the any previous contents of the file
-        this.enforcePosix!(ftruncate)(this.lock_fd, 0);
+        (&this).enforcePosix!(ftruncate)((&this).lock_fd, 0);
 
         char[512] buf;
         auto pid_string = snformat(buf, "{}\n", getpid());
 
-        this.writeNonInterrupted(this.lock_fd, pid_string);
+        (&this).writeNonInterrupted((&this).lock_fd, pid_string);
 
-        this.is_locked = true;
+        (&this).is_locked = true;
         return true;
     }
 

diff --git a/src/ocean/application/components/Signals.d b/src/ocean/application/components/Signals.d
@@ -169,7 +169,7 @@ public class Signals
 
     ***************************************************************************/
 
-    public this ( HandlerDg handler_dg )
+    public this ( scope HandlerDg handler_dg )
     {
         verify(handler_dg !is null);
         this.handler_dg = handler_dg;

diff --git a/src/ocean/application/components/TaskScheduler.d b/src/ocean/application/components/TaskScheduler.d
@@ -40,7 +40,7 @@ public void parseSchedulerConfig ( ConfigParser parser,
     if (parser is null)
         return;
 
-    const category = "SCHEDULER";
+    static immutable category = "SCHEDULER";
 
     foreach (idx, ref field; config.tupleof)
     {
@@ -92,7 +92,7 @@ public void parseSchedulerConfig ( ConfigParser parser,
 
 *******************************************************************************/
 
-public int runInTask ( int delegate () dg )
+public int runInTask ( scope int delegate () dg )
 {
     auto task = new class Task {
         int delegate() dg;

diff --git a/src/ocean/application/components/Timers.d b/src/ocean/application/components/Timers.d
@@ -111,7 +111,7 @@ public class Timers
 
     ***************************************************************************/
 
-    public void register ( EventDg dg, double period_s )
+    public void register ( scope EventDg dg, double period_s )
     {
         verify(dg !is null);
         verify(period_s >= 0.0);
@@ -131,7 +131,7 @@ public class Timers
 
     ***************************************************************************/
 
-    public void register ( EventDg dg, double init_s, double period_s )
+    public void register ( scope EventDg dg, double init_s, double period_s )
     {
         verify(dg !is null);
         verify(init_s >= 0.0);
@@ -157,7 +157,7 @@ public class Timers
 
     ***************************************************************************/
 
-    public void registerMicrosec ( EventDg dg, ulong init_microsec, ulong period_microsec )
+    public void registerMicrosec ( scope EventDg dg, ulong init_microsec, ulong period_microsec )
     {
         verify(dg !is null);
 

diff --git a/src/ocean/core/Array.d b/src/ocean/core/Array.d
@@ -128,8 +128,8 @@ unittest
     test(concat_test(dest, staticstr1, staticstr2), "Static array concatenation test failed");
 
     // Check manifest constant array concatenation
-    const conststr1 = "hi ";
-    const conststr2 = "there";
+    static immutable conststr1 = "hi ";
+    static immutable conststr2 = "there";
     test(concat_test(dest, conststr1, conststr2), "Const array concatenation test failed");
 }