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, 104Settings.ReliableMessagingVersion, ReliableSession.InputID, _inputConnection.Ranges, 105_inputConnection.IsLastKnown, bufferRemaining); 148if (_inputConnection.IsLastKnown) 284if (!_inputConnection.IsValid(sequenceNumber, isLast)) 299else if (_inputConnection.Ranges.Contains(sequenceNumber)) 306_inputConnection.Merge(sequenceNumber, isLast); 308if (_inputConnection.AllAdded) 340&& (Settings.Ordered || _inputConnection.CanMerge(sequenceNumber))) 342_inputConnection.Merge(sequenceNumber, isLast); 348if (_inputConnection.AllAdded) 366if (_inputConnection.IsLastKnown || _pendingAcknowledgements == Settings.MaxTransferWindowSize) 388isTerminateEarly = !_inputConnection.Terminate(); 419if (!_inputConnection.IsLastKnown) 423if (_inputConnection.SetTerminateSequenceLast(last, out isLastLargeEnough)) 434scheduleShutdown = _inputConnection.SetCloseSequenceLast(last); 440ReliableSession.SetFinalAck(_inputConnection.Ranges); 451isLastConsistent = (last == _inputConnection.Last); 454if (isTerminate && isLastConsistent && _inputConnection.IsSequenceClosed) 549ReliableSession.InputID, _inputConnection.Ranges, true, GetBufferRemaining()); 596_inputConnection.Terminate(); 627if (_inputConnection != null) 628_inputConnection.Abort(this); 731await _inputConnection.CloseAsync(timeoutHelper.RemainingTime()); 901_inputConnection.ReliableMessagingVersion = Settings.ReliableMessagingVersion; 944terminated = _inputConnection.Terminate(); 1014if (_deliveryStrategy.EnqueuedCount > 0 || _inputConnection.Ranges.Count > 1) 1053if (_inputConnection != null) 1055_inputConnection.Fault(this);