Index: net/http/bidirectional_stream.h |
diff --git a/net/http/bidirectional_stream.h b/net/http/bidirectional_stream.h |
index 7e6152a48f9d699b62d8853419dfdde9267e1e51..a4dc7d79d7794deb44e2f50c940e407ba0b23586 100644 |
--- a/net/http/bidirectional_stream.h |
+++ b/net/http/bidirectional_stream.h |
@@ -29,8 +29,9 @@ struct BidirectionalStreamRequestInfo; |
struct SSLConfig; |
// A class to do HTTP/2 bidirectional streaming. Note that at most one each of |
-// ReadData or SendData should be in flight until the operation completes. |
-// The BidirectionalStream must be torn down before the HttpNetworkSession. |
+// ReadData or SendData/SendvData should be in flight until the operation |
+// completes. The BidirectionalStream must be torn down before the |
+// HttpNetworkSession. |
class NET_EXPORT BidirectionalStream |
: public NON_EXPORTED_BASE(BidirectionalStreamImpl::Delegate), |
public NON_EXPORTED_BASE(HttpStreamRequest::Delegate) { |
@@ -41,13 +42,13 @@ class NET_EXPORT BidirectionalStream |
public: |
Delegate(); |
- // Called when headers have been sent. This is called at most once for |
- // the lifetime of a stream. |
+ // Called when the stream is ready for writing and reading. This is called |
+ // at most once for the lifetime of a stream. |
// The delegate may call BidirectionalStream::ReadData to start reading, |
// or call BidirectionalStream::SendData to send data. |
// The delegate should not call BidirectionalStream::Cancel |
// during this callback. |
- virtual void OnHeadersSent() = 0; |
+ virtual void OnStreamReady() = 0; |
// Called when headers are received. This is called at most once for the |
// lifetime of a stream. |
@@ -93,12 +94,14 @@ class NET_EXPORT BidirectionalStream |
// |session| and |delegate| must outlive |this|. |
BidirectionalStream(scoped_ptr<BidirectionalStreamRequestInfo> request_info, |
HttpNetworkSession* session, |
+ bool disable_auto_flush, |
Delegate* delegate); |
// Constructor that accepts a Timer, which can be used in tests to control |
// the buffering of received data. |
BidirectionalStream(scoped_ptr<BidirectionalStreamRequestInfo> request_info, |
HttpNetworkSession* session, |
+ bool disable_auto_flush, |
Delegate* delegate, |
scoped_ptr<base::Timer> timer); |
@@ -121,6 +124,11 @@ class NET_EXPORT BidirectionalStream |
// flag. |
void SendData(IOBuffer* data, int length, bool end_stream); |
+ // Same as SendData except this takes in a vector of IOBuffers. |
+ void SendvData(const std::vector<IOBuffer*>& buffers, |
+ const std::vector<int>& lengths, |
+ bool end_stream); |
+ |
// If |stream_request_| is non-NULL, cancel it. If |stream_impl_| is |
// established, cancel it. No delegate method will be called after Cancel(). |
// Any pending operations may or may not succeed. |
@@ -147,7 +155,7 @@ class NET_EXPORT BidirectionalStream |
private: |
// BidirectionalStreamImpl::Delegate implementation: |
- void OnHeadersSent() override; |
+ void OnStreamReady() override; |
void OnHeadersReceived(const SpdyHeaderBlock& response_headers) override; |
void OnDataRead(int bytes_read) override; |
void OnDataSent() override; |
@@ -190,6 +198,7 @@ class NET_EXPORT BidirectionalStream |
HttpNetworkSession* session_; |
+ bool disable_auto_flush_; |
Delegate* const delegate_; |
// Timer used to buffer data received in short time-spans and send a single |