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 |