187 references to RemainingTime
dotnet-svcutil-lib (187)
FrameworkFork\System.ServiceModel\Internals\System\Runtime\TimeoutHelper.cs (2)
43var timeout = RemainingTime(); 174return _originalTimeout - this.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedConnection.cs (9)
38Flush(timeoutHelper.RemainingTime()); 39base.Close(timeoutHelper.RemainingTime(), asyncAndLinger); 168FlushCore(timeoutHelper.RemainingTime()); 169timeout = timeoutHelper.RemainingTime(); 195Connection.Write(buffer, offset, size, false, timeoutHelper.RemainingTime()); 216FlushCore(timeoutHelper.RemainingTime()); 228_pendingTimeout = TimeoutHelper.Add(_pendingTimeout, timeoutHelper.RemainingTime()); 241Flush(timeoutHelper.RemainingTime()); 242return base.BeginWrite(buffer, offset, size, immediate, timeoutHelper.RemainingTime(), callback, state);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ChainedAsyncResult.cs (2)
41IAsyncResult result = begin1(_timeoutHelper.RemainingTime(), s_begin1Callback, this); 87result = _begin2(_timeoutHelper.RemainingTime(), s_begin2Callback, this);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ChannelFactoryBase.cs (2)
172channel.Close(timeoutHelper.RemainingTime()); 174_channels.Close(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ClientWebSocketTransportDuplexSessionChannel.cs (1)
85var certificateProvider = httpsChannelFactory.CreateAndOpenCertificateTokenProvider(RemoteAddress, Via, channelParameterCollection, helper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CloseCollectionAsyncResult.cs (1)
37result = collection[index].BeginClose(timeoutHelper.RemainingTime(), s_nestedCallback, callbackState);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CommunicationObject.cs (2)
192await OnCloseAsync(actualTimeout.RemainingTime()); 348TimeSpan remainingTime = actualTimeout.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ConnectionOrientedTransportChannelFactory.cs (4)
265ReleaseConnectionPool(localConnectionPool, timeoutHelper.RemainingTime()); 270localUpgrade.Close(timeoutHelper.RemainingTime()); 321this.ReleaseConnectionPool(localConnectionPool, timeoutHelper.RemainingTime()); 326await ((IAsyncCommunicationObject)localUpgrade).CloseAsync(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ConnectionPool.cs (10)
141result.CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime()); 176pool.Close(timeoutHelper.RemainingTime()); 196EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 197endpointPool.AddConnection(connection, timeoutHelper.RemainingTime()); 204EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 205return endpointPool.TakeConnection(timeoutHelper.RemainingTime()); 211EndpointConnectionPool endpointPool = GetEndpointPool(key, timeoutHelper.RemainingTime()); 212endpointPool.ReturnConnection(connection, connectionIsStillGood, timeoutHelper.RemainingTime()); 342this.CloseItem(itemsToClose[i], timeoutHelper.RemainingTime()); 456CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ConnectionPoolHelper.cs (4)
63localRawConnection = this.TakeConnection(timeoutHelper.RemainingTime()); 100TimeSpan connectTimeout = timeoutHelper.RemainingTime(); 145localRawConnection = this.TakeConnection(timeoutHelper.RemainingTime()); 182TimeSpan connectTimeout = timeoutHelper.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\CoreClrSocketConnection.cs (10)
142thisPtr.ContinueClose(thisPtr._closeTimeoutHelper.RemainingTime()); 235_readFinTimeout = _closeTimeoutHelper.RemainingTime(); 263ContinueClose(_closeTimeoutHelper.RemainingTime()); 287_readFinTimeout = _closeTimeoutHelper.RemainingTime(); 308ContinueClose(_closeTimeoutHelper.RemainingTime()); 535SetWriteTimeout(timeoutHelper.RemainingTime(), true); 540timeout = timeoutHelper.RemainingTime(); 546ConvertSendException(socketException, timeoutHelper.RemainingTime())); 583SetReadTimeout(timeoutHelper.RemainingTime(), true, closing); 589ConvertReceiveException(socketException, timeoutHelper.RemainingTime()));
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\FramingChannels.cs (22)
248await connection.WriteAsync(preamble.Array, preamble.Offset, preamble.Count, true, timeoutHelper.RemainingTime()); 254await upgradeInitiator.OpenAsync(timeoutHelper.RemainingTime()); 257bool upgradeInitiated = await ConnectionUpgradeHelper.InitiateUpgradeAsync(upgradeInitiator, connectionWrapper, _decoder, this, timeoutHelper.RemainingTime()); 261await ConnectionUpgradeHelper.DecodeFramingFaultAsync(_decoder, connection, this.Via, MessageEncoder.ContentType, timeoutHelper.RemainingTime()); 265await upgradeInitiator.CloseAsync(timeoutHelper.RemainingTime()); 267await connection.WriteAsync(ClientDuplexEncoder.PreambleEndBytes, 0, ClientDuplexEncoder.PreambleEndBytes.Length, true, timeoutHelper.RemainingTime()); 270int ackBytesRead = await connection.ReadAsync(ackBuffer, 0, ackBuffer.Length, timeoutHelper.RemainingTime()); 275MessageEncoder.ContentType, timeoutHelper.RemainingTime()); 287connection.Write(preamble.Array, preamble.Offset, preamble.Count, true, timeoutHelper.RemainingTime()); 293upgradeInitiator.Open(timeoutHelper.RemainingTime()); 300upgradeInitiator.Close(timeoutHelper.RemainingTime()); 301connection.Write(ClientDuplexEncoder.PreambleEndBytes, 0, ClientDuplexEncoder.PreambleEndBytes.Length, true, timeoutHelper.RemainingTime()); 305int ackBytesRead = connection.Read(ackBuffer, 0, ackBuffer.Length, timeoutHelper.RemainingTime()); 438return _channel.SendPreambleAsync(connection, _preamble, timeoutHelper.RemainingTime()); 454timeoutHelper.RemainingTime()); 465ConnectionUtilities.CloseNoThrow(connection, timeoutHelper.RemainingTime()); 480timeoutHelper.RemainingTime()); 495int size = connection.Read(faultBuffer, offset, faultBuffer.Length, timeoutHelper.RemainingTime()); 505ConnectionUtilities.CloseNoThrow(connection, timeoutHelper.RemainingTime()); 518size = connection.Read(faultBuffer, offset, faultBuffer.Length, timeoutHelper.RemainingTime()); 535connection.Write(encodedUpgrade.EncodedBytes, 0, encodedUpgrade.EncodedBytes.Length, true, timeoutHelper.RemainingTime()); 539int size = connection.Read(buffer, 0, buffer.Length, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelFactory.cs (6)
649tokenProvider = CreateAndOpenTokenProvider(timeoutHelper.RemainingTime(), AuthenticationScheme, to, via, channelParameters); 734Factory.CreateAndOpenTokenProviders(RemoteAddress, Via, _channelParameters, timeoutHelper.RemainingTime(), out _tokenProvider); 743_tokenProvider.Close(timeoutHelper.RemainingTime()); 807CloseTokenProviders(timeoutHelper.RemainingTime()); 808await WaitForPendingRequestsAsync(timeoutHelper.RemainingTime()); 826Factory.CreateAndOpenTokenProviders(to, via, _channelParameters, timeoutHelper.RemainingTime(),
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpsChannelFactory.cs (9)
141requestCertificateProvider = CreateAndOpenCertificateTokenProvider(to, via, channelParameters, timeoutHelper.RemainingTime()); 281CreateAndOpenTokenProvider(timeoutHelper.RemainingTime()); 282return base.OnBeginOpen(timeoutHelper.RemainingTime(), callback, state); 288CreateAndOpenTokenProvider(timeoutHelper.RemainingTime()); 289base.OnOpen(timeoutHelper.RemainingTime()); 301CloseTokenProvider(timeoutHelper.RemainingTime()); 302return base.OnBeginClose(timeoutHelper.RemainingTime(), callback, state); 308CloseTokenProvider(timeoutHelper.RemainingTime()); 309base.OnClose(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\IdlingCommunicationPool.cs (1)
239_parent.CloseIdleConnection(itemsToClose[i], timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\LayeredChannelFactory.cs (6)
63base.OnClose(timeoutHelper.RemainingTime()); 64_innerChannelFactory.Close(timeoutHelper.RemainingTime()); 224_innerOutputChannel.Close(timeoutHelper.RemainingTime()); 225base.OnClose(timeoutHelper.RemainingTime()); 241base.OnOpen(timeoutHelper.RemainingTime()); 242_innerOutputChannel.Open(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\OpenCollectionAsyncResult.cs (1)
38IAsyncResult result = collection[index].BeginOpen(_timeoutHelper.RemainingTime(), s_nestedCallback, callbackState);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\RequestChannel.cs (2)
277TimeSpan savedTimeout = timeoutHelper.RemainingTime(); 288savedTimeout = timeoutHelper.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\RequestContextBase.cs (2)
153OnReply(null, timeoutHelper.RemainingTime()); 156OnClose(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceChannel.cs (9)
747EnsureOpened(rpc.TimeoutHelper.RemainingTime()); 761_binder.Send(rpc.Request, rpc.TimeoutHelper.RemainingTime()); 765rpc.Reply = _binder.Request(rpc.Request, rpc.TimeoutHelper.RemainingTime()); 1295await asyncInnerChannel.CloseAsync(timeoutHelper.RemainingTime()); 1299InnerChannel.Close(timeoutHelper.RemainingTime()); 1308await asyncFactory.CloseAsync(timeoutHelper.RemainingTime()); 1312_factory.Close(timeoutHelper.RemainingTime()); 1732TimeSpan timeout = Rpc.TimeoutHelper.RemainingTime(); 1798TimeSpan timeout = Rpc.TimeoutHelper.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceChannelFactory.cs (3)
265channel.Close(timeoutHelper.RemainingTime()); 437base.OnClose(timeoutHelper.RemainingTime()); 438_innerChannelFactory.Close(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SessionConnectionReader.cs (5)
121message = DecodeMessage(timeoutHelper.RemainingTime()); 148var result = _connection.BeginRead(0, _buffer.Length, timeoutHelper.RemainingTime(), TaskHelpers.OnAsyncCompletionCallback, tcs); 179message = DecodeMessage(timeoutHelper.RemainingTime()); 207bytesRead = _connection.Read(EnvelopeBuffer, EnvelopeOffset, _buffer.Length, timeoutHelper.RemainingTime()); 212bytesRead = _connection.Read(_buffer, 0, _buffer.Length, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SocketConnection.cs (2)
551if (timeoutHelper.RemainingTime() == TimeSpan.Zero) 603if (timeoutHelper.RemainingTime() == TimeSpan.Zero)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SslStreamSecurityUpgradeProvider.cs (13)
283SecurityUtils.OpenTokenAuthenticatorIfRequired(this.ClientCertificateAuthenticator, timeoutHelper.RemainingTime()); 287SecurityUtils.OpenTokenProviderIfRequired(_serverTokenProvider, timeoutHelper.RemainingTime()); 290SecurityUtils.CloseTokenProviderIfRequired(_serverTokenProvider, timeoutHelper.RemainingTime()); 521base.Open(timeoutHelper.RemainingTime()); 524SecurityUtils.OpenTokenProviderIfRequired(_clientCertificateProvider, timeoutHelper.RemainingTime()); 525using (CancellationTokenSource cts = new CancellationTokenSource(timeoutHelper.RemainingTime())) 535await base.OpenAsync(timeoutHelper.RemainingTime()); 538SecurityUtils.OpenTokenProviderIfRequired(_clientCertificateProvider, timeoutHelper.RemainingTime()); 539using (CancellationTokenSource cts = new CancellationTokenSource(timeoutHelper.RemainingTime())) 549base.Close(timeoutHelper.RemainingTime()); 552SecurityUtils.CloseTokenProviderIfRequired(_clientCertificateProvider, timeoutHelper.RemainingTime()); 559await base.CloseAsync(timeoutHelper.RemainingTime()); 562SecurityUtils.CloseTokenProviderIfRequired(_clientCertificateProvider, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SynchronizedMessageSource.cs (4)
39return await _source.WaitForMessageAsync(timeoutHelper.RemainingTime()); 64return _source.WaitForMessage(timeoutHelper.RemainingTime()); 89return await _source.ReceiveAsync(timeoutHelper.RemainingTime()); 114return _source.Receive(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (10)
401await this.CloseOutputSessionAsync(timeoutHelper.RemainingTime()); 406await this.EnsureInputClosedAsync(timeoutHelper.RemainingTime()); 410this.CompleteClose(timeoutHelper.RemainingTime()); 416this.CloseOutputSession(timeoutHelper.RemainingTime()); 421this.EnsureInputClosed(timeoutHelper.RemainingTime()); 425this.CompleteClose(timeoutHelper.RemainingTime()); 537completionResult = this.StartWritingStreamedMessage(message, timeoutHelper.RemainingTime(), s_onWriteComplete, this); 551timeoutHelper.RemainingTime(), 635this.OnSendCore(message, timeoutHelper.RemainingTime()); 722this.ReturnConnectionIfNecessary(false, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportSecurityHelpers.cs (2)
60SecurityUtils.OpenTokenProviderIfRequired(tokenProvider, timeoutHelper.RemainingTime()); 79SecurityUtils.CloseTokenProviderIfRequired(tokenProvider, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (3)
295task.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1184task.Wait(timeoutHelper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1273receiveTask.Wait(closeTimeoutHelper.RemainingTime(),
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WindowsStreamSecurityUpgradeProvider.cs (4)
293base.Open(timeoutHelper.RemainingTime()); 298SecurityUtils.OpenTokenProviderIfRequired(_clientTokenProvider, timeoutHelper.RemainingTime()); 319base.Close(timeoutHelper.RemainingTime()); 320SecurityUtils.CloseTokenProviderIfRequired(_clientTokenProvider, timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\ClientBase.cs (4)
196_channelFactory.Open(timeoutHelper.RemainingTime()); 197InnerChannel.Open(timeoutHelper.RemainingTime()); 212InnerChannel.Close(timeoutHelper.RemainingTime()); 215_channelFactory.Close(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Description\MetadataExchangeClient.cs (2)
1032((IClientChannel)metadataClient).OperationTimeout = timeoutHelper.RemainingTime(); 1090((IClientChannel)metadataClient).OperationTimeout = timeoutHelper.RemainingTime();
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ChannelDispatcher.cs (4)
279handler.CloseInput(timeoutHelper.RemainingTime()); 288handler.Close(timeoutHelper.RemainingTime()); 409_listener.Close(timeoutHelper.RemainingTime()); 415handler.Close(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ChannelHandler.cs (2)
584channel.Close(timeoutHelper.RemainingTime()); 596_binder.CloseAfterFault(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (4)
472_channel.Send(message, timeoutHelper.RemainingTime()); 482TimeSpan remaining = timeoutHelper.RemainingTime(); 521_channel.Send(message, timeoutHelper.RemainingTime()); 523return duplexRequest.WaitForReply(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (2)
121rpc.RequestContext.Reply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime()); 161rpc.AsyncResult = rpc.RequestContext.BeginReply(rpc.Reply, rpc.ReplyTimeoutHelper.RemainingTime(),
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ListenerHandler.cs (6)
232channel.Close(timeoutHelper.RemainingTime()); 274CloseChannel(channels[index], timeoutHelper.RemainingTime()); 392this.CloseChannels(timeoutHelper.RemainingTime()); 395return _channelDispatcher.Channels.BeginClose(timeoutHelper.RemainingTime(), callback, state); 409this.CloseChannels(timeoutHelper.RemainingTime()); 412_channelDispatcher.Channels.Close(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\InstanceContext.cs (1)
306IAsyncResult result = _instanceContext._channels.BeginClose(_timeoutHelper.RemainingTime(), PrepareAsyncCompletion(new AsyncCompletion(CloseChannelsCallback)), this);
FrameworkFork\System.ServiceModel\System\ServiceModel\Security\SecurityChannel.cs (2)
89_securityProtocol.Close(false, timeoutHelper.RemainingTime()); 91base.OnClose(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Security\SecurityProtocolFactory.cs (5)
675SecurityUtils.CloseTokenAuthenticatorIfRequired(spec.TokenAuthenticator, timeoutHelper.RemainingTime()); 682SecurityUtils.CloseTokenAuthenticatorIfRequired(spec.TokenAuthenticator, timeoutHelper.RemainingTime()); 818SecurityUtils.OpenTokenAuthenticatorIfRequired(spec.TokenAuthenticator, timeoutHelper.RemainingTime()); 982SecurityUtils.OpenTokenAuthenticatorIfRequired(tokenAuthenticatorSpec.TokenAuthenticator, timeoutHelper.RemainingTime()); 1012MergeSupportingTokenAuthenticators(timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\Security\SecurityUtils.cs (1)
1078thisResult._operationWithTimeout(thisResult._timeoutHelper.RemainingTime());
FrameworkFork\System.ServiceModel\System\ServiceModel\ServiceChannelManager.cs (3)
322return base.OnBeginClose(timeoutHelper.RemainingTime(), callback, state); 329this.CloseInput(timeoutHelper.RemainingTime()); 331base.OnClose(timeoutHelper.RemainingTime());