summaryrefslogtreecommitdiff
path: root/chromium/net/quic/test_tools/quic_connection_peer.cc
diff options
context:
space:
mode:
authorAllan Sandfeld Jensen <allan.jensen@theqtcompany.com>2015-06-18 14:10:49 +0200
committerOswald Buddenhagen <oswald.buddenhagen@theqtcompany.com>2015-06-18 13:53:24 +0000
commit813fbf95af77a531c57a8c497345ad2c61d475b3 (patch)
tree821b2c8de8365f21b6c9ba17a236fb3006a1d506 /chromium/net/quic/test_tools/quic_connection_peer.cc
parentaf6588f8d723931a298c995fa97259bb7f7deb55 (diff)
downloadqtwebengine-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.cc78
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