Tracing federate interactions

core/federated/RTI/CMakeLists.txt

@@ -62,6 +62,7 @@ add_executable(
     RTI
     rti.c
     rti_lib.c
+    ${CoreLib}/trace.c
     ${LF_PLATFORM_FILE}
     ${CoreLib}/platform/lf_unix_clock_support.c
     ${CoreLib}/utils/util.c
@@ -80,6 +81,9 @@ ENDIF(CMAKE_BUILD_TYPE MATCHES DEBUG)
 target_compile_definitions(RTI PUBLIC LF_THREADED=1 FEDERATED=1)
 target_compile_definitions(RTI PUBLIC PLATFORM_${CMAKE_SYSTEM_NAME})
 
+# Set RTI Tracing
+target_compile_definitions(RTI PUBLIC RTI_TRACE)
+
 # Find threads and link to it
 find_package(Threads REQUIRED)
 target_link_libraries(RTI Threads::Threads)

core/federated/RTI/message_record/message_record.c

@@ -162,7 +162,7 @@ tag_t get_minimum_in_transit_message_tag(in_transit_message_record_q_t* queue) {
 
     if (head_of_in_transit_messages != NULL) {
         LF_PRINT_DEBUG(
-            "RTI: Minimum tag of all in-transit messages: (%ld, %u).",
+            "RTI: Minimum tag of all in-transit messages: " PRINTF_TAG,
             head_of_in_transit_messages->tag.time - lf_time_start(),
             head_of_in_transit_messages->tag.microstep
         );

core/federated/RTI/rti.c

@@ -47,14 +47,25 @@ THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
 #include "rti_lib.h"
+unsigned int _lf_number_of_workers = 0u;
 
 extern RTI_instance_t _RTI;
 
-int main(int argc, char* argv[]) {
+/**
+ * RTI trace file name
+ */
+const char *rti_trace_file_name = "rti.lft";
+
+int main(int argc, const char* argv[]) {
     if (!process_args(argc, argv)) {
         // Processing command-line arguments failed.
         return -1;
     }
+    if (_RTI.tracing_enabled) {
+        _lf_number_of_workers = _RTI.number_of_federates;
+        start_trace(rti_trace_file_name);
+        printf("Tracing the RTI execution in %s file.\n", rti_trace_file_name);
+    }
     printf("Starting RTI for %d federates in federation ID %s\n", _RTI.number_of_federates, _RTI.federation_id);
     assert(_RTI.number_of_federates < UINT16_MAX);
     _RTI.federates = (federate_t*)calloc(_RTI.number_of_federates, sizeof(federate_t));
@@ -63,6 +74,9 @@ int main(int argc, char* argv[]) {
     }
     int socket_descriptor = start_rti_server(_RTI.user_specified_port);
     wait_for_federates(socket_descriptor);
+    if (_RTI.tracing_enabled) {
+        stop_trace();
+    }
     printf("RTI is exiting.\n");
     return 0;
 }