Skip to content

Commit 2ce74a4

Browse files
committed
Renamed owner to OwnerReplica
1 parent e46a135 commit 2ce74a4

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/FunctionTests/SunshineTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -741,8 +741,8 @@ public async Task ExecutingFunctionHasOwner(Task<IFunctionStore> storeTask)
741741
await insideFlag.WaitForRaised();
742742

743743
var cp = await registration.ControlPanel(flowId.Instance).ShouldNotBeNullAsync();
744-
cp.Owner.ShouldNotBeNull();
745-
cp.Owner.ShouldBe(functionsRegistry.ClusterInfo.ReplicaId);
744+
cp.OwnerReplica.ShouldNotBeNull();
745+
cp.OwnerReplica.ShouldBe(functionsRegistry.ClusterInfo.ReplicaId);
746746

747747
completeFlag.Raise();
748748
await flowTask;

Core/Cleipnir.ResilientFunctions/Domain/ControlPanel.cs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ internal ControlPanel(
1515
Invoker<Unit, Unit> invoker,
1616
InvocationHelper<Unit, Unit> invocationHelper,
1717
FlowId flowId, StoredId storedId,
18-
ReplicaId? owner,
18+
ReplicaId? ownerReplica,
1919
Status status, int epoch, long expires,
2020
ExistingEffects effects,
2121
ExistingStates states, ExistingMessages messages, ExistingSemaphores semaphores,
@@ -24,7 +24,7 @@ internal ControlPanel(
2424
UtcNow utcNow
2525
) : base(
2626
invoker, invocationHelper,
27-
flowId, storedId, owner, status, epoch,
27+
flowId, storedId, ownerReplica, status, epoch,
2828
expires, innerParam: Unit.Instance, innerResult: Unit.Instance, effects,
2929
states, messages, registeredTimeouts, semaphores, correlations, fatalWorkflowException,
3030
utcNow
@@ -59,7 +59,7 @@ internal ControlPanel(
5959
Invoker<TParam, Unit> invoker,
6060
InvocationHelper<TParam, Unit> invocationHelper,
6161
FlowId flowId, StoredId storedId,
62-
ReplicaId? owner,
62+
ReplicaId? ownerReplica,
6363
Status status, int epoch, long expires, TParam innerParam,
6464
ExistingEffects effects,
6565
ExistingStates states, ExistingMessages messages, ExistingSemaphores semaphores,
@@ -68,7 +68,7 @@ internal ControlPanel(
6868
UtcNow utcNow
6969
) : base(
7070
invoker, invocationHelper,
71-
flowId, storedId, owner, status, epoch,
71+
flowId, storedId, ownerReplica, status, epoch,
7272
expires, innerParam, innerResult: Unit.Instance, effects,
7373
states, messages, registeredTimeouts, semaphores, correlations, fatalWorkflowException,
7474
utcNow
@@ -108,15 +108,15 @@ public class ControlPanel<TParam, TReturn> : BaseControlPanel<TParam, TReturn> w
108108
internal ControlPanel(
109109
Invoker<TParam, TReturn> invoker,
110110
InvocationHelper<TParam, TReturn> invocationHelper,
111-
FlowId flowId, StoredId storedId, ReplicaId? owner, Status status, int epoch,
111+
FlowId flowId, StoredId storedId, ReplicaId? ownerReplica, Status status, int epoch,
112112
long expires, TParam innerParam,
113113
TReturn? innerResult,
114114
ExistingEffects effects, ExistingStates states, ExistingMessages messages, ExistingSemaphores semaphores,
115115
ExistingRegisteredTimeouts registeredTimeouts, Correlations correlations, FatalWorkflowException? fatalWorkflowException,
116116
UtcNow utcNow
117117
) : base(
118118
invoker, invocationHelper,
119-
flowId, storedId, owner, status, epoch, expires,
119+
flowId, storedId, ownerReplica, status, epoch, expires,
120120
innerParam, innerResult, effects, states, messages,
121121
registeredTimeouts, semaphores, correlations, fatalWorkflowException,
122122
utcNow
@@ -163,7 +163,7 @@ internal BaseControlPanel(
163163
InvocationHelper<TParam, TReturn> invocationHelper,
164164
FlowId flowId,
165165
StoredId storedId,
166-
ReplicaId? owner,
166+
ReplicaId? ownerReplica,
167167
Status status,
168168
int epoch,
169169
long expires,
@@ -182,7 +182,7 @@ internal BaseControlPanel(
182182
_invocationHelper = invocationHelper;
183183
FlowId = flowId;
184184
StoredId = storedId;
185-
Owner = owner;
185+
OwnerReplica = ownerReplica;
186186
Status = status;
187187
Epoch = epoch;
188188
LeaseExpiration = expires == long.MaxValue
@@ -204,7 +204,7 @@ internal BaseControlPanel(
204204

205205
public FlowId FlowId { get; }
206206
public StoredId StoredId { get; }
207-
public ReplicaId? Owner { get; }
207+
public ReplicaId? OwnerReplica { get; }
208208
public Status Status { get; private set; }
209209
protected UtcNow UtcNow { get; }
210210

0 commit comments

Comments
 (0)