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\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\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());