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 #ifndef NET_SPDY_SPDY_STREAM_H_ | 5 #ifndef NET_SPDY_SPDY_STREAM_H_ |
6 #define NET_SPDY_SPDY_STREAM_H_ | 6 #define NET_SPDY_SPDY_STREAM_H_ |
7 #pragma once | 7 #pragma once |
8 | 8 |
9 #include <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
(...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
249 // Get the URL associated with this stream. Only valid when has_url() is | 249 // Get the URL associated with this stream. Only valid when has_url() is |
250 // true. | 250 // true. |
251 GURL GetUrl() const; | 251 GURL GetUrl() const; |
252 | 252 |
253 // ChunkCallback methods. | 253 // ChunkCallback methods. |
254 virtual void OnChunkAvailable() OVERRIDE; | 254 virtual void OnChunkAvailable() OVERRIDE; |
255 | 255 |
256 private: | 256 private: |
257 enum State { | 257 enum State { |
258 STATE_NONE, | 258 STATE_NONE, |
259 STATE_GET_ORIGIN_BOUND_CERT, | 259 STATE_GET_DOMAIN_BOUND_CERT, |
260 STATE_GET_ORIGIN_BOUND_CERT_COMPLETE, | 260 STATE_GET_DOMAIN_BOUND_CERT_COMPLETE, |
261 STATE_SEND_ORIGIN_BOUND_CERT, | 261 STATE_SEND_DOMAIN_BOUND_CERT, |
262 STATE_SEND_ORIGIN_BOUND_CERT_COMPLETE, | 262 STATE_SEND_DOMAIN_BOUND_CERT_COMPLETE, |
263 STATE_SEND_HEADERS, | 263 STATE_SEND_HEADERS, |
264 STATE_SEND_HEADERS_COMPLETE, | 264 STATE_SEND_HEADERS_COMPLETE, |
265 STATE_SEND_BODY, | 265 STATE_SEND_BODY, |
266 STATE_SEND_BODY_COMPLETE, | 266 STATE_SEND_BODY_COMPLETE, |
267 STATE_WAITING_FOR_RESPONSE, | 267 STATE_WAITING_FOR_RESPONSE, |
268 STATE_OPEN, | 268 STATE_OPEN, |
269 STATE_DONE | 269 STATE_DONE |
270 }; | 270 }; |
271 | 271 |
272 friend class base::RefCounted<SpdyStream>; | 272 friend class base::RefCounted<SpdyStream>; |
273 virtual ~SpdyStream(); | 273 virtual ~SpdyStream(); |
274 | 274 |
275 void OnGetOriginBoundCertComplete(int result); | 275 void OnGetDomainBoundCertComplete(int result); |
276 | 276 |
277 // Try to make progress sending/receiving the request/response. | 277 // Try to make progress sending/receiving the request/response. |
278 int DoLoop(int result); | 278 int DoLoop(int result); |
279 | 279 |
280 // The implementations of each state of the state machine. | 280 // The implementations of each state of the state machine. |
281 int DoGetOriginBoundCert(); | 281 int DoGetDomainBoundCert(); |
282 int DoGetOriginBoundCertComplete(int result); | 282 int DoGetDomainBoundCertComplete(int result); |
283 int DoSendOriginBoundCert(); | 283 int DoSendDomainBoundCert(); |
284 int DoSendOriginBoundCertComplete(int result); | 284 int DoSendDomainBoundCertComplete(int result); |
285 int DoSendHeaders(); | 285 int DoSendHeaders(); |
286 int DoSendHeadersComplete(int result); | 286 int DoSendHeadersComplete(int result); |
287 int DoSendBody(); | 287 int DoSendBody(); |
288 int DoSendBodyComplete(int result); | 288 int DoSendBodyComplete(int result); |
289 int DoReadHeaders(); | 289 int DoReadHeaders(); |
290 int DoReadHeadersComplete(int result); | 290 int DoReadHeadersComplete(int result); |
291 int DoOpen(int result); | 291 int DoOpen(int result); |
292 | 292 |
293 // Update the histograms. Can safely be called repeatedly, but should only | 293 // Update the histograms. Can safely be called repeatedly, but should only |
294 // be called after the stream has completed. | 294 // be called after the stream has completed. |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
344 BoundNetLog net_log_; | 344 BoundNetLog net_log_; |
345 | 345 |
346 base::TimeTicks send_time_; | 346 base::TimeTicks send_time_; |
347 base::TimeTicks recv_first_byte_time_; | 347 base::TimeTicks recv_first_byte_time_; |
348 base::TimeTicks recv_last_byte_time_; | 348 base::TimeTicks recv_last_byte_time_; |
349 int send_bytes_; | 349 int send_bytes_; |
350 int recv_bytes_; | 350 int recv_bytes_; |
351 // Data received before delegate is attached. | 351 // Data received before delegate is attached. |
352 std::vector<scoped_refptr<IOBufferWithSize> > pending_buffers_; | 352 std::vector<scoped_refptr<IOBufferWithSize> > pending_buffers_; |
353 | 353 |
354 SSLClientCertType ob_cert_type_; | 354 SSLClientCertType domain_bound_cert_type_; |
355 std::string ob_private_key_; | 355 std::string domain_bound_private_key_; |
356 std::string ob_cert_; | 356 std::string domain_bound_cert_; |
357 OriginBoundCertService::RequestHandle ob_cert_request_handle_; | 357 ServerBoundCertService::RequestHandle domain_bound_cert_request_handle_; |
358 | 358 |
359 DISALLOW_COPY_AND_ASSIGN(SpdyStream); | 359 DISALLOW_COPY_AND_ASSIGN(SpdyStream); |
360 }; | 360 }; |
361 | 361 |
362 class NetLogSpdyStreamErrorParameter : public NetLog::EventParameters { | 362 class NetLogSpdyStreamErrorParameter : public NetLog::EventParameters { |
363 public: | 363 public: |
364 NetLogSpdyStreamErrorParameter(spdy::SpdyStreamId stream_id, | 364 NetLogSpdyStreamErrorParameter(spdy::SpdyStreamId stream_id, |
365 int status, | 365 int status, |
366 const std::string& description); | 366 const std::string& description); |
367 | 367 |
368 spdy::SpdyStreamId stream_id() const { return stream_id_; } | 368 spdy::SpdyStreamId stream_id() const { return stream_id_; } |
369 virtual base::Value* ToValue() const OVERRIDE; | 369 virtual base::Value* ToValue() const OVERRIDE; |
370 | 370 |
371 private: | 371 private: |
372 virtual ~NetLogSpdyStreamErrorParameter(); | 372 virtual ~NetLogSpdyStreamErrorParameter(); |
373 | 373 |
374 const spdy::SpdyStreamId stream_id_; | 374 const spdy::SpdyStreamId stream_id_; |
375 const int status_; | 375 const int status_; |
376 const std::string description_; | 376 const std::string description_; |
377 | 377 |
378 DISALLOW_COPY_AND_ASSIGN(NetLogSpdyStreamErrorParameter); | 378 DISALLOW_COPY_AND_ASSIGN(NetLogSpdyStreamErrorParameter); |
379 }; | 379 }; |
380 | 380 |
381 } // namespace net | 381 } // namespace net |
382 | 382 |
383 #endif // NET_SPDY_SPDY_STREAM_H_ | 383 #endif // NET_SPDY_SPDY_STREAM_H_ |
OLD | NEW |