Draft: Create Network driver instead of directly using sockets.

core/src/main/java/org/lflang/federated/extensions/CExtension.java

@@ -289,7 +289,8 @@ public String generateNetworkSenderBody(
             + " in federate "
             + connection.getDstFederate().name);
 
-    // In case sendRef is a multiport or is in a bank, this reaction will be triggered when any
+    // In case sendRef is a multiport or is in a bank, this reaction will be
+    // triggered when any
     // channel or bank index of sendRef is present
     // ex. if a.out[i] is present, the entire output a.out is triggered.
     if (connection.getSrcBank() != -1 || connection.getSrcChannel() != -1) {
@@ -300,10 +301,13 @@ public String generateNetworkSenderBody(
       result.pr("}");
     }
 
-    // If the connection is physical and the receiving federate is remote, send it directly on a
+    // If the connection is physical and the receiving federate is remote, send it
+    // directly on a
     // socket.
-    // If the connection is logical and the coordination mode is centralized, send via RTI.
-    // If the connection is logical and the coordination mode is decentralized, send directly
+    // If the connection is logical and the coordination mode is centralized, send
+    // via RTI.
+    // If the connection is logical and the coordination mode is decentralized, send
+    // directly
     String messageType;
     // Name of the next immediate destination of this message
     var next_destination_name = "\"federate " + connection.getDstFederate().id + "\"";
@@ -682,10 +686,11 @@ private String generateCodeToInitializeFederate(
         String.join(
             "\n",
             "// Initialize the socket mutexes",
-            "lf_mutex_init(&lf_outbound_socket_mutex);",
-            "lf_mutex_init(&socket_mutex);",
+            "lf_mutex_init(&lf_outbound_netdrv_mutex);",
+            "lf_mutex_init(&netdrv_mutex);",
             "lf_cond_init(&lf_port_status_changed, &env->mutex);"));
-
+    // CExtensionUtils.surroundWithIfOpenSSLRequired(
+    //     "OPENSSL_init_crypto(OPENSSL_INIT_NO_ATEXIT, NULL);"),
     // Find the STA (A.K.A. the global STP offset) for this federate.
     if (federate.targetConfig.get(CoordinationProperty.INSTANCE)
         == CoordinationMode.DECENTRALIZED) {
@@ -738,14 +743,16 @@ else if (globalSTP instanceof CodeExprImpl)
             "\n",
             "// Initialize the array of socket for incoming connections to -1.",
             "for (int i = 0; i < NUMBER_OF_FEDERATES; i++) {",
-            "    _fed.sockets_for_inbound_p2p_connections[i] = -1;",
+            "    _fed.netdrv_for_inbound_p2p_connections[i] = NULL;",
+            // "    _fed.netdrv_to_inbound[i] = NULL;",
             "}"));
     code.pr(
         String.join(
             "\n",
             "// Initialize the array of socket for outgoing connections to -1.",
             "for (int i = 0; i < NUMBER_OF_FEDERATES; i++) {",
-            "    _fed.sockets_for_outbound_p2p_connections[i] = -1;",
+            "    _fed.netdrv_for_outbound_p2p_connections[i] = NULL;",
+            // "    _fed.netdrv_to_outbound[i] = NULL;",
             "}"));
     var clockSyncOptions = federate.targetConfig.getOrDefault(ClockSyncOptionsProperty.INSTANCE);
     // If a test clock offset has been specified, insert code to set it here.
