| 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 230 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 241 } | 241 } |
| 242 | 242 |
| 243 void set_client_initial_flow_control_receive_window(uint32 window) { | 243 void set_client_initial_flow_control_receive_window(uint32 window) { |
| 244 CHECK(client_.get() == NULL); | 244 CHECK(client_.get() == NULL); |
| 245 DVLOG(1) << "Setting client initial flow control window: " << window; | 245 DVLOG(1) << "Setting client initial flow control window: " << window; |
| 246 client_config_.SetInitialFlowControlWindowToSend(window); | 246 client_config_.SetInitialFlowControlWindowToSend(window); |
| 247 } | 247 } |
| 248 | 248 |
| 249 void set_client_initial_stream_flow_control_receive_window(uint32 window) { | 249 void set_client_initial_stream_flow_control_receive_window(uint32 window) { |
| 250 CHECK(client_.get() == NULL); | 250 CHECK(client_.get() == NULL); |
| 251 DLOG(INFO) << "Setting client initial stream flow control window: " | 251 DVLOG(1) << "Setting client initial stream flow control window: " << window; |
| 252 << window; | |
| 253 client_config_.SetInitialStreamFlowControlWindowToSend(window); | 252 client_config_.SetInitialStreamFlowControlWindowToSend(window); |
| 254 } | 253 } |
| 255 | 254 |
| 256 void set_client_initial_session_flow_control_receive_window(uint32 window) { | 255 void set_client_initial_session_flow_control_receive_window(uint32 window) { |
| 257 CHECK(client_.get() == NULL); | 256 CHECK(client_.get() == NULL); |
| 258 DLOG(INFO) << "Setting client initial session flow control window: " | 257 DVLOG(1) << "Setting client initial session flow control window: " |
| 259 << window; | 258 << window; |
| 260 client_config_.SetInitialSessionFlowControlWindowToSend(window); | 259 client_config_.SetInitialSessionFlowControlWindowToSend(window); |
| 261 } | 260 } |
| 262 | 261 |
| 263 void set_server_initial_flow_control_receive_window(uint32 window) { | 262 void set_server_initial_flow_control_receive_window(uint32 window) { |
| 264 CHECK(server_thread_.get() == NULL); | 263 CHECK(server_thread_.get() == NULL); |
| 265 DVLOG(1) << "Setting server initial flow control window: " << window; | 264 DVLOG(1) << "Setting server initial flow control window: " << window; |
| 266 server_config_.SetInitialFlowControlWindowToSend(window); | 265 server_config_.SetInitialFlowControlWindowToSend(window); |
| 267 } | 266 } |
| 268 | 267 |
| 269 void set_server_initial_stream_flow_control_receive_window(uint32 window) { | 268 void set_server_initial_stream_flow_control_receive_window(uint32 window) { |
| 270 CHECK(server_thread_.get() == NULL); | 269 CHECK(server_thread_.get() == NULL); |
| 271 DLOG(INFO) << "Setting server initial stream flow control window: " | 270 DVLOG(1) << "Setting server initial stream flow control window: " |
| 272 << window; | 271 << window; |
| 273 server_config_.SetInitialStreamFlowControlWindowToSend(window); | 272 server_config_.SetInitialStreamFlowControlWindowToSend(window); |
| 274 } | 273 } |
| 275 | 274 |
| 276 void set_server_initial_session_flow_control_receive_window(uint32 window) { | 275 void set_server_initial_session_flow_control_receive_window(uint32 window) { |
| 277 CHECK(server_thread_.get() == NULL); | 276 CHECK(server_thread_.get() == NULL); |
| 278 DLOG(INFO) << "Setting server initial session flow control window: " | 277 DVLOG(1) << "Setting server initial session flow control window: " |
| 279 << window; | 278 << window; |
| 280 server_config_.SetInitialSessionFlowControlWindowToSend(window); | 279 server_config_.SetInitialSessionFlowControlWindowToSend(window); |
| 281 } | 280 } |
| 282 | 281 |
| 283 const QuicSentPacketManager * | 282 const QuicSentPacketManager * |
| 284 GetSentPacketManagerFromFirstServerSession() const { | 283 GetSentPacketManagerFromFirstServerSession() const { |
| 285 QuicDispatcher* dispatcher = | 284 QuicDispatcher* dispatcher = |
| 286 QuicServerPeer::GetDispatcher(server_thread_->server()); | 285 QuicServerPeer::GetDispatcher(server_thread_->server()); |
| 287 QuicSession* session = dispatcher->session_map().begin()->second; | 286 QuicSession* session = dispatcher->session_map().begin()->second; |
| 288 return &session->connection()->sent_packet_manager(); | 287 return &session->connection()->sent_packet_manager(); |
| 289 } | 288 } |
| (...skipping 1089 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1379 QuicSession* session = dispatcher->session_map().begin()->second; | 1378 QuicSession* session = dispatcher->session_map().begin()->second; |
| 1380 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( | 1379 EXPECT_EQ(0u, QuicSessionPeer::GetLocallyClosedStreamsHighestOffset( |
| 1381 session).size()); | 1380 session).size()); |
| 1382 server_thread_->Resume(); | 1381 server_thread_->Resume(); |
| 1383 } | 1382 } |
| 1384 | 1383 |
| 1385 } // namespace | 1384 } // namespace |
| 1386 } // namespace test | 1385 } // namespace test |
| 1387 } // namespace tools | 1386 } // namespace tools |
| 1388 } // namespace net | 1387 } // namespace net |
| OLD | NEW |