Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(51)

Unified Diff: extensions/renderer/api/serial/data_receiver_unittest.cc

Issue 2410743002: Remove the mojo serial interfaces and related infrastructure. (Closed)
Patch Set: Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « extensions/renderer/api/serial/DEPS ('k') | extensions/renderer/api/serial/data_sender_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: extensions/renderer/api/serial/data_receiver_unittest.cc
diff --git a/extensions/renderer/api/serial/data_receiver_unittest.cc b/extensions/renderer/api/serial/data_receiver_unittest.cc
deleted file mode 100644
index 274909933f2fdda7fb0a1fa3f0167133bb8ec252..0000000000000000000000000000000000000000
--- a/extensions/renderer/api/serial/data_receiver_unittest.cc
+++ /dev/null
@@ -1,202 +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 <stdint.h>
-
-#include <queue>
-#include <utility>
-
-#include "base/macros.h"
-#include "device/serial/data_source_sender.h"
-#include "device/serial/data_stream.mojom.h"
-#include "extensions/renderer/api_test_base.h"
-#include "gin/dictionary.h"
-#include "gin/wrappable.h"
-#include "grit/extensions_renderer_resources.h"
-#include "mojo/edk/js/handle.h"
-
-namespace extensions {
-
-class DataReceiverFactory : public gin::Wrappable<DataReceiverFactory> {
- public:
- using Callback = base::Callback<void(
- mojo::InterfaceRequest<device::serial::DataSource>,
- mojo::InterfacePtr<device::serial::DataSourceClient>)>;
- static gin::Handle<DataReceiverFactory> Create(v8::Isolate* isolate,
- const Callback& callback) {
- return gin::CreateHandle(isolate,
- new DataReceiverFactory(callback, isolate));
- }
-
- gin::ObjectTemplateBuilder GetObjectTemplateBuilder(
- v8::Isolate* isolate) override {
- return Wrappable<DataReceiverFactory>::GetObjectTemplateBuilder(isolate)
- .SetMethod("create", &DataReceiverFactory::CreateReceiver);
- }
-
- gin::Dictionary CreateReceiver() {
- mojo::InterfacePtr<device::serial::DataSource> sink;
- mojo::InterfacePtr<device::serial::DataSourceClient> client;
- mojo::InterfaceRequest<device::serial::DataSourceClient> client_request =
- mojo::GetProxy(&client);
- callback_.Run(mojo::GetProxy(&sink), std::move(client));
-
- gin::Dictionary result = gin::Dictionary::CreateEmpty(isolate_);
- result.Set("source", sink.PassInterface().PassHandle().release());
- result.Set("client", client_request.PassMessagePipe().release());
- return result;
- }
-
- static gin::WrapperInfo kWrapperInfo;
-
- private:
- DataReceiverFactory(const Callback& callback, v8::Isolate* isolate)
- : callback_(callback), isolate_(isolate) {}
-
- base::Callback<void(mojo::InterfaceRequest<device::serial::DataSource>,
- mojo::InterfacePtr<device::serial::DataSourceClient>)>
- callback_;
- v8::Isolate* isolate_;
-};
-
-gin::WrapperInfo DataReceiverFactory::kWrapperInfo = {gin::kEmbedderNativeGin};
-
-// Runs tests defined in extensions/test/data/data_receiver_unittest.js
-class DataReceiverTest : public ApiTestBase {
- public:
- DataReceiverTest() {}
-
- void SetUp() override {
- ApiTestBase::SetUp();
- gin::ModuleRegistry::From(env()->context()->v8_context())
- ->AddBuiltinModule(env()->isolate(),
- "device/serial/data_receiver_test_factory",
- DataReceiverFactory::Create(
- env()->isolate(),
- base::Bind(&DataReceiverTest::CreateDataSource,
- base::Unretained(this))).ToV8());
- }
-
- void TearDown() override {
- if (sender_.get()) {
- sender_->ShutDown();
- sender_ = NULL;
- }
- ApiTestBase::TearDown();
- }
-
- std::queue<int32_t> error_to_send_;
- std::queue<std::string> data_to_send_;
-
- private:
- void CreateDataSource(
- mojo::InterfaceRequest<device::serial::DataSource> request,
- mojo::InterfacePtr<device::serial::DataSourceClient> client) {
- sender_ = new device::DataSourceSender(
- std::move(request), std::move(client),
- base::Bind(&DataReceiverTest::ReadyToSend, base::Unretained(this)),
- base::Bind(base::DoNothing));
- }
-
- void ReadyToSend(std::unique_ptr<device::WritableBuffer> buffer) {
- if (data_to_send_.empty() && error_to_send_.empty())
- return;
-
- std::string data;
- int32_t error = 0;
- if (!data_to_send_.empty()) {
- data = data_to_send_.front();
- data_to_send_.pop();
- }
- if (!error_to_send_.empty()) {
- error = error_to_send_.front();
- error_to_send_.pop();
- }
- DCHECK(buffer->GetSize() >= static_cast<uint32_t>(data.size()));
- memcpy(buffer->GetData(), data.c_str(), data.size());
- if (error)
- buffer->DoneWithError(static_cast<uint32_t>(data.size()), error);
- else
- buffer->Done(static_cast<uint32_t>(data.size()));
- }
-
- scoped_refptr<device::DataSourceSender> sender_;
-
- DISALLOW_COPY_AND_ASSIGN(DataReceiverTest);
-};
-
-// https://crbug.com/599898
-#if defined(LEAK_SANITIZER)
-#define MAYBE_Receive DISABLED_Receive
-#else
-#define MAYBE_Receive Receive
-#endif
-TEST_F(DataReceiverTest, MAYBE_Receive) {
- data_to_send_.push("a");
- RunTest("data_receiver_unittest.js", "testReceive");
-}
-
-// https://crbug.com/599898
-#if defined(LEAK_SANITIZER)
-#define MAYBE_ReceiveError DISABLED_ReceiveError
-#else
-#define MAYBE_ReceiveError ReceiveError
-#endif
-TEST_F(DataReceiverTest, MAYBE_ReceiveError) {
- error_to_send_.push(1);
- RunTest("data_receiver_unittest.js", "testReceiveError");
-}
-
-TEST_F(DataReceiverTest, ReceiveDataAndError) {
- data_to_send_.push("a");
- data_to_send_.push("b");
- error_to_send_.push(1);
- RunTest("data_receiver_unittest.js", "testReceiveDataAndError");
-}
-
-TEST_F(DataReceiverTest, ReceiveErrorThenData) {
- data_to_send_.push("");
- data_to_send_.push("a");
- error_to_send_.push(1);
- RunTest("data_receiver_unittest.js", "testReceiveErrorThenData");
-}
-
-TEST_F(DataReceiverTest, ReceiveBeforeAndAfterSerialization) {
- data_to_send_.push("a");
- data_to_send_.push("b");
- RunTest("data_receiver_unittest.js",
- "testReceiveBeforeAndAfterSerialization");
-}
-
-TEST_F(DataReceiverTest, ReceiveErrorSerialization) {
- error_to_send_.push(1);
- error_to_send_.push(3);
- RunTest("data_receiver_unittest.js", "testReceiveErrorSerialization");
-}
-
-TEST_F(DataReceiverTest, ReceiveDataAndErrorSerialization) {
- data_to_send_.push("a");
- data_to_send_.push("b");
- error_to_send_.push(1);
- error_to_send_.push(3);
- RunTest("data_receiver_unittest.js", "testReceiveDataAndErrorSerialization");
-}
-
-TEST_F(DataReceiverTest, SerializeDuringReceive) {
- data_to_send_.push("a");
- RunTest("data_receiver_unittest.js", "testSerializeDuringReceive");
-}
-
-// https://crbug.com/599898
-#if defined(LEAK_SANITIZER)
-#define MAYBE_SerializeAfterClose DISABLED_SerializeAfterClose
-#else
-#define MAYBE_SerializeAfterClose SerializeAfterClose
-#endif
-TEST_F(DataReceiverTest, MAYBE_SerializeAfterClose) {
- data_to_send_.push("a");
- RunTest("data_receiver_unittest.js", "testSerializeAfterClose");
-}
-
-} // namespace extensions
« no previous file with comments | « extensions/renderer/api/serial/DEPS ('k') | extensions/renderer/api/serial/data_sender_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698