| Index: remoting/base/buffered_socket_writer.h
|
| diff --git a/remoting/base/buffered_socket_writer.h b/remoting/base/buffered_socket_writer.h
|
| index dffed45f4e277de902def779adb84bbb9e46f214..c153ebec65c2851014d51eec086bbeddaa8cfdc4 100644
|
| --- a/remoting/base/buffered_socket_writer.h
|
| +++ b/remoting/base/buffered_socket_writer.h
|
| @@ -36,13 +36,14 @@ class BufferedSocketWriter {
|
| BufferedSocketWriter();
|
| virtual ~BufferedSocketWriter();
|
|
|
| - // Initializes the writer. |write_callback| is called to write data to the
|
| + // Starts the writer. |write_callback| is called to write data to the
|
| // socket. |write_failed_callback| is called when write operation fails.
|
| // Writing stops after the first failed write.
|
| - void Init(const WriteCallback& write_callback,
|
| - const WriteFailedCallback& write_failed_callback);
|
| + void Start(const WriteCallback& write_callback,
|
| + const WriteFailedCallback& write_failed_callback);
|
|
|
| - // Puts a new data chunk in the buffer.
|
| + // Puts a new data chunk in the buffer. If called before Start() then all data
|
| + // is buffered until Start().
|
| void Write(const scoped_refptr<net::IOBufferWithSize>& buffer,
|
| const base::Closure& done_task);
|
|
|
| @@ -53,9 +54,6 @@ class BufferedSocketWriter {
|
| struct PendingPacket;
|
| typedef std::list<PendingPacket*> DataQueue;
|
|
|
| - // Returns true if the writer is closed due to an error.
|
| - bool is_closed();
|
| -
|
| void DoWrite();
|
| void HandleWriteResult(int result);
|
| void OnWritten(int result);
|
| @@ -65,6 +63,8 @@ class BufferedSocketWriter {
|
| WriteCallback write_callback_;
|
| WriteFailedCallback write_failed_callback_;
|
|
|
| + bool closed_ = false;
|
| +
|
| DataQueue queue_;
|
|
|
| bool write_pending_ = false;
|
|
|