Index: mojo/services/network/public/cpp/web_socket_write_queue.h |
diff --git a/mojo/services/network/public/cpp/web_socket_write_queue.h b/mojo/services/network/public/cpp/web_socket_write_queue.h |
index b2c48fc9076d8fd8b7390aa77271a7df0dab5a60..ddfcadad624b2e04e9b6768eae8f82564e5e9736 100644 |
--- a/mojo/services/network/public/cpp/web_socket_write_queue.h |
+++ b/mojo/services/network/public/cpp/web_socket_write_queue.h |
@@ -19,7 +19,7 @@ namespace mojo { |
// See also: WebSocketReadQueue |
class WebSocketWriteQueue { |
public: |
- WebSocketWriteQueue(DataPipeProducerHandle handle); |
+ explicit WebSocketWriteQueue(DataPipeProducerHandle handle); |
~WebSocketWriteQueue(); |
void Write(const char* data, |
@@ -29,14 +29,17 @@ class WebSocketWriteQueue { |
private: |
struct Operation; |
- MojoResult TryToWrite(); |
+ void TryToWrite(); |
void Wait(); |
void OnHandleReady(MojoResult result); |
DataPipeProducerHandle handle_; |
common::HandleWatcher handle_watcher_; |
ScopedVector<Operation> queue_; |
- bool is_waiting_; |
+ bool is_busy_; |
+ // If non-null, the boolean it points to (allocated on the stack) will be set |
+ // to true when this object is destructed. |
+ bool* destructed_; |
}; |
} // namespace mojo |