Index: mojo/services/network/public/cpp/web_socket_write_queue.cc |
diff --git a/mojo/services/network/public/cpp/web_socket_write_queue.cc b/mojo/services/network/public/cpp/web_socket_write_queue.cc |
deleted file mode 100644 |
index e47260a63ea85e1956e7ede8d8e9715abf27b2a5..0000000000000000000000000000000000000000 |
--- a/mojo/services/network/public/cpp/web_socket_write_queue.cc |
+++ /dev/null |
@@ -1,104 +0,0 @@ |
-// Copyright 2014 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. |
- |
-#include "network/public/cpp/web_socket_write_queue.h" |
- |
-#include <stdint.h> |
- |
-#include "base/bind.h" |
-#include "base/logging.h" |
- |
-namespace mojo { |
- |
-struct WebSocketWriteQueue::Operation { |
- uint32_t num_bytes_; |
- base::Callback<void(const char*)> callback_; |
- |
- const char* data_; |
- // Only initialized if the initial Write fails. This saves a copy in |
- // the common case. |
- std::vector<char> data_copy_; |
-}; |
- |
-WebSocketWriteQueue::WebSocketWriteQueue(DataPipeProducerHandle handle) |
- : handle_(handle), is_busy_(false), weak_factory_(this) { |
-} |
- |
-WebSocketWriteQueue::~WebSocketWriteQueue() { |
-} |
- |
-void WebSocketWriteQueue::Write(const char* data, |
- uint32_t num_bytes, |
- base::Callback<void(const char*)> callback) { |
- Operation* op = new Operation; |
- op->num_bytes_ = num_bytes; |
- op->callback_ = callback; |
- op->data_ = data; |
- queue_.push_back(op); |
- |
- if (!is_busy_) { |
- is_busy_ = true; |
- // This call may reset |is_busy_| to false. |
- TryToWrite(); |
- } |
- |
- if (is_busy_) { |
- // If we have to wait, make a local copy of the data so we know it will |
- // live until we need it. |
- op->data_copy_.resize(num_bytes); |
- memcpy(&op->data_copy_[0], data, num_bytes); |
- op->data_ = &op->data_copy_[0]; |
- } |
-} |
- |
-void WebSocketWriteQueue::TryToWrite() { |
- DCHECK(is_busy_); |
- DCHECK(!queue_.empty()); |
- do { |
- Operation* op = queue_[0]; |
- uint32_t bytes_written = op->num_bytes_; |
- MojoResult result = WriteDataRaw( |
- handle_, op->data_, &bytes_written, MOJO_WRITE_DATA_FLAG_ALL_OR_NONE); |
- if (result == MOJO_RESULT_SHOULD_WAIT) { |
- Wait(); |
- return; |
- } |
- |
- // Ensure |op| is deleted, whether or not |this| goes away. |
- scoped_ptr<Operation> op_deleter(op); |
- queue_.weak_erase(queue_.begin()); |
- |
- // http://crbug.com/490193 This should run callback as well. May need to |
- // change the callback signature. |
- if (result != MOJO_RESULT_OK) |
- return; |
- |
- base::WeakPtr<WebSocketWriteQueue> self(weak_factory_.GetWeakPtr()); |
- |
- // This call may delete |this|. In that case, |self| will be invalidated. |
- // It may re-enter Write() too. Because |is_busy_| is true during the whole |
- // process, TryToWrite() won't be re-entered. |
- op->callback_.Run(op->data_); |
- |
- if (!self) |
- return; |
- } while (!queue_.empty()); |
- is_busy_ = false; |
-} |
- |
-void WebSocketWriteQueue::Wait() { |
- DCHECK(is_busy_); |
- handle_watcher_.Start(handle_, |
- MOJO_HANDLE_SIGNAL_WRITABLE, |
- MOJO_DEADLINE_INDEFINITE, |
- base::Bind(&WebSocketWriteQueue::OnHandleReady, |
- base::Unretained(this))); |
-} |
- |
-void WebSocketWriteQueue::OnHandleReady(MojoResult result) { |
- DCHECK(is_busy_); |
- TryToWrite(); |
-} |
- |
-} // namespace mojo |