1 write to strategy
System.ServiceModel (1)
System\ServiceModel\Channels\ReliableOutputConnection.cs (1)
51
this.
strategy
= new TransmissionStrategy(reliableMessagingVersion, initialRtt, maxTransferWindowSize,
27 references to strategy
System.ServiceModel (27)
System\ServiceModel\Channels\ReliableOutputConnection.cs (27)
53
this.
strategy
.RetryTimeoutElapsed = OnRetryTimeoutElapsed;
54
this.
strategy
.OnException = RaiseOnException;
112
return this.
strategy
.Last;
136
return this.
strategy
;
149
this.
strategy
.Abort(channel);
164
if (this.
strategy
.SetLast())
204
if (this.
strategy
.SetLast())
274
return this.
strategy
.DoneTransmitting;
296
this.
strategy
.Close();
305
this.
strategy
.DequeuePending();
309
MessageAttemptInfo attemptInfo = this.
strategy
.GetMessageInfoForRetry(true);
350
this.
strategy
.Close();
357
this.
strategy
.Fault(channel);
374
attemptInfo = this.
strategy
.AddLast(message, helper.RemainingTime(), null);
376
else if (!this.
strategy
.Add(message, helper.RemainingTime(), state, out attemptInfo))
419
return this.
strategy
.IsFinalAckConsistent(ranges);
479
this.
strategy
.DequeuePending();
481
if (this.
strategy
.DoneTransmitting)
498
this.
strategy
.ProcessAcknowledgement(ranges, out invalidAck, out inconsistentAck);
503
if ((transferred > 0) && this.
strategy
.ProcessTransferred(transferred, quotaRemaining))
524
this.
strategy
.ProcessAcknowledgement(ranges, out invalidAck, out inconsistentAck);
528
if (this.
strategy
.ProcessTransferred(ranges, quotaRemaining))
566
MessageAttemptInfo attemptInfo = this.
strategy
.GetMessageInfoForRetry(false);
648
result = this.connection.
strategy
.BeginAddLast(message, this.timeoutHelper.RemainingTime(), state, addCompleteStatic, this);
652
result = this.connection.
strategy
.BeginAdd(message, this.timeoutHelper.RemainingTime(), state, addCompleteStatic, this);
713
attemptInfo = this.connection.
strategy
.EndAddLast(result);
715
else if (!this.connection.
strategy
.EndAdd(result, out attemptInfo))