[C#] Real time APIs

bindings/csharp/src/Ingescape.cs

@@ -2195,6 +2195,58 @@ public static Result ElectionLeave(string electionName)
         }
         #endregion
 
+        #region Ingescape real-time communications
+
+        [DllImport(ingescapeDLLPath, CallingConvention = CallingConvention.Cdecl)]
+        private static extern int igs_rt_get_current_timestamp();
+        /// <summary>
+        /// GET TIMESTAMP FOR RECEIVED INPUTS AND SERVICES
+        /// When observing an input or a service, call this function inside the callback
+        /// to get the current timestamp in microseconds for the received information.
+        /// NB: if timestamp is not available in received input or service, current
+        /// time in microseconds is set to INT64_MIN.
+        /// </summary>
+        public static int RtGetCurrentTimestamp() { return igs_rt_get_current_timestamp(); }
+
+
+        [DllImport(ingescapeDLLPath, CallingConvention = CallingConvention.Cdecl)]
+        private static extern void igs_rt_set_timestamps(bool enable);
+        /// <summary>
+        /// ENABLE TIMESTAMPS IN OUR AGENT FOR PUBLISHED OUTPUTS AND SERVICE CALLS
+        /// When timestamps are enabled, every output publication and every service call
+        /// carry an additional information providing the timestamp of the message on
+        /// the sender side. On the receiver side, timestamp is obtained by calling
+        /// igs_rt_get_current_timestamp
+        /// </summary>
+        public static void RtSetTimestamps(bool enable) { igs_rt_set_timestamps(enable); }
+
+        [DllImport(ingescapeDLLPath, CallingConvention = CallingConvention.Cdecl)]
+        private static extern bool igs_rt_timestamps();
+        public static bool RtTimestamps() { return igs_rt_timestamps(); }
+
+
+        [DllImport(ingescapeDLLPath, CallingConvention = CallingConvention.Cdecl)]
+        private static extern void igs_rt_set_time(int microseconds);
+
+        /// <summary>
+        /// SET TIME MANUALLY FOR TIMESTAMPED PUBLISHED OUTPUTS AND SERVICES
+        /// When a master clock is involed(e.g.linked to an input of an agent), it
+        /// is possible to override the automatic timestamp mechanism to force a value
+        /// for the current time in microseconds.
+        /// Once igs_rt_set_time has been called, it is necessary to continue calling it
+        /// periodically and manually to update the agent's current time in microseconds.
+        /// NB : a call to igs_rt_set_time autmatically enables timestamps for outputs
+        /// and services on all agents in our process.Timestamps cannot be disabled afterwards.
+        /// NB : igs_rt_set_time and igs_rt_time operate at peer level for all the agents
+        /// in the process. All agents in a process use the same time set by igs_rt_set_time.
+        /// </summary>
+        public static void RtSetTime(int microseconds) { igs_rt_set_time(microseconds); }
+
+        [DllImport(ingescapeDLLPath, CallingConvention = CallingConvention.Cdecl)]
+        private static extern int igs_rt_time();
+        public static int RtTime() { return igs_rt_time(); }
+        #endregion
+
         #region Administration, logging, configuration and utilities
 
         #region LOG ALIASES

bindings/csharp/test/src/test.cs

@@ -602,10 +602,10 @@ public void Tester()
             Assert.IsTrue(Igs.OutputType("my_data") == IopValueType.Data);
             Assert.IsTrue(Igs.OutputExists("my_data"));
             Assert.IsTrue(!Igs.OutputBool("my_bool"));
-            Assert.IsTrue(Igs.OutputInt("my_int") == 2);
-            Assert.IsTrue(Igs.OutputDouble("my_double") - 2.0 < 0.000001);
+            Assert.IsTrue(Igs.OutputInt("my_int") == 0);
+            Assert.IsTrue(Igs.OutputDouble("my_double") == 0.0);
             outputString = Igs.OutputString("my_string");
-            Assert.AreEqual(outputString, "new string");
+            Assert.AreEqual(outputString, "");
             Assert.IsTrue(Igs.OutputData("my_data").Length == 0);
             listOfStrings = Igs.ParameterList();
             Assert.IsTrue(listOfStrings != null && listOfStrings.Length == 6);
@@ -624,10 +624,10 @@ public void Tester()
             Assert.IsTrue(Igs.ParameterType("my_data") == IopValueType.Data);
             Assert.IsTrue(Igs.ParameterExists("my_data"));
             Assert.IsTrue(!Igs.ParameterBool("my_bool"));
-            Assert.IsTrue(Igs.ParameterInt("my_int") == 2);
-            Assert.IsTrue(Igs.ParameterDouble("my_double") - 2.0 < 0.000001);
+            Assert.IsTrue(Igs.ParameterInt("my_int") == 0);
+            Assert.IsTrue(Igs.ParameterDouble("my_double") == 0);
             parameterString = Igs.ParameterString("my_string");
-            Assert.AreEqual(parameterString, "new string");
+            Assert.AreEqual(parameterString, "");
             parameterString = null;
             Assert.IsTrue(Igs.ParameterData("my_data").Length == 0);
             Igs.ClearDefinition();
@@ -670,10 +670,10 @@ public void Tester()
             Assert.IsTrue(Igs.OutputType("my_data") == IopValueType.Data);
             Assert.IsTrue(Igs.OutputExists("my_data"));
             Assert.IsTrue(!Igs.OutputBool("my_bool"));
-            Assert.IsTrue(Igs.OutputInt("my_int") == 2);
-            Assert.IsTrue(Igs.OutputDouble("my_double") - 2.0 < 0.000001);
+            Assert.IsTrue(Igs.OutputInt("my_int") == 0);
+            Assert.IsTrue(Igs.OutputDouble("my_double") == 0);
             outputString = Igs.OutputString("my_string");
-            Assert.AreEqual(outputString, "new string");
+            Assert.AreEqual(outputString, "");
             outputString = null;
             data = null;
             Assert.IsTrue(Igs.OutputData("my_data").Length == 0);
@@ -695,10 +695,10 @@ public void Tester()
             Assert.IsTrue(Igs.ParameterType("my_data") == IopValueType.Data);
             Assert.IsTrue(Igs.ParameterExists("my_data"));
             Assert.IsTrue(!Igs.ParameterBool("my_bool"));
-            Assert.IsTrue(Igs.ParameterInt("my_int") == 2);
-            Assert.IsTrue(Igs.ParameterDouble("my_double") - 2.0 < 0.000001);
+            Assert.IsTrue(Igs.ParameterInt("my_int") == 0);
+            Assert.IsTrue(Igs.ParameterDouble("my_double") == 0);
             parameterString = Igs.ParameterString("my_string");
-            Assert.AreEqual(parameterString, "new string");
+            Assert.AreEqual(parameterString, "");
             parameterString = null;
             data = null;
             Assert.IsTrue(Igs.ParameterData("my_data").Length == 0);
@@ -1405,6 +1405,15 @@ public void Tester()
 
             FirstAgent.Destroy();
             SecondAgent.Destroy();
+
+            Igs.RtSetTimestamps(true);
+            Assert.IsTrue(Igs.RtTimestamps());
+            Assert.IsTrue(Igs.RtGetCurrentTimestamp() == 0);
+
+            Igs.RtSetTimestamps(false);
+            Igs.RtSetTime(1000);
+            Igs.RtSetTimestamps(true);
+            Assert.IsTrue(Igs.RtTime() == 1000);
         }
 
         [TestCleanup]