211 references to RemainingTime
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)
299await GetChannelFactory().OpenHelperAsync(timeoutHelper.RemainingTime()); 302await InnerChannel.OpenHelperAsync(timeoutHelper.RemainingTime()); 360await InnerChannel.CloseHelperAsync(timeoutHelper.RemainingTime()); 387await GetChannelFactory().CloseHelperAsync(timeoutHelper.RemainingTime()); 482GetChannelFactory().Open(timeoutHelper.RemainingTime()); 485InnerChannel.Open(timeoutHelper.RemainingTime()); 500InnerChannel.Close(timeoutHelper.RemainingTime()); 527_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)
1104thisResult._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());