Draft: ref: output: Rewrite sink functionality

This MR rewrites much of the output layer. It's meant to consolidate loose variables and redundant code into concise abstractions and support further changes beyond the traditional POSIX use case, like expanding support for DAX interfaces.

Main improvements:

• OutputFile.cc source file
• sink.h / sink.cc unit with dedicated FileSink class to concentrate synchronous metadata write operations and asynchronous commits, managing the preexisting close-and-rename queue in a separate thread. As such, only the data staging step remains within the scope of OutputFile
• Metadata classes: RunMetadata, LumisectionMetadata and FileMetadata.
• [potential bug fix] The run number used in the footers and filenames is now collected at the data intake step, not by consulting the control structure at the output step. This may prevent a race condition if the structure is changed in parallel before all slices make their way down the pipeline.

Some further changes are still planned; above all, clang-formatting has to be re-toggled. These updates will come as needed according to progress on DAX support in the next few days.

scripts/mock_control.py

-#! /usr/bin/python2
+#! /usr/bin/python3
 
 import socket
 import time
 
 MAX_RUNS = 3
-EXEC_TIME_SECS = 5
-STOP_DELAY_SECS = 10
+EXEC_TIME_SECS = 20
+STOP_DELAY_SECS = 20
 
 
 def send_command(sock, cmd, run_no):
     message = cmd + " " + str(run_no)
-    print "Sending message: ", message
+    print("Sending message: ", message)
     try:
-        sock.sendall(message)
-        data = sock.recv(256)
-        print "Server response: ", data
+        sock.sendall(message.encode('utf-8'))
+        data = sock.recv(256).decode('utf-8')
         if "ok" in data:
-            print "Command successful"
-            return True
+            return cmd + " command successful: received " + data
         else:
-            return False
+            return cmd + " command FAILED: received " + data
     except Exception as e:
-        print "ERROR! ", e
+        print("ERROR! ", e)
         return False
 
-
 if __name__ == "__main__":
     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server_address = ('localhost', 8000)
     sock.connect(server_address)
 
+    time.sleep(5)
+
     do_start = True
-    for current_run in range(0, MAX_RUNS):
+    for current_run in range(1, MAX_RUNS + 1):
         if do_start:
-            print "Starting run ", current_run
+            print("Starting run ", current_run)
             send_command(sock, "start", current_run)
             time.sleep(EXEC_TIME_SECS)
 
-        print "Halting run ", current_run
+        print("Halting run ", current_run)
         send_command(sock, "stop", current_run)
         time.sleep(STOP_DELAY_SECS)