IGNITE-23747 / update client protocol in C#

apache · Dec 14, 2024 · 10b92c7 · 10b92c7
1 parent c1d9d8a
commit 10b92c7
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 1 deletion.
diff --git a/modules/platforms/dotnet/Apache.Ignite.Tests/FakeServer.cs b/modules/platforms/dotnet/Apache.Ignite.Tests/FakeServer.cs
@@ -309,6 +309,7 @@ protected override void Handle(Socket handler, CancellationToken cancellationTok
 
                     case ClientOp.TxBegin:
                         reader.Skip(); // Read only.
+                        reader.Skip(8); // TimeoutMillis.
                         LastClientObservableTimestamp = reader.ReadInt64();
 
                         Send(handler, requestId, new byte[] { 0 }.AsMemory());

diff --git a/modules/platforms/dotnet/Apache.Ignite/Internal/Transactions/LazyTransaction.cs b/modules/platforms/dotnet/Apache.Ignite/Internal/Transactions/LazyTransaction.cs
@@ -197,6 +197,7 @@ void Write()
         {
             var w = writer.MessageWriter;
             w.Write(_options.ReadOnly);
+            w.Write(_options.TimeoutMillis);
             w.Write(failoverSocket.ObservableTimestamp);
         }
     }

diff --git a/modules/platforms/dotnet/Apache.Ignite/Transactions/TransactionOptions.cs b/modules/platforms/dotnet/Apache.Ignite/Transactions/TransactionOptions.cs
@@ -25,4 +25,7 @@ namespace Apache.Ignite.Transactions;
 /// Read-only transactions provide a snapshot view of data at a certain point in time.
 /// They are lock-free and perform better than normal transactions, but do not permit data modifications.
 /// </param>
-public readonly record struct TransactionOptions(bool ReadOnly);
+/// <param name="TimeoutMillis">
+/// Transaction timeout. 0 means 'use default timeout'.
+/// </param>
+public readonly record struct TransactionOptions(bool ReadOnly, long TimeoutMillis = 0);