diff options
author | Allan Sandfeld Jensen <allan.jensen@theqtcompany.com> | 2015-06-18 14:10:49 +0200 |
---|---|---|
committer | Oswald Buddenhagen <oswald.buddenhagen@theqtcompany.com> | 2015-06-18 13:53:24 +0000 |
commit | 813fbf95af77a531c57a8c497345ad2c61d475b3 (patch) | |
tree | 821b2c8de8365f21b6c9ba17a236fb3006a1d506 /chromium/net/quic/test_tools/quic_connection_peer.cc | |
parent | af6588f8d723931a298c995fa97259bb7f7deb55 (diff) | |
download | qtwebengine-chromium-813fbf95af77a531c57a8c497345ad2c61d475b3.tar.gz |
BASELINE: Update chromium to 44.0.2403.47
Change-Id: Ie056fedba95cf5e5c76b30c4b2c80fca4764aa2f
Reviewed-by: Oswald Buddenhagen <oswald.buddenhagen@theqtcompany.com>
Diffstat (limited to 'chromium/net/quic/test_tools/quic_connection_peer.cc')
-rw-r--r-- | chromium/net/quic/test_tools/quic_connection_peer.cc | 78 |
1 files changed, 26 insertions, 52 deletions
diff --git a/chromium/net/quic/test_tools/quic_connection_peer.cc b/chromium/net/quic/test_tools/quic_connection_peer.cc index 8a8df465bae..3525a3247ef 100644 --- a/chromium/net/quic/test_tools/quic_connection_peer.cc +++ b/chromium/net/quic/test_tools/quic_connection_peer.cc @@ -5,7 +5,6 @@ #include "net/quic/test_tools/quic_connection_peer.h" #include "base/stl_util.h" -#include "net/quic/congestion_control/receive_algorithm_interface.h" #include "net/quic/congestion_control/send_algorithm_interface.h" #include "net/quic/quic_connection.h" #include "net/quic/quic_packet_writer.h" @@ -23,14 +22,6 @@ void QuicConnectionPeer::SendAck(QuicConnection* connection) { } // static -void QuicConnectionPeer::SetReceiveAlgorithm( - QuicConnection* connection, - ReceiveAlgorithmInterface* receive_algorithm) { - connection->received_packet_manager_.receive_algorithm_.reset( - receive_algorithm); -} - -// static void QuicConnectionPeer::SetSendAlgorithm( QuicConnection* connection, SendAlgorithmInterface* send_algorithm) { @@ -38,14 +29,16 @@ void QuicConnectionPeer::SetSendAlgorithm( } // static -QuicAckFrame* QuicConnectionPeer::CreateAckFrame(QuicConnection* connection) { - return connection->CreateAckFrame(); +void QuicConnectionPeer::PopulateAckFrame(QuicConnection* connection, + QuicAckFrame* ack) { + connection->PopulateAckFrame(ack); } // static -QuicStopWaitingFrame* QuicConnectionPeer::CreateStopWaitingFrame( - QuicConnection* connection) { - return connection->CreateStopWaitingFrame(); +void QuicConnectionPeer::PopulateStopWaitingFrame( + QuicConnection* connection, + QuicStopWaitingFrame* stop_waiting) { + connection->PopulateStopWaitingFrame(stop_waiting); } // static @@ -74,35 +67,12 @@ QuicSentPacketManager* QuicConnectionPeer::GetSentPacketManager( } // static -QuicReceivedPacketManager* QuicConnectionPeer::GetReceivedPacketManager( - QuicConnection* connection) { - return &connection->received_packet_manager_; -} - -// static QuicTime::Delta QuicConnectionPeer::GetNetworkTimeout( QuicConnection* connection) { return connection->idle_network_timeout_; } // static -bool QuicConnectionPeer::IsSavedForRetransmission( - QuicConnection* connection, - QuicPacketSequenceNumber sequence_number) { - return connection->sent_packet_manager_.IsUnacked(sequence_number) && - connection->sent_packet_manager_.HasRetransmittableFrames( - sequence_number); -} - -// static -bool QuicConnectionPeer::IsRetransmission( - QuicConnection* connection, - QuicPacketSequenceNumber sequence_number) { - return QuicSentPacketManagerPeer::IsRetransmission( - &connection->sent_packet_manager_, sequence_number); -} - -// static // TODO(ianswett): Create a GetSentEntropyHash which accepts an AckFrame. QuicPacketEntropyHash QuicConnectionPeer::GetSentEntropyHash( QuicConnection* connection, @@ -130,15 +100,10 @@ QuicPacketEntropyHash QuicConnectionPeer::ReceivedEntropyHash( } // static -bool QuicConnectionPeer::IsServer(QuicConnection* connection) { - return connection->is_server_; -} - -// static -void QuicConnectionPeer::SetIsServer(QuicConnection* connection, - bool is_server) { - connection->is_server_ = is_server; - QuicFramerPeer::SetIsServer(&connection->framer_, is_server); +void QuicConnectionPeer::SetPerspective(QuicConnection* connection, + Perspective perspective) { + connection->perspective_ = perspective; + QuicFramerPeer::SetPerspective(&connection->framer_, perspective); } // static @@ -154,6 +119,11 @@ void QuicConnectionPeer::SetPeerAddress(QuicConnection* connection, } // static +bool QuicConnectionPeer::IsSilentCloseEnabled(QuicConnection* connection) { + return connection->silent_close_enabled_; +} + +// static void QuicConnectionPeer::SwapCrypters(QuicConnection* connection, QuicFramer* framer) { QuicFramerPeer::SwapCrypters(framer, &connection->framer_); @@ -188,6 +158,11 @@ QuicAlarm* QuicConnectionPeer::GetPingAlarm(QuicConnection* connection) { } // static +QuicAlarm* QuicConnectionPeer::GetFecAlarm(QuicConnection* connection) { + return connection->fec_alarm_.get(); +} + +// static QuicAlarm* QuicConnectionPeer::GetResumeWritesAlarm( QuicConnection* connection) { return connection->resume_writes_alarm_.get(); @@ -237,12 +212,6 @@ QuicEncryptedPacket* QuicConnectionPeer::GetConnectionClosePacket( } // static -void QuicConnectionPeer::SetSupportedVersions(QuicConnection* connection, - QuicVersionVector versions) { - connection->framer_.SetSupportedVersions(versions); -} - -// static QuicPacketHeader* QuicConnectionPeer::GetLastHeader( QuicConnection* connection) { return &connection->last_header_; @@ -254,5 +223,10 @@ void QuicConnectionPeer::SetSequenceNumberOfLastSentPacket( connection->sequence_number_of_last_sent_packet_ = number; } +// static +QuicConnectionStats* QuicConnectionPeer::GetStats(QuicConnection* connection) { + return &connection->stats_; +} + } // namespace test } // namespace net |