Mojo: Add ErrorHandler to RemotePtr

mojo/public/bindings/tests/connector_unittest.cc

 // Copyright 2013 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 <stdlib.h>
 #include <string.h>
 
 #include "mojo/public/bindings/lib/connector.h"
 #include "mojo/public/bindings/lib/message_queue.h"
 #include "mojo/public/environment/environment.h"
@@ skipping 65 matching lines @@
   internal::Connector connector1(handle1_.Pass());
 
   const char kText[] = "hello world";
 
   Message message;
   AllocMessage(kText, &message);
 
   connector0.Accept(&message);
 
   MessageAccumulator accumulator;
-  connector1.SetIncomingReceiver(&accumulator);
+  connector1.set_incoming_receiver(&accumulator);
 
   PumpMessages();
 
   ASSERT_FALSE(accumulator.IsEmpty());
 
   Message message_received;
   accumulator.Pop(&message_received);
 
   EXPECT_EQ(std::string(kText),
             std::string(
                 reinterpret_cast<char*>(message_received.data->payload)));
 }
 
 TEST_F(ConnectorTest, Basic_EarlyIncomingReceiver) {
   internal::Connector connector0(handle0_.Pass());
   internal::Connector connector1(handle1_.Pass());
 
   MessageAccumulator accumulator;
-  connector1.SetIncomingReceiver(&accumulator);
+  connector1.set_incoming_receiver(&accumulator);
 
   const char kText[] = "hello world";
 
   Message message;
   AllocMessage(kText, &message);
 
   connector0.Accept(&message);
 
   PumpMessages();
 
@@ skipping 14 matching lines @@
   const char* kText[] = { "hello", "world" };
 
   for (size_t i = 0; i < MOJO_ARRAYSIZE(kText); ++i) {
     Message message;
     AllocMessage(kText[i], &message);
 
     connector0.Accept(&message);
   }
 
   MessageAccumulator accumulator;
-  connector1.SetIncomingReceiver(&accumulator);
+  connector1.set_incoming_receiver(&accumulator);
 
   PumpMessages();
 
   for (size_t i = 0; i < MOJO_ARRAYSIZE(kText); ++i) {
     ASSERT_FALSE(accumulator.IsEmpty());
 
     Message message_received;
     accumulator.Pop(&message_received);
 
     EXPECT_EQ(std::string(kText[i]),
@@ skipping 34 matching lines @@
   ScopedMessagePipeHandle handles[2];
   CreateMessagePipe(&handles[0], &handles[1]);
   message.handles.push_back(handles[0].release());
 
   connector0.Accept(&message);
 
   // The message should have been transferred, releasing the handles.
   EXPECT_TRUE(message.handles.empty());
 
   MessageAccumulator accumulator;
-  connector1.SetIncomingReceiver(&accumulator);
+  connector1.set_incoming_receiver(&accumulator);
 
   PumpMessages();
 
   ASSERT_FALSE(accumulator.IsEmpty());
 
   Message message_received;
   accumulator.Pop(&message_received);
 
   EXPECT_EQ(std::string(kText),
             std::string(
                 reinterpret_cast<char*>(message_received.data->payload)));
   ASSERT_EQ(1U, message_received.handles.size());
 
   // Now send a message to the transferred handle and confirm it's sent through
   // to the orginal pipe.
   // TODO(vtl): Do we need a better way of "downcasting" the handle types?
   ScopedMessagePipeHandle smph;
   smph.reset(MessagePipeHandle(message_received.handles[0].value()));
   message_received.handles[0] = Handle();  // |smph| now owns this handle.
 
   internal::Connector connector_received(smph.Pass());
   internal::Connector connector_original(handles[1].Pass());
 
   AllocMessage(kText, &message);
 
   connector_received.Accept(&message);
-  connector_original.SetIncomingReceiver(&accumulator);
+  connector_original.set_incoming_receiver(&accumulator);
   PumpMessages();
 
   ASSERT_FALSE(accumulator.IsEmpty());
 
   accumulator.Pop(&message_received);
 
   EXPECT_EQ(std::string(kText),
             std::string(
                 reinterpret_cast<char*>(message_received.data->payload)));
 }
 
 }  // namespace test
 }  // namespace mojo