335 references to RemainingTime
System.ServiceModel.Http (32)
System\ServiceModel\Channels\ClientWebSocketTransportDuplexSessionChannel.cs (4)
74await ConfigureClientWebSocketAsync(clientWebSocket, helper.RemainingTime()); 152helper.RemainingTime()); 157SecurityTokenProvider certificateProvider = await httpsChannelFactory.CreateAndOpenCertificateTokenProviderAsync(RemoteAddress, Via, channelParameterCollection, helper.RemainingTime()); 203helper.RemainingTime());
System\ServiceModel\Channels\HttpChannelFactory.cs (8)
745SecurityTokenProviderContainer tokenProvider = await CreateAndOpenTokenProviderAsync(timeoutHelper.RemainingTime(), AuthenticationScheme, to, via, channelParameters); 749proxyTokenProvider = await CreateAndOpenTokenProviderAsync(timeoutHelper.RemainingTime(), ProxyFactory.AuthenticationScheme, to, via, channelParameters); 832(_tokenProvider, _proxyTokenProvider) = await Factory.CreateAndOpenTokenProvidersAsync(RemoteAddress, Via, ChannelParameters, timeoutHelper.RemainingTime()); 841_tokenProvider.Close(timeoutHelper.RemainingTime()); 904CloseTokenProviders(timeoutHelper.RemainingTime()); 905await WaitForPendingRequestsAsync(timeoutHelper.RemainingTime()); 924(requestTokenProvider, requestProxyTokenProvider) = await Factory.CreateAndOpenTokenProvidersAsync(to, via, ChannelParameters, timeoutHelper.RemainingTime()); 934return await Factory.GetHttpClientAsync(to, via, requestTokenProvider, requestProxyTokenProvider, clientCertificateToken, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\HttpsChannelFactory.cs (8)
174requestCertificateProvider = await CreateAndOpenCertificateTokenProviderAsync(to, via, channelParameters, timeoutHelper.RemainingTime()); 183token = await requestCertificateProvider.GetTokenAsync(timeoutHelper.RemainingTime()); 363await CreateAndOpenTokenProviderAsync(timeoutHelper.RemainingTime()); 364await base.OnOpenAsync(timeoutHelper.RemainingTime()); 376CloseTokenProvider(timeoutHelper.RemainingTime()); 377return base.OnBeginClose(timeoutHelper.RemainingTime(), callback, state); 383CloseTokenProvider(timeoutHelper.RemainingTime()); 384base.OnClose(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\SynchronizedMessageSource.cs (2)
39return await _source.WaitForMessageAsync(timeoutHelper.RemainingTime()); 64return await _source.ReceiveAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (7)
354await CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 359await EnsureInputClosedAsync(timeoutHelper.RemainingTime()); 363CompleteClose(timeoutHelper.RemainingTime()); 480completionResult = StartWritingStreamedMessage(message, timeoutHelper.RemainingTime(), s_onWriteComplete, tcs); 494timeoutHelper.RemainingTime(), 578OnSendCore(message, timeoutHelper.RemainingTime()); 652ReturnConnectionIfNecessary(false, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (3)
274task.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1156task.Wait(timeoutHelper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1245receiveTask.Wait(closeTimeoutHelper.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.NetTcp (6)
System\ServiceModel\Channels\SocketConnection.cs (6)
222ConvertReceiveException(socketException, timeoutHelper.RemainingTime(), timeout)); 304ConvertSendException(socketException, timeoutHelper.RemainingTime(), timeout)); 348Shutdown(_closeTimeoutHelper.RemainingTime()); 349_readFinTimeout = _closeTimeoutHelper.RemainingTime(); 371_socket.Close(TimeoutHelper.ToMilliseconds(_closeTimeoutHelper.RemainingTime())); 953if (timeoutHelper.RemainingTime() == TimeSpan.Zero)
System.ServiceModel.Primitives (211)
Internals\System\Runtime\TimeoutHelper.cs (2)
44var timeout = RemainingTime(); 171return OriginalTimeout - RemainingTime();
System\ServiceModel\Channels\ChannelFactoryBase.cs (4)
184channel.Close(timeoutHelper.RemainingTime()); 187_channels.Close(timeoutHelper.RemainingTime()); 211await CloseOtherAsync(channel, timeoutHelper.RemainingTime()); 218await _channels.CloseAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ClientReliableChannelBinder.cs (2)
153(bool success, TChannel channel) = await Synchronizer.TryGetChannelForOutputAsync(timeoutHelper.RemainingTime(), maskingMode); 173return await OnRequestAsync(channel, message, timeoutHelper.RemainingTime(),
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (15)
195await OutputConnection.CloseAsync(timeoutHelper.RemainingTime()); 199await CloseSequenceAsync(timeoutHelper.RemainingTime()); 202await TerminateSequenceAsync(timeoutHelper.RemainingTime()); 724await _closeOutputWaitObject.WaitAsync(timeoutHelper.RemainingTime()); 728await InternalCloseOutputSessionAsync(timeoutHelper.RemainingTime()); 731await _inputConnection.CloseAsync(timeoutHelper.RemainingTime()); 734await _guard.CloseAsync(timeoutHelper.RemainingTime()); 735await ReliableSession.CloseAsync(timeoutHelper.RemainingTime()); 736await Binder.CloseAsync(timeoutHelper.RemainingTime(), MaskingMode.Handled); 737await base.OnCloseAsync(timeoutHelper.RemainingTime()); 1156await Binder.OpenAsync(timeoutHelper.RemainingTime()); 1157await ReliableSession.OpenAsync(timeoutHelper.RemainingTime()); 1164await Binder.CloseAsync(timeoutHelper.RemainingTime()); 1231TimeSpan timeout = _closing ? _closeTimeoutHelper.RemainingTime() : DefaultCloseTimeout; 1263timeout = TimeoutHelper.Divide(_closeTimeoutHelper.RemainingTime(), 2);
System\ServiceModel\Channels\CloseCollectionAsyncResult.cs (1)
38result = collection[index].BeginClose(timeoutHelper.RemainingTime(), s_nestedCallback, callbackState);
System\ServiceModel\Channels\CommunicationObject.cs (2)
274await OnCloseAsyncInternal(actualTimeout.RemainingTime()); 534await OnOpenAsyncInternal(actualTimeout.RemainingTime());
System\ServiceModel\Channels\LayeredChannelFactory.cs (9)
60await base.OnCloseAsync(timeoutHelper.RemainingTime()); 61await InnerChannelFactory.CloseHelperAsync(timeoutHelper.RemainingTime()); 67base.OnClose(timeoutHelper.RemainingTime()); 68InnerChannelFactory.Close(timeoutHelper.RemainingTime()); 286await base.OnCloseAsync(timeoutHelper.RemainingTime()); 298await base.OnOpenAsync(timeoutHelper.RemainingTime()); 299await _innerOutputChannel.OpenHelperAsync(timeoutHelper.RemainingTime()); 305base.OnOpen(timeoutHelper.RemainingTime()); 306_innerOutputChannel.Open(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\OpenCollectionAsyncResult.cs (1)
42IAsyncResult result = collection[index].BeginOpen(_timeoutHelper.RemainingTime(), s_nestedCallback, callbackState);
System\ServiceModel\Channels\ReliableChannelBinder.cs (18)
255await OnCloseAsync(timeoutHelper.RemainingTime()); 259await CloseChannelAsync(channel, timeoutHelper.RemainingTime()); 618(bool success, TChannel channel) = await Synchronizer.TryGetChannelForOutputAsync(timeoutHelper.RemainingTime(), maskingMode); 639await OnSendAsync(channel, message, timeoutHelper.RemainingTime()); 751CanGetChannelForReceive, timeoutHelper.RemainingTime()); 764(success, requestContext) = await OnTryReceiveAsync(channel, timeoutHelper.RemainingTime()); 1786_timeoutHelper.RemainingTime())) 1810await channel.OpenHelperAsync(_timeoutHelper.RemainingTime()); 1857if (!await _tcs.Task.AwaitWithTimeout(_timeoutHelper.RemainingTime())) 2009await ((ISessionChannel<IAsyncDuplexSession>)channel).Session.CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 2010await binder.WaitForPendingOperationsAsync(timeoutHelper.RemainingTime()); 2012TimeSpan iterationTimeout = timeoutHelper.RemainingTime(); 2035await channel.CloseHelperAsync(timeoutHelper.RemainingTime()); 2078iterationTimeout = timeoutHelper.RemainingTime(); 2091await binder.WaitForPendingOperationsAsync(timeoutHelper.RemainingTime()); 2093TimeSpan iterationTimeout = timeoutHelper.RemainingTime(); 2109await channel.CloseHelperAsync(timeoutHelper.RemainingTime()); 2153iterationTimeout = timeoutHelper.RemainingTime();
System\ServiceModel\Channels\ReliableChannelFactory.cs (3)
91await base.OnCloseAsync(timeoutHelper.RemainingTime()); 92await FaultHelper.CloseAsync(timeoutHelper.RemainingTime()); 93await InnerChannelFactory.CloseHelperAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ReliableInputConnection.cs (2)
223await _shutdownWaitObject.WaitAsync(timeoutHelper.RemainingTime()); 224await _terminateWaitObject.WaitAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (7)
871lastIteration = remainingTimeout <= iterationTimeout.RemainingTime(); 926TimeSpan requestTimeout = GetNextRequestTimeout(timeoutHelper.RemainingTime(), 966await abortHandle.WaitAsync(iterationTimeoutHelper.RemainingTime()); 1089await Binder.SendAsync(request, timeoutHelper.RemainingTime(), MaskingMode.None); 1090TimeSpan receiveTimeout = GetReceiveTimeout(timeoutHelper.RemainingTime()); 1160await Binder.SendAsync(request, timeoutHelper.RemainingTime(), MaskingMode.None); 1161TimeSpan waitTimeout = GetWaitTimeout(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ReliableOutputConnection.cs (6)
118await CompleteTransferAsync(timeoutHelper.RemainingTime()); 121await _shutdownHandle.WaitAsync(timeoutHelper.RemainingTime()); 122await _sendGuard.CloseAsync(timeoutHelper.RemainingTime()); 147attemptInfo = await Strategy.AddLastAsync(message, helper.RemainingTime(), null); 152(attemptInfo, success) = await Strategy.AddAsync(message, helper.RemainingTime(), state); 179await _sendAsyncHandler(attemptInfo, helper.RemainingTime(), false);
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (8)
247await Connection.CloseAsync(timeoutHelper.RemainingTime()); 251await CloseSequenceAsync(timeoutHelper.RemainingTime()); 254await TerminateSequenceAsync(timeoutHelper.RemainingTime()); 255await _session.CloseAsync(timeoutHelper.RemainingTime()); 256await _binder.CloseAsync(timeoutHelper.RemainingTime(), MaskingMode.Handled); 340await _binder.OpenAsync(timeoutHelper.RemainingTime()); 341await _session.OpenAsync(timeoutHelper.RemainingTime()); 348await Binder.CloseAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (13)
251await connection.CloseAsync(timeoutHelper.RemainingTime()); 252await WaitForShutdownAsync(timeoutHelper.RemainingTime()); 256await CloseSequenceAsync(timeoutHelper.RemainingTime()); 259await TerminateSequenceAsync(timeoutHelper.RemainingTime()); 260await session.CloseAsync(timeoutHelper.RemainingTime()); 261await binder.CloseAsync(timeoutHelper.RemainingTime(), MaskingMode.Handled); 368await binder.OpenAsync(timeoutHelper.RemainingTime()); 369await session.OpenAsync(timeoutHelper.RemainingTime()); 376await binder.CloseAsync(timeoutHelper.RemainingTime()); 675return shutdownHandle.WaitAsync(timeoutHelper.RemainingTime()); 683return replyAckConsistencyGuard.CloseAsync(timeoutHelper.RemainingTime()); 745if (!await _parent.connection.AddMessageAsync(message, timeoutHelper.RemainingTime(), this)) 791expired = !await TaskHelpers.AwaitWithTimeout(_tcs.Task, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\RequestChannel.cs (2)
264TimeSpan savedTimeout = timeoutHelper.RemainingTime(); 275savedTimeout = timeoutHelper.RemainingTime();
System\ServiceModel\Channels\RequestContextBase.cs (2)
139OnReply(null, timeoutHelper.RemainingTime()); 142OnClose(timeoutHelper.RemainingTime());
System\ServiceModel\Channels\SecurityChannelFactory.cs (17)
128await CloseProtocolFactoryAsync(false, timeoutHelper.RemainingTime()); 131await _sessionClientSettings.CloseAsync(timeoutHelper.RemainingTime()); 176await OnOpenCoreAsync(timeoutHelper.RemainingTime()); 177await base.OnOpenAsync(timeoutHelper.RemainingTime()); 228return SessionClientSettings.OpenAsync(this, InnerChannelFactory, ChannelBuilder, timeoutHelper.RemainingTime()); 233return SecurityProtocolFactory.OpenAsync(true, timeoutHelper.RemainingTime()); 289timeoutHelper.RemainingTime()); 291await SecurityProtocol.OpenAsync(timeoutHelper.RemainingTime()); 292await base.OnOpenAsync(timeoutHelper.RemainingTime()); 367message = await SecurityProtocol.SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime()); 370await asyncOutputChannel.SendAsync(message, timeoutHelper.RemainingTime()); 374await Task.Factory.FromAsync(InnerChannel.BeginSend, InnerChannel.EndSend, message, timeoutHelper.RemainingTime(), null); 470(correlationState, message) = await SecurityProtocol.SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime(), null); 471Message reply = await Task.Factory.FromAsync(InnerChannel.BeginRequest, InnerChannel.EndRequest, message, timeoutHelper.RemainingTime(), null); 473return ProcessReply(reply, correlationState, timeoutHelper.RemainingTime()); 619(success, message) = await asyncDuplexChannel.TryReceiveAsync(timeoutHelper.RemainingTime()); 627message = ProcessMessage(message, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\ServiceChannel.cs (7)
742EnsureOpened(rpc.TimeoutHelper.RemainingTime()); 756Binder.Send(rpc.Request, rpc.TimeoutHelper.RemainingTime()); 760rpc.Reply = Binder.Request(rpc.Request, rpc.TimeoutHelper.RemainingTime()); 1311await CloseOtherAsync(InnerChannel, timeoutHelper.RemainingTime()); 1316await CloseOtherAsync(Factory, timeoutHelper.RemainingTime()); 1769TimeSpan timeout = _rpc.TimeoutHelper.RemainingTime(); 1835TimeSpan timeout = _rpc.TimeoutHelper.RemainingTime();
System\ServiceModel\Channels\ServiceChannelFactory.cs (7)
258channel.Close(timeoutHelper.RemainingTime()); 413await CloseOtherAsync(channel, timeoutHelper.RemainingTime()); 455base.OnClose(timeoutHelper.RemainingTime()); 456InnerChannelFactory.Close(timeoutHelper.RemainingTime()); 500await TaskHelpers.CallActionAsync(base.OnClose, timeoutHelper.RemainingTime()); 504await Task.Factory.FromAsync(base.OnBeginClose, base.OnEndClose, timeoutHelper.RemainingTime(), TaskCreationOptions.None); 507await CloseOtherAsync(InnerChannelFactory, timeoutHelper.RemainingTime());
System\ServiceModel\ClientBase.cs (8)
319await GetChannelFactory().OpenHelperAsync(timeoutHelper.RemainingTime()); 322await InnerChannel.OpenHelperAsync(timeoutHelper.RemainingTime()); 380await InnerChannel.CloseHelperAsync(timeoutHelper.RemainingTime()); 407await GetChannelFactory().CloseHelperAsync(timeoutHelper.RemainingTime()); 502GetChannelFactory().Open(timeoutHelper.RemainingTime()); 505InnerChannel.Open(timeoutHelper.RemainingTime()); 520InnerChannel.Close(timeoutHelper.RemainingTime()); 547_channelFactoryRef.Close(timeoutHelper.RemainingTime());
System\ServiceModel\Dispatcher\ChannelDispatcher.cs (4)
260handler.CloseInput(timeoutHelper.RemainingTime()); 269handler.Close(timeoutHelper.RemainingTime()); 390_listener.Close(timeoutHelper.RemainingTime()); 396handler.Close(timeoutHelper.RemainingTime());
System\ServiceModel\Dispatcher\ChannelHandler.cs (2)
576channel.Close(timeoutHelper.RemainingTime()); 588Binder.CloseAfterFault(timeoutHelper.RemainingTime());
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (4)
470_channel.Send(message, timeoutHelper.RemainingTime()); 480TimeSpan remaining = timeoutHelper.RemainingTime(); 521_channel.Send(message, timeoutHelper.RemainingTime()); 523return duplexRequest.WaitForReply(timeoutHelper.RemainingTime());
System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (2)
187rpc.RequestContext.Reply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime()); 227rpc.AsyncResult = rpc.RequestContext.BeginReply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime(),
System\ServiceModel\Dispatcher\ListenerHandler.cs (4)
74await CloseChannelsAsync(timeoutHelper.RemainingTime()); 185channel.Close(timeoutHelper.RemainingTime()); 212closeTasks[index] = CloseChannelAsync(channels[index], timeoutHelper.RemainingTime()); 344CloseChannelsAsync(timeoutHelper.RemainingTime()).WaitForCompletion();
System\ServiceModel\Dispatcher\TerminatingOperationBehavior.cs (1)
61rpc.Channel.Close(rpc.TimeoutHelper.RemainingTime());
System\ServiceModel\Security\IssuanceTokenProviderBase.cs (5)
450negotiationState = await CreateNegotiationStateAsync(_targetAddress, _via, timeoutHelper.RemainingTime()); 452await InitializeChannelFactoriesAsync(negotiationState.RemoteAddress, timeoutHelper.RemainingTime()); 454await rstChannel.OpenAsync(timeoutHelper.RemainingTime()); 470timeLeft = timeoutHelper.RemainingTime(); 488rstChannel.Close(timeoutHelper.RemainingTime());
System\ServiceModel\Security\NegotiationTokenProvider.cs (2)
85await base.OnCloseAsync(timeoutHelper.RemainingTime()); 107await base.OnOpenAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Security\ReceiveSecurityHeader.cs (1)
558ReadToken(reader, AppendPosition, null, null, null, _timeoutHelper.RemainingTime());
System\ServiceModel\Security\SecurityChannel.cs (2)
66await _securityProtocol.CloseAsync(false, timeoutHelper.RemainingTime()); 69await base.OnCloseAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Security\SecurityProtocol.cs (6)
275await SecurityUtils.OpenTokenProviderIfRequiredAsync(spec.TokenProvider, timeoutHelper.RemainingTime()); 340await SecurityUtils.OpenTokenProviderIfRequiredAsync(tokenProviderSpec.TokenProvider, timeoutHelper.RemainingTime()); 354await MergeSupportingTokenProvidersAsync(timeoutHelper.RemainingTime()); 397await SecurityUtils.CloseTokenProviderIfRequiredAsync(spec.TokenProvider, timeoutHelper.RemainingTime()); 405await SecurityUtils.CloseTokenProviderIfRequiredAsync(spec.TokenProvider, timeoutHelper.RemainingTime()); 514supportingToken = await spec.TokenProvider.GetTokenAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Security\SecuritySessionClientSettings.cs (31)
238return _sessionProtocolFactory.OpenAsync(true, timeoutHelper.RemainingTime()); 443_securityProtocol = Settings.SessionProtocolFactory.CreateSecurityProtocol(RemoteAddress, Via, null, true, timeoutHelper.RemainingTime()); 449await _securityProtocol.OpenAsync(timeoutHelper.RemainingTime()); 450await ChannelBinder.OpenAsync(timeoutHelper.RemainingTime()); 482await SecurityUtils.OpenTokenProviderIfRequiredAsync(_sessionTokenProvider, timeoutHelper.RemainingTime()); 486SecurityToken sessionToken = await _sessionTokenProvider.GetTokenAsync(timeoutHelper.RemainingTime()); 489await OpenCoreAsync(sessionToken, timeoutHelper.RemainingTime()); 624(closeCorrelationState, closeMessage) = await _securityProtocol.SecureOutgoingMessageAsync(closeMessage, timeoutHelper.RemainingTime(), null); 625await ChannelBinder.SendAsync(closeMessage, timeoutHelper.RemainingTime()); 644(dummy, message) = await _securityProtocol.SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime(), null); 645await ChannelBinder.SendAsync(message, timeoutHelper.RemainingTime()); 906return ProcessIncomingMessage(message, timeoutHelper.RemainingTime(), correlationState, out dummyProtocolFault); 936requestContext.Close(timeoutHelper.RemainingTime()); 1072await RenewKeyAsync(timeoutHelper.RemainingTime()); 1074return await _securityProtocol.SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime(), null); 1102await ChannelBinder.CloseAsync(timeoutHelper.RemainingTime()); 1106SecurityUtils.CloseTokenProviderIfRequired(_sessionTokenProvider, timeoutHelper.RemainingTime()); 1125(bool success, RequestContext requestContext) = await ChannelBinder.TryReceiveAsync(timeoutHelper.RemainingTime()); 1133Message message = ProcessRequestContext(requestContext, timeoutHelper.RemainingTime(), correlationState); 1141if (timeoutHelper.RemainingTime() == TimeSpan.Zero) 1166await CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 1167bool sessionClosed = await _inputSessionClosedHandle.WaitAsync(timeoutHelper.RemainingTime(), false); 1281if (!await _outputSessionCloseHandle.WaitAsync(timeoutHelper.RemainingTime(), false)) 1299await CloseCoreAsync(timeoutHelper.RemainingTime()); 1447SecurityProtocolCorrelationState correlationState = await base.CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 1449Message message = await ReceiveInternalAsync(timeoutHelper.RemainingTime(), correlationState); 1525(correlationState, message) = await SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime()); 1526Message reply = await ChannelBinder.RequestAsync(message, timeoutHelper.RemainingTime()); 1527return ProcessReply(reply, timeoutHelper.RemainingTime(), correlationState); 1639(dummy, message) = await SecureOutgoingMessageAsync(message, timeoutHelper.RemainingTime()); 1640await ChannelBinder.SendAsync(message, timeoutHelper.RemainingTime());
System\ServiceModel\Security\SecuritySessionSecurityTokenProvider.cs (5)
291await _rstChannelFactory.OpenHelperAsync(timeoutHelper.RemainingTime()); 313await _rstChannelFactory.CloseHelperAsync(timeoutHelper.RemainingTime()); 509await channel.OpenAsync(timeoutHelper.RemainingTime()); 519using (Message reply = await channel.RequestAsync(requestMessage, timeoutHelper.RemainingTime())) 532await channel.CloseAsync(timeoutHelper.RemainingTime());
System\ServiceModel\Security\SecurityUtils.cs (1)
1111thisResult._operationWithTimeout(thisResult._timeoutHelper.RemainingTime());
System\ServiceModel\Security\TransportSecurityProtocol.cs (1)
153securityHeader.Process(timeoutHelper.RemainingTime(), SecurityUtils.GetChannelBindingFromMessage(message), factory.ExtendedProtectionPolicy);
System\ServiceModel\ServiceChannelManager.cs (4)
250CloseInput(timeoutHelper.RemainingTime()); 252base.OnClose(timeoutHelper.RemainingTime()); 258await CloseInputAsync(timeoutHelper.RemainingTime()); 259await base.OnCloseAsync(timeoutHelper.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)