diff --git a/src/Orleans.Transactions.TestKit.Base/Grains/ITransactionCoordinatorGrain.cs b/src/Orleans.Transactions.TestKit.Base/Grains/ITransactionCoordinatorGrain.cs index e7d0222e81a..b6adae108dc 100644 --- a/src/Orleans.Transactions.TestKit.Base/Grains/ITransactionCoordinatorGrain.cs +++ b/src/Orleans.Transactions.TestKit.Base/Grains/ITransactionCoordinatorGrain.cs @@ -24,7 +24,7 @@ public interface ITransactionCoordinatorGrain : IGrainWithGuidKey Task MultiGrainDoubleByWRWR(List grains, int numberToAdd); [Transaction(TransactionOption.Create)] - Task OrphanCallTransaction(ITransactionTestGrain grain); + Task OrphanCallTransaction(); [Transaction(TransactionOption.Create)] Task AddAndThrow(ITransactionTestGrain grain, int numberToAdd); diff --git a/src/Orleans.Transactions.TestKit.Base/Grains/TransactionCoordinatorGrain.cs b/src/Orleans.Transactions.TestKit.Base/Grains/TransactionCoordinatorGrain.cs index 6d1c38b67fc..0f55f533c08 100644 --- a/src/Orleans.Transactions.TestKit.Base/Grains/TransactionCoordinatorGrain.cs +++ b/src/Orleans.Transactions.TestKit.Base/Grains/TransactionCoordinatorGrain.cs @@ -3,6 +3,7 @@ using System.Linq; using System.Threading.Tasks; using Orleans.Concurrency; +using Orleans.Transactions; using Orleans.Transactions.Abstractions; using Orleans.Transactions.TestKit.Correctnesss; @@ -26,9 +27,9 @@ public Task MultiGrainDouble(List grains) return Task.WhenAll(grains.Select(Double)); } - public Task OrphanCallTransaction(ITransactionTestGrain grain) + public Task OrphanCallTransaction() { - _ = grain.Add(1000); + _ = TransactionContext.GetRequiredTransactionInfo().Fork(); return Task.CompletedTask; } diff --git a/src/Orleans.Transactions.TestKit.Base/TestRunners/GrainFaultTransactionTestRunner.cs b/src/Orleans.Transactions.TestKit.Base/TestRunners/GrainFaultTransactionTestRunner.cs index 6b349b6ff7d..16527a540da 100644 --- a/src/Orleans.Transactions.TestKit.Base/TestRunners/GrainFaultTransactionTestRunner.cs +++ b/src/Orleans.Transactions.TestKit.Base/TestRunners/GrainFaultTransactionTestRunner.cs @@ -145,7 +145,7 @@ public virtual async Task AbortTransactionOnOrphanCalls(string grainStates) ITransactionCoordinatorGrain coordinator = this.grainFactory.GetGrain(Guid.NewGuid()); await grain.Set(expected); - Func task = () => coordinator.OrphanCallTransaction(grain); + Func task = () => coordinator.OrphanCallTransaction(); await task.Should().ThrowAsync(); //await Task.Delay(20000); // give time for GC diff --git a/src/api/Orleans.Transactions.TestKit.Base/Orleans.Transactions.TestKit.Base.cs b/src/api/Orleans.Transactions.TestKit.Base/Orleans.Transactions.TestKit.Base.cs index c9562e915be..aa672cfca44 100644 --- a/src/api/Orleans.Transactions.TestKit.Base/Orleans.Transactions.TestKit.Base.cs +++ b/src/api/Orleans.Transactions.TestKit.Base/Orleans.Transactions.TestKit.Base.cs @@ -323,7 +323,7 @@ public partial interface ITransactionCoordinatorGrain : IGrainWithGuidKey, IGrai [Transaction(TransactionOption.Create)] System.Threading.Tasks.Task MultiGrainSetBit(System.Collections.Generic.List grains, int bitIndex); [Transaction(TransactionOption.Create)] - System.Threading.Tasks.Task OrphanCallTransaction(ITransactionTestGrain grain); + System.Threading.Tasks.Task OrphanCallTransaction(); [Transaction(TransactionOption.Create)] [Concurrency.ReadOnly] System.Threading.Tasks.Task UpdateViolated(ITransactionTestGrain grains, int numberToAdd); @@ -719,7 +719,7 @@ public partial class TransactionCoordinatorGrain : Grain, ITransactionCoordinato public System.Threading.Tasks.Task MultiGrainSetBit(System.Collections.Generic.List grains, int bitIndex) { throw null; } - public System.Threading.Tasks.Task OrphanCallTransaction(ITransactionTestGrain grain) { throw null; } + public System.Threading.Tasks.Task OrphanCallTransaction() { throw null; } public System.Threading.Tasks.Task UpdateViolated(ITransactionTestGrain grain, int numberToAdd) { throw null; } }