Added a Timeout property.

mgnsm · May 10, 2022 · 0f0f4aa · 0f0f4aa
1 parent 00790d9
commit 0f0f4aa
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 1 deletion.
diff --git a/Source/Millistream.Streaming/MDF_OPTION.cs b/Source/Millistream.Streaming/MDF_OPTION.cs
@@ -21,6 +21,7 @@ internal enum MDF_OPTION
 		MDF_OPT_CRYPT_DIGESTS,
 		MDF_OPT_CRYPT_CIPHERS,
 		MDF_OPT_CRYPT_DIGEST,
-		MDF_OPT_CRYPT_CIPHER
+		MDF_OPT_CRYPT_CIPHER,
+		MDF_OPT_TIMEOUT
 	};
 }
diff --git a/Source/Millistream.Streaming/MarketDataFeed.cs b/Source/Millistream.Streaming/MarketDataFeed.cs
@@ -324,6 +324,13 @@ public string Ciphers
         /// <exception cref="InvalidOperationException">The native value of the <see cref="MDF_OPTION.MDF_OPT_CRYPT_CIPHER"/> option cannot be fetched.</exception>
         /// <exception cref="ObjectDisposedException">The <see cref="MarketDataFeed{TCallbackData,TStatusCallbackData}"/> instance has been disposed.</exception>
         public string Cipher => GetStringProperty(MDF_OPTION.MDF_OPT_CRYPT_CIPHER);
+
+        /// <summary>
+        /// Returns the number of seconds to wait before having to call <see cref="Consume(int)"/>.
+        /// </summary>
+        /// <exception cref="InvalidOperationException">The native value of the <see cref="MDF_OPTION.MDF_OPT_TIMEOUT"/> option cannot be fetched.</exception>
+        /// <exception cref="ObjectDisposedException">The <see cref="MarketDataFeed{TCallbackData,TStatusCallbackData}"/> instance has been disposed.</exception>
+        public int Timeout => GetInt32Property(MDF_OPTION.MDF_OPT_TIMEOUT);
         #endregion
 
         #region Methods

diff --git a/Tests/Millistream.Streaming.IntegrationTests/MarketDataFeedTests.cs b/Tests/Millistream.Streaming.IntegrationTests/MarketDataFeedTests.cs
@@ -113,6 +113,9 @@ public void GetAndSetPropertiesTest()
 
             _ = mdf.TimeDifferenceNs;
 
+            //Timeout
+            _ = mdf.Timeout;
+
             //Allocations
             long allocatedBytes = GetTotalAllocatedBytes();
             _ = mdf.FileDescriptor;
@@ -145,6 +148,8 @@ public void GetAndSetPropertiesTest()
 
             mdf.BindAddress = "abc";
 
+            _ = mdf.Timeout;
+
             Assert.AreEqual(allocatedBytes, GetTotalAllocatedBytes());
         }
 

diff --git a/Tests/Millistream.Streaming.UnitTests/MarketDataFeedTests.cs b/Tests/Millistream.Streaming.UnitTests/MarketDataFeedTests.cs
@@ -384,6 +384,10 @@ public void GetMessageDigestTest() =>
         public void GetCipherTest() =>
             GetStringProperty(MDF_OPTION.MDF_OPT_CRYPT_CIPHER, mdf => mdf.Cipher);
 
+        [TestMethod]
+        public void GetTimeoutTest() =>
+            GetInt32Property(MDF_OPTION.MDF_OPT_TIMEOUT, mdf => mdf.Timeout);
+
         [TestMethod]
         public void GetAndSetDataCallbackTest()
         {
@@ -682,6 +686,10 @@ public void SendTest()
         [ExpectedException(typeof(ObjectDisposedException))]
         public void CannotGetCipherAfterDisposeTest() => _ = GetDisposedMdf().Cipher;
 
+        [TestMethod]
+        [ExpectedException(typeof(ObjectDisposedException))]
+        public void CannotGetTimeoutAfterDisposeTest() => _ = GetDisposedMdf().Timeout;
+
         [TestMethod]
         [ExpectedException(typeof(ObjectDisposedException))]
         public void CannotGetDataCallbackfterDisposeTest() => _ = GetDisposedMdf().DataCallback;