components: Add Exosphere component.

components/exo/wayland/server_unittest.cc

Index: components/exo/wayland/server_unittest.cc
diff --git a/components/exo/wayland/server_unittest.cc b/components/exo/wayland/server_unittest.cc
new file mode 100644
index 0000000000000000000000000000000000000000..adc1dd446c76970aa972b9ad2c7208c8ea58243a
--- /dev/null
+++ b/components/exo/wayland/server_unittest.cc
@@ -0,0 +1,97 @@
+// Copyright 2015 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 <wayland-client-core.h>
+
+#include "base/atomic_sequence_num.h"
+#include "base/bind.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/process/process_handle.h"
+#include "base/strings/stringprintf.h"
+#include "base/threading/thread.h"
+#include "components/exo/display.h"
+#include "components/exo/wayland/server.h"
+#include "testing/gtest/include/gtest/gtest.h"
+
+namespace exo {
+namespace wayland {
+namespace {
+
+base::StaticAtomicSequenceNumber g_next_socket_id;
+
+std::string GetUniqueSocketName() {
+  return base::StringPrintf("wayland-test-%d-%d", base::GetCurrentProcId(),
+                            g_next_socket_id.GetNext());
+}
+
+TEST(ServerTest, AddSocket) {
+  scoped_ptr<Display> display(new Display);
+  scoped_ptr<Server> server(new Server(display.get()));
+
+  // Check that calling AddSocket() with a unique socket name succeeds.
+  bool rv = server->AddSocket(GetUniqueSocketName());
+  EXPECT_TRUE(rv);
+}
+
+TEST(ServerTest, GetFileDescriptor) {
+  scoped_ptr<Display> display(new Display);
+  scoped_ptr<Server> server(new Server(display.get()));
+
+  bool rv = server->AddSocket(GetUniqueSocketName());
+  EXPECT_TRUE(rv);
+
+  // Check that the returned file descriptor is valid.
+  int fd = server->GetFileDescriptor();
+  DCHECK_GE(fd, 0);
+}
+
+void ConnectToServer(const std::string socket_name,
+                     bool* connected_to_server,
+                     base::WaitableEvent* event) {
+  wl_display* display = wl_display_connect(socket_name.c_str());
+  *connected_to_server = !!display;
+  event->Signal();
+  wl_display_disconnect(display);
+}
+
+TEST(ServerTest, Dispatch) {
+  scoped_ptr<Display> display(new Display);
+  scoped_ptr<Server> server(new Server(display.get()));
+
+  std::string socket_name = GetUniqueSocketName();
+  bool rv = server->AddSocket(socket_name);
+  EXPECT_TRUE(rv);
+
+  base::Thread client("client-" + socket_name);
+  ASSERT_TRUE(client.Start());
+
+  // Post a task that connects server on the created thread.
+  bool connected_to_server = false;
+  base::WaitableEvent event(false, false);
+  client.task_runner()->PostTask(
+      FROM_HERE,
+      base::Bind(&ConnectToServer, socket_name, &connected_to_server, &event));
+
+  // Call Dispatch() with a 5 second timeout.
+  server->Dispatch(base::TimeDelta::FromSeconds(5));
+
+  // Check if client thread managed to connect to server.
+  event.Wait();
+  EXPECT_TRUE(connected_to_server);
+}
+
+TEST(ServerTest, Flush) {
+  scoped_ptr<Display> display(new Display);
+  scoped_ptr<Server> server(new Server(display.get()));
+
+  bool rv = server->AddSocket(GetUniqueSocketName());
+  EXPECT_TRUE(rv);
+
+  // Just call Flush to check that it doesn't have any bad side-effects.
+  server->Flush();
+}
+
+}  // namespace
+}  // namespace wayland
+}  // namespace exo