Index: google_apis/gcm/base/socket_stream.h |
diff --git a/google_apis/gcm/base/socket_stream.h b/google_apis/gcm/base/socket_stream.h |
new file mode 100644 |
index 0000000000000000000000000000000000000000..a45842016f6ce4c68f60d44c15d2fe15c6d725dd |
--- /dev/null |
+++ b/google_apis/gcm/base/socket_stream.h |
@@ -0,0 +1,205 @@ |
+// Copyright 2013 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+// |
+// Protobuf ZeroCopy[Input/Output]Stream implementations capable of using a |
+// net::StreamSocket. Built to work with Protobuf CodedStreams. |
+ |
+#ifndef GOOGLE_APIS_GCM_BASE_SOCKET_STREAM_H_ |
+#define GOOGLE_APIS_GCM_BASE_SOCKET_STREAM_H_ |
+ |
+#include "base/basictypes.h" |
+#include "base/callback_forward.h" |
+#include "base/compiler_specific.h" |
+#include "base/memory/ref_counted.h" |
+#include "base/memory/weak_ptr.h" |
+#include "google/protobuf/io/zero_copy_stream.h" |
+#include "google_apis/gcm/base/gcm_export.h" |
+#include "net/base/net_errors.h" |
+ |
+namespace net { |
+class DrainableIOBuffer; |
+class IOBuffer; |
+class StreamSocket; |
+} // namespace net |
+ |
+namespace gcm { |
+ |
+// A helper class for interacting with a net::StreamSocket that is receiving |
+// protobuf encoded messages. A SocketInputStream does not take ownership of |
+// the socket itself, and it is expected that the life of the input stream |
+// should match the life of the socket itself (while the socket remains |
+// connected). If an error is encounters, the input stream will store the error |
+// in |last_error_|, and GetState() will be set to CLOSED. |
+// Typical usage: |
+// 1. Check the GetState() of the input stream before using it. If CLOSED, the |
+// input stream must be rebuilt (and the socket likely needs to be |
+// reconnected as an error was encountered). |
+// 2. If GetState() is EMPTY, call Refresh(..), passing the maximum byte size |
+// for a message, and wait until completion. It is invalid to attempt to |
+// Refresh an input stream or read data from the stream while a Refresh is |
+// pending. |
+// 3. Check GetState() again to ensure the Refresh was successful. |
+// 4. Use a CodedInputStream to read from the ZeroCopyInputStream interface of |
+// the SocketInputStream. Next(..) will return true until there is no data |
+// remaining. |
+// 5. Call RebuildBuffer when done reading, to shift any unread data to the |
+// start of the buffer. |
+// 6. Repeat as necessary. |
+class GCM_EXPORT SocketInputStream |
+ : public google::protobuf::io::ZeroCopyInputStream { |
+ public: |
+ enum State { |
+ // No valid data to read. This means the buffer is either empty or all data |
+ // in the buffer has already been consumed. |
+ EMPTY, |
+ // Valid data to read. |
+ READY, |
+ // In the process of reading new data from the socket. |
+ READING, |
+ // An permanent error occurred and the stream is now closed. |
+ CLOSED, |
+ }; |
+ |
+ // |socket| should already be connected. |
+ explicit SocketInputStream(net::StreamSocket* socket); |
+ virtual ~SocketInputStream(); |
+ |
+ // ZeroCopyInputStream implementation. |
+ virtual bool Next(const void** data, int* size) OVERRIDE; |
+ virtual void BackUp(int count) OVERRIDE; |
+ virtual bool Skip(int count) OVERRIDE; // Not implemented. |
+ virtual int64 ByteCount() const OVERRIDE; |
+ |
+ // The remaining amount of valid data available to be read. |
+ size_t UnreadByteCount() const; |
+ |
+ // Reads from the socket, appending a max of |byte_limit| bytes onto the read |
+ // buffer. net::ERR_IO_PENDING is returned if the refresh can't complete |
+ // synchronously, in which case the callback is invoked upon completion. If |
+ // the refresh can complete synchronously, even in case of an error, returns |
+ // net::OK without invoking callback. |
+ // Note: GetState() (and possibly last_error()) should be checked upon |
+ // completion to determine whether the Refresh encountered an error. |
+ net::Error Refresh(const base::Closure& callback, int byte_limit); |
+ |
+ // Rebuilds the buffer state by copying over any unread data to the beginning |
+ // of the buffer and resetting the buffer read/write positions. |
+ // Note: it is not valid to call Rebuild() if GetState() == CLOSED. The stream |
+ // must be recreated from scratch in such a scenario. |
+ void RebuildBuffer(); |
+ |
+ // Returns the last fatal error encountered. Only valid if GetState() == |
+ // CLOSED. |
+ net::Error last_error() const; |
+ |
+ // Returns the current state. |
+ State GetState() const; |
+ |
+ private: |
+ // Clears the local state. |
+ void ResetInternal(); |
+ |
+ // Callback for Socket::Read calls. |
+ void RefreshCompletionCallback(const base::Closure& callback, int result); |
+ |
+ // Permanently closes the stream. |
+ void CloseStream(net::Error error, const base::Closure& callback); |
+ |
+ // Internal net components. |
+ net::StreamSocket* const socket_; |
+ const scoped_refptr<net::IOBuffer> io_buffer_; |
+ // IOBuffer implementation that wraps the data within |io_buffer_| that hasn't |
+ // been written to yet by Socket::Read calls. |
+ const scoped_refptr<net::DrainableIOBuffer> read_buffer_; |
+ |
+ // Starting position of the data within |io_buffer_| to consume on subsequent |
+ // Next(..) call. 0 <= next_pos_ <= read_buffer_.BytesConsumed() |
+ // Note: next_pos == read_buffer_.BytesConsumed() implies GetState() == EMPTY. |
+ int next_pos_; |
+ |
+ // If < net::ERR_IO_PENDING, the last net error received. |
+ // Note: last_error_ == net::ERR_IO_PENDING implies GetState() == READING. |
+ net::Error last_error_; |
+ |
+ base::WeakPtrFactory<SocketInputStream> weak_ptr_factory_; |
+ |
+ DISALLOW_COPY_AND_ASSIGN(SocketInputStream); |
+}; |
+ |
+// A helper class for writing to a SocketStream with protobuf encoded data. |
+// A SocketOutputStream does not take ownership of the socket itself, and it is |
+// expected that the life of the output stream should match the life of the |
+// socket itself (while the socket remains connected). |
+// Typical usage: |
+// 1. Check the GetState() of the output stream before using it. If CLOSED, the |
+// output stream must be rebuilt (and the socket likely needs to be |
+// reconnected, as an error was encountered). |
+// 2. If EMPTY, the output stream can be written via a CodedOutputStream using |
+// the ZeroCopyOutputStream interface. |
+// 3. Once done writing, GetState() should be READY, so call Flush(..) to write |
+// the buffer into the StreamSocket. Wait for the callback to be invoked |
+// (it's invalid to write to an output stream while it's flushing). |
+// 4. Check the GetState() again to ensure the Flush was successful. GetState() |
+// should be EMPTY again. |
+// 5. Repeat. |
+class GCM_EXPORT SocketOutputStream |
+ : public google::protobuf::io::ZeroCopyOutputStream { |
+ public: |
+ enum State { |
+ // No valid data yet. |
+ EMPTY, |
+ // Ready for flushing (some data is present). |
+ READY, |
+ // In the process of flushing into the socket. |
+ FLUSHING, |
+ // A permanent error occurred, and the stream is now closed. |
+ CLOSED, |
+ }; |
+ |
+ // |socket| should already be connected. |
+ explicit SocketOutputStream(net::StreamSocket* socket); |
+ virtual ~SocketOutputStream(); |
+ |
+ // ZeroCopyOutputStream implementation. |
+ virtual bool Next(void** data, int* size) OVERRIDE; |
+ virtual void BackUp(int count) OVERRIDE; |
+ virtual int64 ByteCount() const OVERRIDE; |
+ |
+ // Writes the buffer into the Socket. |
+ net::Error Flush(const base::Closure& callback); |
+ |
+ // Returns the last fatal error encountered. Only valid if GetState() == |
+ // CLOSED. |
+ net::Error last_error() const; |
+ |
+ // Returns the current state. |
+ State GetState() const; |
+ |
+ private: |
+ void FlushCompletionCallback(const base::Closure& callback, int result); |
+ |
+ // Internal net components. |
+ net::StreamSocket* const socket_; |
+ const scoped_refptr<net::IOBuffer> io_buffer_; |
+ // IOBuffer implementation that wraps the data within |io_buffer_| that hasn't |
+ // been written to the socket yet. |
+ const scoped_refptr<net::DrainableIOBuffer> write_buffer_; |
+ |
+ // Starting position of the data within |io_buffer_| to consume on subsequent |
+ // Next(..) call. 0 <= write_buffer_.BytesConsumed() <= next_pos_ |
+ // Note: next_pos == 0 implies GetState() == EMPTY. |
+ int next_pos_; |
+ |
+ // If < net::ERR_IO_PENDING, the last net error received. |
+ // Note: last_error_ == net::ERR_IO_PENDING implies GetState() == FLUSHING. |
+ net::Error last_error_; |
+ |
+ base::WeakPtrFactory<SocketOutputStream> weak_ptr_factory_; |
+ |
+ DISALLOW_COPY_AND_ASSIGN(SocketOutputStream); |
+}; |
+ |
+} // namespace gcm |
+ |
+#endif // GOOGLE_APIS_GCM_BASE_SOCKET_STREAM_H_ |