1 write to Strategy
System.ServiceModel.Primitives (1)
System\ServiceModel\Channels\ReliableOutputConnection.cs (1)
42
Strategy
= new TransmissionStrategy(reliableMessagingVersion, initialRtt, maxTransferWindowSize, requestAcks, id);
24 references to Strategy
System.ServiceModel.Primitives (24)
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (3)
1193
channel._clientSession.ResumePolling(channel.OutputConnection.
Strategy
.QuotaRemaining == 0);
1200
ReliableSession.OnRemoteActivity(OutputConnection.
Strategy
.QuotaRemaining == 0);
1238
_clientSession.ResumePolling(OutputConnection.
Strategy
.QuotaRemaining == 0);
System\ServiceModel\Channels\ReliableOutputConnection.cs (19)
43
Strategy
.RetryTimeoutElapsed = OnRetryTimeoutElapsed;
44
Strategy
.OnException = RaiseOnException;
52
public long Last =>
Strategy
.Last;
62
Strategy
.Abort(channel);
77
if (
Strategy
.SetLast())
101
return
Strategy
.DoneTransmitting;
123
Strategy
.Close();
130
Strategy
.Fault(channel);
147
attemptInfo = await
Strategy
.AddLastAsync(message, helper.RemainingTime(), null);
152
(attemptInfo, success) = await
Strategy
.AddAsync(message, helper.RemainingTime(), state);
197
return
Strategy
.IsFinalAckConsistent(ranges);
217
Strategy
.DequeuePending();
219
if (
Strategy
.DoneTransmitting)
236
Strategy
.ProcessAcknowledgement(ranges, out invalidAck, out inconsistentAck);
241
if ((transferred > 0) &&
Strategy
.ProcessTransferred(transferred, quotaRemaining))
262
Strategy
.ProcessAcknowledgement(ranges, out invalidAck, out inconsistentAck);
266
if (
Strategy
.ProcessTransferred(ranges, quotaRemaining))
305
MessageAttemptInfo attemptInfo =
Strategy
.GetMessageInfoForRetry(false);
318
Strategy
.DequeuePending();
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (1)
563
_session.OnRemoteActivity(Connection.
Strategy
.QuotaRemaining == 0);
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (1)
585
session.OnRemoteActivity(connection.
Strategy
.QuotaRemaining == 0);