@@ -771,7 +778,7 @@ else if (globalSTP instanceof CodeExprImpl)
     // Disable clock synchronization for the federate if it resides on the same host as the RTI,
     // unless that is overridden with the clock-sync-options target property.
     if (CExtensionUtils.clockSyncIsOn(federate, rtiConfig)) {
-      code.pr("synchronize_initial_physical_clock_with_rti(&_fed.socket_TCP_RTI);");
+      code.pr("synchronize_initial_physical_clock_with_rti(_fed.netdrv_to_rti);");
     }
 
     if (numberOfInboundConnections > 0) {

core/src/main/java/org/lflang/federated/extensions/CExtensionUtils.java

@@ -28,6 +28,7 @@
 import org.lflang.target.property.ClockSyncOptionsProperty;
 import org.lflang.target.property.ClockSyncOptionsProperty.ClockSyncOptions;
 import org.lflang.target.property.CmakeIncludeProperty;
+import org.lflang.target.property.CommunicationTypeProperty;
 import org.lflang.target.property.CompileDefinitionsProperty;
 import org.lflang.target.property.CoordinationOptionsProperty;
 import org.lflang.target.property.CoordinationProperty;
@@ -201,6 +202,10 @@ public static void handleCompileDefinitions(
     if (federate.targetConfig.get(AuthProperty.INSTANCE)) {
       definitions.put("FEDERATED_AUTHENTICATED", "");
     }
+    if (federate.targetConfig.isSet(CommunicationTypeProperty.INSTANCE)) {
+      definitions.put(
+          "COMM_TYPE", federate.targetConfig.get(CommunicationTypeProperty.INSTANCE).toString());
+    }
     definitions.put("NUMBER_OF_FEDERATES", String.valueOf(federateNames.size()));
     definitions.put("EXECUTABLE_PREAMBLE", "");
     definitions.put("FEDERATE_ID", String.valueOf(federate.id));
@@ -342,7 +347,7 @@ public static String generateFederateNeighborStructure(FederateInstance federate
             "* information is needed for the RTI to perform the centralized coordination.",
             "* @see MSG_TYPE_NEIGHBOR_STRUCTURE in net_common.h",
             "*/",
-            "void lf_send_neighbor_structure_to_RTI(int rti_socket) {"));
+            "void lf_send_neighbor_structure_to_RTI(netdrv_t *netdrv) {"));
     code.indent();
     // Initialize the array of information about the federate's immediate upstream
     // and downstream relayed (through the RTI) logical connections, to send to the
@@ -444,8 +449,8 @@ public static String generateFederateNeighborStructure(FederateInstance federate
     code.pr(
         String.join(
             "\n",
-            "write_to_socket_fail_on_error(",
-            "    &rti_socket, ",
+            "write_to_netdrv_fail_on_error(",
+            "    netdrv, ",
             "    buffer_size,",
             "    buffer_to_send,",
             "    NULL,",
@@ -525,6 +530,20 @@ public static String surroundWithIfFederatedDecentralized(String code) {
         .formatted(code);
   }
 
+  // /**
+  //  * Surround {@code code} with blocks to ensure that code only executes if the program is
+  // federated
+  //  * and has a decentralized coordination.
+  //  */
+  // public static String surroundWithIfOpenSSLRequired(String code) {
+  //   return """
+  //           #ifdef OPENSSL_REQUIRED
+  //           %s
+  //           #endif // OPENSSL_REQUIRED
+  //           """
+  //       .formatted(code);
+  // }
+
   /** Generate preamble code needed for enabled serializers of the federate. */
   public static String generateSerializationIncludes(FederateInstance federate) {
     CodeBuilder code = new CodeBuilder();

core/src/main/java/org/lflang/federated/generator/FedGenerator.java

@@ -59,6 +59,7 @@
 import org.lflang.lf.VarRef;
 import org.lflang.target.Target;
 import org.lflang.target.TargetConfig;
+import org.lflang.target.property.CommunicationTypeProperty;
 import org.lflang.target.property.CoordinationProperty;
 import org.lflang.target.property.DockerProperty;
 import org.lflang.target.property.DockerProperty.DockerOptions;
@@ -159,6 +160,15 @@ public boolean doGenerate(Resource resource, LFGeneratorContext context) throws
     // for logical connections.
     replaceFederateConnectionsWithProxies(federation, main, resource);
 
+    // Generate Credentials for SST.
+    if (context
+        .getTargetConfig()
+        .get(CommunicationTypeProperty.INSTANCE)
+        .toString()
+        .equals("SST")) {
+      SSTGenerator.setupSST(fileConfig, federates, messageReporter, context);
+    }
+
     FedEmitter fedEmitter =
         new FedEmitter(
             fileConfig,

core/src/main/java/org/lflang/federated/generator/FederateInstance.java

@@ -74,7 +74,7 @@
  * @author Soroush Bateni
  */
 public class FederateInstance {
-
+  // TODO: DONGHA: Need to take out network related things.
   /**
    * Construct a new federate instance on the basis of an instantiation in the federated reactor.
    *

core/src/main/java/org/lflang/federated/generator/FederationFileConfig.java

@@ -91,6 +91,26 @@ public Path getFedBinPath() {
     return getFedGenPath().resolve("bin");
   }
 
+  public Path getSSTPath() {
+    return getGenPath().resolve("sst");
+  }
+
+  public Path getSSTConfigPath() {
+    return getSSTPath().resolve("configs");
+  }
+
+  public Path getSSTCredentialsPath() {
+    return getSSTPath().resolve("credentials");
+  }
+
+  public Path getSSTGraphsPath() {
+    return getSSTPath().resolve("graphs");
+  }
+
+  public Path getSSTAuthPath() {
+    return getSSTPath().resolve("auth");
+  }
+
   @Override
   public void doClean() throws IOException {
     super.doClean();