| 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_QUIC_QUIC_HTTP_STREAM_H_ | 5 #ifndef NET_QUIC_QUIC_HTTP_STREAM_H_ |
| 6 #define NET_QUIC_QUIC_HTTP_STREAM_H_ | 6 #define NET_QUIC_QUIC_HTTP_STREAM_H_ |
| 7 | 7 |
| 8 #include <stddef.h> | 8 #include <stddef.h> |
| 9 #include <stdint.h> | 9 #include <stdint.h> |
| 10 | 10 |
| (...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 89 const SpdyHeaderBlock& promise_response) override; | 89 const SpdyHeaderBlock& promise_response) override; |
| 90 void OnRendezvousResult(QuicSpdyStream* stream) override; | 90 void OnRendezvousResult(QuicSpdyStream* stream) override; |
| 91 | 91 |
| 92 private: | 92 private: |
| 93 friend class test::QuicHttpStreamPeer; | 93 friend class test::QuicHttpStreamPeer; |
| 94 | 94 |
| 95 enum State { | 95 enum State { |
| 96 STATE_NONE, | 96 STATE_NONE, |
| 97 STATE_REQUEST_STREAM, | 97 STATE_REQUEST_STREAM, |
| 98 STATE_SET_REQUEST_PRIORITY, | 98 STATE_SET_REQUEST_PRIORITY, |
| 99 STATE_WAIT_FOR_CONFIRMATION, |
| 100 STATE_WAIT_FOR_CONFIRMATION_COMPLETE, |
| 99 STATE_SEND_HEADERS, | 101 STATE_SEND_HEADERS, |
| 100 STATE_SEND_HEADERS_COMPLETE, | 102 STATE_SEND_HEADERS_COMPLETE, |
| 101 STATE_READ_REQUEST_BODY, | 103 STATE_READ_REQUEST_BODY, |
| 102 STATE_READ_REQUEST_BODY_COMPLETE, | 104 STATE_READ_REQUEST_BODY_COMPLETE, |
| 103 STATE_SEND_BODY, | 105 STATE_SEND_BODY, |
| 104 STATE_SEND_BODY_COMPLETE, | 106 STATE_SEND_BODY_COMPLETE, |
| 105 STATE_OPEN, | 107 STATE_OPEN, |
| 106 }; | 108 }; |
| 107 | 109 |
| 108 void OnStreamReady(int rv); | 110 void OnStreamReady(int rv); |
| 109 void OnIOComplete(int rv); | 111 void OnIOComplete(int rv); |
| 110 void DoCallback(int rv); | 112 void DoCallback(int rv); |
| 111 | 113 |
| 112 int DoLoop(int rv); | 114 int DoLoop(int rv); |
| 113 int DoStreamRequest(); | 115 int DoStreamRequest(); |
| 114 int DoSetRequestPriority(); | 116 int DoSetRequestPriority(); |
| 117 int DoWaitForConfirmation(); |
| 118 int DoWaitForConfirmationComplete(int rv); |
| 115 int DoSendHeaders(); | 119 int DoSendHeaders(); |
| 116 int DoSendHeadersComplete(int rv); | 120 int DoSendHeadersComplete(int rv); |
| 117 int DoReadRequestBody(); | 121 int DoReadRequestBody(); |
| 118 int DoReadRequestBodyComplete(int rv); | 122 int DoReadRequestBodyComplete(int rv); |
| 119 int DoSendBody(); | 123 int DoSendBody(); |
| 120 int DoSendBodyComplete(int rv); | 124 int DoSendBodyComplete(int rv); |
| 121 | 125 |
| 122 int ProcessResponseHeaders(const SpdyHeaderBlock& headers); | 126 int ProcessResponseHeaders(const SpdyHeaderBlock& headers); |
| 123 | 127 |
| 124 int ReadAvailableData(IOBuffer* buf, int buf_len); | 128 int ReadAvailableData(IOBuffer* buf, int buf_len); |
| (...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 204 QuicClientPushPromiseIndex::TryHandle* push_handle_; | 208 QuicClientPushPromiseIndex::TryHandle* push_handle_; |
| 205 | 209 |
| 206 base::WeakPtrFactory<QuicHttpStream> weak_factory_; | 210 base::WeakPtrFactory<QuicHttpStream> weak_factory_; |
| 207 | 211 |
| 208 DISALLOW_COPY_AND_ASSIGN(QuicHttpStream); | 212 DISALLOW_COPY_AND_ASSIGN(QuicHttpStream); |
| 209 }; | 213 }; |
| 210 | 214 |
| 211 } // namespace net | 215 } // namespace net |
| 212 | 216 |
| 213 #endif // NET_QUIC_QUIC_HTTP_STREAM_H_ | 217 #endif // NET_QUIC_QUIC_HTTP_STREAM_H_ |
| OLD | NEW |