| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <stddef.h> | 5 #include <stddef.h> |
| 6 #include <string> | 6 #include <string> |
| 7 #include <sys/epoll.h> | 7 #include <sys/epoll.h> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| (...skipping 237 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 248 } | 248 } |
| 249 | 249 |
| 250 void set_client_initial_flow_control_receive_window(uint32 window) { | 250 void set_client_initial_flow_control_receive_window(uint32 window) { |
| 251 CHECK(client_.get() == NULL); | 251 CHECK(client_.get() == NULL); |
| 252 DVLOG(1) << "Setting client initial flow control window: " << window; | 252 DVLOG(1) << "Setting client initial flow control window: " << window; |
| 253 client_config_.SetInitialFlowControlWindowToSend(window); | 253 client_config_.SetInitialFlowControlWindowToSend(window); |
| 254 } | 254 } |
| 255 | 255 |
| 256 void set_client_initial_stream_flow_control_receive_window(uint32 window) { | 256 void set_client_initial_stream_flow_control_receive_window(uint32 window) { |
| 257 CHECK(client_.get() == NULL); | 257 CHECK(client_.get() == NULL); |
| 258 DLOG(INFO) << "Setting client initial stream flow control window: " | 258 DVLOG(1) << "Setting client initial stream flow control window: " << window; |
| 259 << window; | |
| 260 client_config_.SetInitialStreamFlowControlWindowToSend(window); | 259 client_config_.SetInitialStreamFlowControlWindowToSend(window); |
| 261 } | 260 } |
| 262 | 261 |
| 263 void set_client_initial_session_flow_control_receive_window(uint32 window) { | 262 void set_client_initial_session_flow_control_receive_window(uint32 window) { |
| 264 CHECK(client_.get() == NULL); | 263 CHECK(client_.get() == NULL); |
| 265 DLOG(INFO) << "Setting client initial session flow control window: " | 264 DVLOG(1) << "Setting client initial session flow control window: " |
| 266 << window; | 265 << window; |
| 267 client_config_.SetInitialSessionFlowControlWindowToSend(window); | 266 client_config_.SetInitialSessionFlowControlWindowToSend(window); |
| 268 } | 267 } |
| 269 | 268 |
| 270 void set_server_initial_flow_control_receive_window(uint32 window) { | 269 void set_server_initial_flow_control_receive_window(uint32 window) { |
| 271 CHECK(server_thread_.get() == NULL); | 270 CHECK(server_thread_.get() == NULL); |
| 272 DVLOG(1) << "Setting server initial flow control window: " << window; | 271 DVLOG(1) << "Setting server initial flow control window: " << window; |
| 273 server_config_.SetInitialFlowControlWindowToSend(window); | 272 server_config_.SetInitialFlowControlWindowToSend(window); |
| 274 } | 273 } |
| 275 | 274 |
| 276 void set_server_initial_stream_flow_control_receive_window(uint32 window) { | 275 void set_server_initial_stream_flow_control_receive_window(uint32 window) { |
| 277 CHECK(server_thread_.get() == NULL); | 276 CHECK(server_thread_.get() == NULL); |
| 278 DLOG(INFO) << "Setting server initial stream flow control window: " | 277 DVLOG(1) << "Setting server initial stream flow control window: " |
| 279 << window; | 278 << window; |
| 280 server_config_.SetInitialStreamFlowControlWindowToSend(window); | 279 server_config_.SetInitialStreamFlowControlWindowToSend(window); |
| 281 } | 280 } |
| 282 | 281 |
| 283 void set_server_initial_session_flow_control_receive_window(uint32 window) { | 282 void set_server_initial_session_flow_control_receive_window(uint32 window) { |
| 284 CHECK(server_thread_.get() == NULL); | 283 CHECK(server_thread_.get() == NULL); |
| 285 DLOG(INFO) << "Setting server initial session flow control window: " | 284 DVLOG(1) << "Setting server initial session flow control window: " |
| 286 << window; | 285 << window; |
| 287 server_config_.SetInitialSessionFlowControlWindowToSend(window); | 286 server_config_.SetInitialSessionFlowControlWindowToSend(window); |
| 288 } | 287 } |
| 289 | 288 |
| 290 const QuicSentPacketManager * | 289 const QuicSentPacketManager * |
| 291 GetSentPacketManagerFromFirstServerSession() const { | 290 GetSentPacketManagerFromFirstServerSession() const { |
| 292 QuicDispatcher* dispatcher = | 291 QuicDispatcher* dispatcher = |
| 293 QuicServerPeer::GetDispatcher(server_thread_->server()); | 292 QuicServerPeer::GetDispatcher(server_thread_->server()); |
| 294 QuicSession* session = dispatcher->session_map().begin()->second; | 293 QuicSession* session = dispatcher->session_map().begin()->second; |
| 295 return &session->connection()->sent_packet_manager(); | 294 return &session->connection()->sent_packet_manager(); |
| 296 } | 295 } |
| (...skipping 1092 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1389 QuicSession* session = dispatcher->session_map().begin()->second; | 1388 QuicSession* session = dispatcher->session_map().begin()->second; |
| 1390 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( | 1389 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( |
| 1391 session).size()); | 1390 session).size()); |
| 1392 server_thread_->Resume(); | 1391 server_thread_->Resume(); |
| 1393 } | 1392 } |
| 1394 | 1393 |
| 1395 } // namespace | 1394 } // namespace |
| 1396 } // namespace test | 1395 } // namespace test |
| 1397 } // namespace tools | 1396 } // namespace tools |
| 1398 } // namespace net | 1397 } // namespace net |
| OLD | NEW |