1 write to _inputConnection
System.ServiceModel.Primitives (1)
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (1)
900
_inputConnection
= new ReliableInputConnection();
30 references to _inputConnection
System.ServiceModel.Primitives (30)
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (30)
75
_inputConnection
.Ranges,
76
_inputConnection
.IsLastKnown,
104
Settings.ReliableMessagingVersion, ReliableSession.InputID,
_inputConnection
.Ranges,
105
_inputConnection
.IsLastKnown, bufferRemaining);
148
if (
_inputConnection
.IsLastKnown)
284
if (!
_inputConnection
.IsValid(sequenceNumber, isLast))
299
else if (
_inputConnection
.Ranges.Contains(sequenceNumber))
306
_inputConnection
.Merge(sequenceNumber, isLast);
308
if (
_inputConnection
.AllAdded)
340
&& (Settings.Ordered ||
_inputConnection
.CanMerge(sequenceNumber)))
342
_inputConnection
.Merge(sequenceNumber, isLast);
348
if (
_inputConnection
.AllAdded)
366
if (
_inputConnection
.IsLastKnown || _pendingAcknowledgements == Settings.MaxTransferWindowSize)
388
isTerminateEarly = !
_inputConnection
.Terminate();
419
if (!
_inputConnection
.IsLastKnown)
423
if (
_inputConnection
.SetTerminateSequenceLast(last, out isLastLargeEnough))
434
scheduleShutdown =
_inputConnection
.SetCloseSequenceLast(last);
440
ReliableSession.SetFinalAck(
_inputConnection
.Ranges);
451
isLastConsistent = (last ==
_inputConnection
.Last);
454
if (isTerminate && isLastConsistent &&
_inputConnection
.IsSequenceClosed)
549
ReliableSession.InputID,
_inputConnection
.Ranges, true, GetBufferRemaining());
596
_inputConnection
.Terminate();
627
if (
_inputConnection
!= null)
628
_inputConnection
.Abort(this);
731
await
_inputConnection
.CloseAsync(timeoutHelper.RemainingTime());
901
_inputConnection
.ReliableMessagingVersion = Settings.ReliableMessagingVersion;
944
terminated =
_inputConnection
.Terminate();
1014
if (_deliveryStrategy.EnqueuedCount > 0 ||
_inputConnection
.Ranges.Count > 1)
1053
if (
_inputConnection
!= null)
1055
_inputConnection
.Fault(this);