Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(744)

Side by Side Diff: net/spdy/spdy_session.h

Issue 18796003: When an idle socket is added back to a socket pool, check for stalled jobs in lower pools (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src/
Patch Set: Update comments Created 7 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « net/socket/transport_client_socket_pool.cc ('k') | net/spdy/spdy_session.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 #ifndef NET_SPDY_SPDY_SESSION_H_ 5 #ifndef NET_SPDY_SPDY_SESSION_H_
6 #define NET_SPDY_SPDY_SESSION_H_ 6 #define NET_SPDY_SPDY_SESSION_H_
7 7
8 #include <deque> 8 #include <deque>
9 #include <map> 9 #include <map>
10 #include <set> 10 #include <set>
(...skipping 168 matching lines...) Expand 10 before | Expand all | Expand 10 after
179 GURL url_; 179 GURL url_;
180 RequestPriority priority_; 180 RequestPriority priority_;
181 BoundNetLog net_log_; 181 BoundNetLog net_log_;
182 CompletionCallback callback_; 182 CompletionCallback callback_;
183 183
184 DISALLOW_COPY_AND_ASSIGN(SpdyStreamRequest); 184 DISALLOW_COPY_AND_ASSIGN(SpdyStreamRequest);
185 }; 185 };
186 186
187 class NET_EXPORT SpdySession : public BufferedSpdyFramerVisitorInterface, 187 class NET_EXPORT SpdySession : public BufferedSpdyFramerVisitorInterface,
188 public SpdyFramerDebugVisitorInterface, 188 public SpdyFramerDebugVisitorInterface,
189 public LayeredPool { 189 public HigherLayeredPool {
190 public: 190 public:
191 // TODO(akalin): Use base::TickClock when it becomes available. 191 // TODO(akalin): Use base::TickClock when it becomes available.
192 typedef base::TimeTicks (*TimeFunc)(void); 192 typedef base::TimeTicks (*TimeFunc)(void);
193 193
194 // How we handle flow control (version-dependent). 194 // How we handle flow control (version-dependent).
195 enum FlowControlState { 195 enum FlowControlState {
196 FLOW_CONTROL_NONE, 196 FLOW_CONTROL_NONE,
197 FLOW_CONTROL_STREAM, 197 FLOW_CONTROL_STREAM,
198 FLOW_CONTROL_STREAM_AND_SESSION 198 FLOW_CONTROL_STREAM_AND_SESSION
199 }; 199 };
(...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after
473 return buffered_spdy_framer_->GetFrameMaximumSize(); 473 return buffered_spdy_framer_->GetFrameMaximumSize();
474 } 474 }
475 475
476 size_t GetDataFrameMaximumPayload() const { 476 size_t GetDataFrameMaximumPayload() const {
477 return buffered_spdy_framer_->GetDataFrameMaximumPayload(); 477 return buffered_spdy_framer_->GetDataFrameMaximumPayload();
478 } 478 }
479 479
480 // Must be used only by |pool_|. 480 // Must be used only by |pool_|.
481 base::WeakPtr<SpdySession> GetWeakPtr(); 481 base::WeakPtr<SpdySession> GetWeakPtr();
482 482
483 // LayeredPool implementation: 483 // HigherLayeredPool implementation:
484 virtual bool CloseOneIdleConnection() OVERRIDE; 484 virtual bool CloseOneIdleConnection() OVERRIDE;
485 485
486 private: 486 private:
487 friend class base::RefCounted<SpdySession>; 487 friend class base::RefCounted<SpdySession>;
488 friend class SpdyStreamRequest; 488 friend class SpdyStreamRequest;
489 friend class SpdySessionTest; 489 friend class SpdySessionTest;
490 490
491 // Allow tests to access our innards for testing purposes. 491 // Allow tests to access our innards for testing purposes.
492 FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, ClientPing); 492 FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, ClientPing);
493 FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, FailedPing); 493 FRIEND_TEST_ALL_PREFIXES(SpdySessionTest, FailedPing);
(...skipping 640 matching lines...) Expand 10 before | Expand all | Expand 10 after
1134 // This SPDY proxy is allowed to push resources from origins that are 1134 // This SPDY proxy is allowed to push resources from origins that are
1135 // different from those of their associated streams. 1135 // different from those of their associated streams.
1136 HostPortPair trusted_spdy_proxy_; 1136 HostPortPair trusted_spdy_proxy_;
1137 1137
1138 TimeFunc time_func_; 1138 TimeFunc time_func_;
1139 }; 1139 };
1140 1140
1141 } // namespace net 1141 } // namespace net
1142 1142
1143 #endif // NET_SPDY_SPDY_SESSION_H_ 1143 #endif // NET_SPDY_SPDY_SESSION_H_
OLDNEW
« no previous file with comments | « net/socket/transport_client_socket_pool.cc ('k') | net/spdy/spdy_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698