86 references to RemainingTime
System.ServiceModel.NetFramingBase (77)
System\ServiceModel\Channels\BufferedConnection.cs (5)
148await FlushCoreAsync(timeoutHelper.RemainingTime()); 149timeout = timeoutHelper.RemainingTime(); 173await Connection.WriteAsync(buffer, false, timeoutHelper.RemainingTime()); 194await FlushCoreAsync(timeoutHelper.RemainingTime()); 205_pendingTimeout = TimeoutHelper.Add(_pendingTimeout, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ConnectionPool.cs (10)
140result.CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime()); 177await pool.CloseAsync(timeoutHelper.RemainingTime()); 197EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 198endpointPool.AddConnection(connection, timeoutHelper.RemainingTime()); 205EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 206return endpointPool.TakeConnection(timeoutHelper.RemainingTime()); 212EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 213endpointPool.ReturnConnection(connection, connectionIsStillGood, timeoutHelper.RemainingTime()); 335var valueTask = CloseItemAsync(itemsToClose[i], timeoutHelper.RemainingTime()); 463CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ConnectionPoolHelper.cs (2)
61localRawConnection = TakeConnection(timeoutHelper.RemainingTime()); 98TimeSpan connectTimeout = timeoutHelper.RemainingTime();
System\ServiceModel\Channels\FramingChannels.cs (12)
226await connection.WriteAsync(preamble, true, timeoutHelper.RemainingTime()); 233await upgradeInitiator.OpenAsync(timeoutHelper.RemainingTime()); 235(upgradeInitiated, connection) = await ConnectionUpgradeHelper.InitiateUpgradeAsync(upgradeInitiator, connection, _decoder, this, timeoutHelper.RemainingTime()); 238await ConnectionUpgradeHelper.DecodeFramingFaultAsync(_decoder, connection, Via, MessageEncoder.ContentType, timeoutHelper.RemainingTime()); 247await upgradeInitiator.CloseAsync(timeoutHelper.RemainingTime()); 249await connection.WriteAsync(SessionEncoder.PreambleEndBytes, true, timeoutHelper.RemainingTime()); 252int ackBytesRead = await connection.ReadAsync(ackBuffer, timeoutHelper.RemainingTime()); 257MessageEncoder.ContentType, timeoutHelper.RemainingTime()); 366return _channel.SendPreambleAsync(connection, _preamble, timeoutHelper.RemainingTime()); 383timeoutHelper.RemainingTime()); 394await ConnectionUtilities.CloseNoThrowAsync(connection, timeoutHelper.RemainingTime()); 409timeoutHelper.RemainingTime());
System\ServiceModel\Channels\IdlingCommunicationPool.cs (1)
222_parent.CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime());
System\ServiceModel\Channels\NetFramingTransportChannelFactory.cs (4)
294ReleaseConnectionPoolAsync(localConnectionPool, timeoutHelper.RemainingTime()).GetAwaiter().GetResult(); 299localUpgrade.Close(timeoutHelper.RemainingTime()); 352await ReleaseConnectionPoolAsync(localConnectionPool, timeoutHelper.RemainingTime()); 357await Task.Factory.FromAsync(localUpgrade.BeginClose, localUpgrade.EndClose, timeoutHelper.RemainingTime(), null);
System\ServiceModel\Channels\SessionConnectionReader.cs (3)
81message = DecodeMessage(timeoutHelper.RemainingTime()); 115bytesRead = await _connection.ReadAsync(new Memory<byte>(EnvelopeBuffer, EnvelopeOffset, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 122bytesRead = await _connection.ReadAsync(new Memory<byte>(_buffer, 0, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime());
System\ServiceModel\Channels\SingletonConnectionReader.cs (9)
96_inputStream.ReadTimeout = TimeoutHelper.ToMilliseconds(timeoutHelper.RemainingTime()); 104OnClose(timeoutHelper.RemainingTime()); 148DoneReceiving(true, timeoutHelper.RemainingTime()); 155size = await Connection.ReadAsync(new Memory<byte>(buffer, 0, Connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 158DoneReceiving(true, timeoutHelper.RemainingTime()); 583await connection.WriteAsync(envelopeStartBytes, false, timeoutHelper.RemainingTime()); 585Stream writeTimeoutStream = new TimeoutStream(connectionStream, timeoutHelper.RemainingTime()); 595messageData.Count + envelopeStartBytes.Length), true, timeoutHelper.RemainingTime()); 606true, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\SslStreamSecurityUpgradeProvider.cs (9)
211await SecurityUtilsEx.OpenTokenAuthenticatorIfRequiredAsync(ClientCertificateAuthenticator, timeoutHelper.RemainingTime()); 215await SecurityUtils.OpenTokenProviderIfRequiredAsync(_serverTokenProvider, timeoutHelper.RemainingTime()); 216SecurityToken token = _serverTokenProvider.GetTokenAsync(timeoutHelper.RemainingTime()).GetAwaiter().GetResult(); 218await SecurityUtils.CloseTokenProviderIfRequiredAsync(_serverTokenProvider, timeoutHelper.RemainingTime()); 331await base.OpenAsync(timeoutHelper.RemainingTime()); 334await SecurityUtils.OpenTokenProviderIfRequiredAsync(_clientCertificateProvider, timeoutHelper.RemainingTime()); 335_clientToken = (X509SecurityToken)await _clientCertificateProvider.GetTokenAsync(timeoutHelper.RemainingTime()); 342await base.CloseAsync(timeoutHelper.RemainingTime()); 345await SecurityUtils.CloseTokenProviderIfRequiredAsync(_clientCertificateProvider, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\StreamedFramingRequestChannel.cs (8)
73await connection.WriteAsync(Preamble, true, timeoutHelper.RemainingTime()); 81(upgradeInitiated, connection)= await ConnectionUpgradeHelper.InitiateUpgradeAsync(upgradeInitiator, connection, decoder, this, timeoutHelper.RemainingTime()); 84await ConnectionUpgradeHelper.DecodeFramingFaultAsync(decoder, connection, Via, _messageEncoder.ContentType, timeoutHelper.RemainingTime()); 93await connection.WriteAsync(ClientSingletonEncoder.PreambleEndBytes, true, timeoutHelper.RemainingTime()); 97int ackBytesRead = await connection.ReadAsync(ackBuffer, timeoutHelper.RemainingTime()); 102_messageEncoder.ContentType, timeoutHelper.RemainingTime()); 223_connection = await _connectionPoolHelper.EstablishConnectionAsync(timeoutHelper.RemainingTime()); 231new TimeoutException(SR.Format(SR.TimeoutOnRequest, timeoutHelper.RemainingTime()), exception));
System\ServiceModel\Channels\SynchronizedMessageSource.cs (2)
37return await _source.WaitForMessageAsync(timeoutHelper.RemainingTime()); 62return await _source.ReceiveAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (7)
305await CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 310await EnsureInputClosedAsync(timeoutHelper.RemainingTime()); 314CompleteClose(timeoutHelper.RemainingTime()); 426await StartWritingStreamedMessage(message, timeoutHelper.RemainingTime()); 440timeoutHelper.RemainingTime()); 496OnSendCoreAsync(message, timeoutHelper.RemainingTime()).GetAwaiter().GetResult(); 570ReturnConnectionIfNecessary(false, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\WindowsStreamSecurityUpgradeProvider.cs (5)
133await base.OpenAsync(timeoutHelper.RemainingTime()); 134await SecurityUtils.OpenTokenProviderIfRequiredAsync(_clientTokenProvider, timeoutHelper.RemainingTime()); 135(_credential, _impersonationLevel, _allowNtlm) = await WindowsStreamTransportSecurityHelpers.GetSspiCredentialAsync(_clientTokenProvider, timeoutHelper.RemainingTime()); 142await base.CloseAsync(timeoutHelper.RemainingTime()); 143await SecurityUtils.CloseTokenProviderIfRequiredAsync(_clientTokenProvider, timeoutHelper.RemainingTime());
System.ServiceModel.NetNamedPipe (3)
System\ServiceModel\Channels\PipeConnection.cs (1)
288if (!await _atEOFTask.Task.AwaitWithTimeout(timeoutHelper.RemainingTime()))
System\ServiceModel\Channels\PipeConnectionInitiator.cs (2)
42PrepareConnect(remoteUri, timeoutHelper.RemainingTime(), out resolvedAddress, out backoffHelper); 58timeoutHelper.RemainingTime(),
System.ServiceModel.UnixDomainSocket (6)
System\ServiceModel\Channels\SocketConnection.cs (6)
204ConvertReceiveException(socketException, timeoutHelper.RemainingTime(), timeout)); 283ConvertSendException(socketException, timeoutHelper.RemainingTime(), timeout)); 327Shutdown(_closeTimeoutHelper.RemainingTime()); 328_readFinTimeout = _closeTimeoutHelper.RemainingTime(); 350_socket.Close(TimeoutHelper.ToMilliseconds(_closeTimeoutHelper.RemainingTime())); 848if (timeoutHelper.RemainingTime() == TimeSpan.Zero)