Implementation and fixes for Blimp client/engine E2E communication.

blimp/net/browser_connection_handler_unittest.cc

 // 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 <stddef.h>
 #include <string>
 
 #include "base/callback_helpers.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
@@ skipping 59 matching lines @@
                             public BlimpMessageProcessor {
  public:
   FakeBlimpConnection() {}
   ~FakeBlimpConnection() override {}
 
   void set_other_end(FakeBlimpConnection* other_end) { other_end_ = other_end; }
 
   ConnectionErrorObserver* error_observer() { return error_observer_; }
 
   // BlimpConnection implementation.
-  void SetConnectionErrorObserver(ConnectionErrorObserver* observer) override {
+  void AddConnectionErrorObserver(ConnectionErrorObserver* observer) override {
     error_observer_ = observer;
   }
 
   void SetIncomingMessageProcessor(BlimpMessageProcessor* processor) override {
     incoming_message_processor_ = processor;
   }
 
   BlimpMessageProcessor* GetOutgoingMessageProcessor() override { return this; }
 
  private:
@@ skipping 111 matching lines @@
       std::move(client_input_message), net::CompletionCallback());
 }
 
 TEST_F(BrowserConnectionHandlerTest, ReconnectionAfterError) {
   scoped_ptr<BlimpMessage> client_input_message = CreateInputMessage(1);
   EXPECT_CALL(
       *(engine_input_feature_->incoming_message_processor()),
       MockableProcessMessage(EqualsMessageIgnoringId(*client_input_message), _))
       .RetiresOnSaturation();
 
+  // Simulate a connection failure.
   client_connection_->error_observer()->OnConnectionError(net::ERR_FAILED);
+  engine_connection_->error_observer()->OnConnectionError(net::ERR_FAILED);
+
   // Message will be queued to be transmitted when the connection is
   // re-established.
   client_input_feature_->outgoing_message_processor()->ProcessMessage(
       std::move(client_input_message), net::CompletionCallback());
 
   // Simulates reconnection.
   SetupConnections();
 }
 
 }  // namespace
 }  // namespace blimp