[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/system/platform_handle_dispatcher_unittest.cc

 // 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 "mojo/edk/system/platform_handle_dispatcher.h"
 
 #include <stdio.h>
 #include <utility>
 
 #include "base/files/file_path.h"
@@ skipping 41 matching lines @@
   rewind(fp.get());
   char read_buffer[1000] = {};
   EXPECT_EQ(sizeof(kHelloWorld),
             fread(read_buffer, 1, sizeof(read_buffer), fp.get()));
   EXPECT_STREQ(kHelloWorld, read_buffer);
 
   // Try getting the handle again. (It should fail cleanly.)
   h = dispatcher->PassPlatformHandle();
   EXPECT_FALSE(h.is_valid());
 
-  EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close());
+  Dispatcher::RequestContext request_context;
+  EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close(&request_context));
 }
 
 TEST(PlatformHandleDispatcherTest, Serialization) {
   base::ScopedTempDir temp_dir;
   ASSERT_TRUE(temp_dir.CreateUniqueTempDir());
 
   static const char kFooBar[] = "foo bar";
 
   base::FilePath unused;
   base::ScopedFILE fp(
       CreateAndOpenTemporaryFileInDir(temp_dir.path(), &unused));
   EXPECT_EQ(sizeof(kFooBar), fwrite(kFooBar, 1, sizeof(kFooBar), fp.get()));
 
   scoped_refptr<PlatformHandleDispatcher> dispatcher =
       PlatformHandleDispatcher::Create(
           test::PlatformHandleFromFILE(std::move(fp)));
 
+  Dispatcher::RequestContext request_context;
   uint32_t num_bytes = 0;
   uint32_t num_ports = 0;
   uint32_t num_handles = 0;
-  EXPECT_TRUE(dispatcher->BeginTransit());
+  EXPECT_TRUE(dispatcher->BeginTransit(&request_context));
   dispatcher->StartSerialize(&num_bytes, &num_ports, &num_handles);
 
   EXPECT_EQ(0u, num_bytes);
   EXPECT_EQ(0u, num_ports);
   EXPECT_EQ(1u, num_handles);
 
   ScopedPlatformHandleVectorPtr handles(new PlatformHandleVector(1));
   EXPECT_TRUE(dispatcher->EndSerialize(nullptr, nullptr, handles->data()));
-  dispatcher->CompleteTransitAndClose();
+  dispatcher->CompleteTransitAndClose(&request_context);
 
   EXPECT_TRUE(handles->at(0).is_valid());
 
   ScopedPlatformHandle handle = dispatcher->PassPlatformHandle();
   EXPECT_FALSE(handle.is_valid());
 
-  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dispatcher->Close());
+  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dispatcher->Close(&request_context));
 
   dispatcher = static_cast<PlatformHandleDispatcher*>(
       Dispatcher::Deserialize(Dispatcher::Type::PLATFORM_HANDLE, nullptr,
                               num_bytes, nullptr, num_ports, handles->data(),
                               1).get());
 
   EXPECT_FALSE(handles->at(0).is_valid());
   EXPECT_TRUE(dispatcher->GetType() == Dispatcher::Type::PLATFORM_HANDLE);
 
   fp = test::FILEFromPlatformHandle(dispatcher->PassPlatformHandle(), "rb");
   EXPECT_TRUE(fp);
 
   rewind(fp.get());
   char read_buffer[1000] = {};
   EXPECT_EQ(sizeof(kFooBar),
             fread(read_buffer, 1, sizeof(read_buffer), fp.get()));
   EXPECT_STREQ(kFooBar, read_buffer);
 
-  EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close());
+  EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close(&request_context));
 }
 
 }  // namespace
 }  // namespace edk
 }  // namespace mojo