| Index: mojo/services/network/public/cpp/web_socket_read_queue.h
|
| diff --git a/mojo/services/network/public/cpp/web_socket_read_queue.h b/mojo/services/network/public/cpp/web_socket_read_queue.h
|
| index 27315105710a963d0521eb23d3aaffd7234bf27d..287e91cb34b429f77138d2d35229d0dcacc30fbd 100644
|
| --- a/mojo/services/network/public/cpp/web_socket_read_queue.h
|
| +++ b/mojo/services/network/public/cpp/web_socket_read_queue.h
|
| @@ -7,6 +7,7 @@
|
|
|
| #include "base/callback.h"
|
| #include "base/memory/scoped_vector.h"
|
| +#include "base/memory/weak_ptr.h"
|
| #include "mojo/common/handle_watcher.h"
|
| #include "third_party/mojo/src/mojo/public/cpp/system/data_pipe.h"
|
|
|
| @@ -19,7 +20,7 @@ namespace mojo {
|
| // See also: WebSocketWriteQueue
|
| class WebSocketReadQueue {
|
| public:
|
| - WebSocketReadQueue(DataPipeConsumerHandle handle);
|
| + explicit WebSocketReadQueue(DataPipeConsumerHandle handle);
|
| ~WebSocketReadQueue();
|
|
|
| void Read(uint32_t num_bytes, base::Callback<void(const char*)> callback);
|
| @@ -34,7 +35,8 @@ class WebSocketReadQueue {
|
| DataPipeConsumerHandle handle_;
|
| common::HandleWatcher handle_watcher_;
|
| ScopedVector<Operation> queue_;
|
| - bool is_waiting_;
|
| + bool is_busy_;
|
| + base::WeakPtrFactory<WebSocketReadQueue> weak_factory_;
|
| };
|
|
|
| } // namespace mojo
|
|
|