Retry: sync: Gracefully handle early shutdown

sync/engine/syncer_proto_util_unittest.cc

 // Copyright (c) 2012 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 "sync/engine/syncer_proto_util.h"
 
 #include <string>
 
 #include "base/basictypes.h"
 #include "base/compiler_specific.h"
 #include "base/message_loop/message_loop.h"
 #include "base/time/time.h"
+#include "sync/internal_api/public/base/cancelation_signal.h"
 #include "sync/internal_api/public/base/model_type_test_util.h"
 #include "sync/protocol/bookmark_specifics.pb.h"
 #include "sync/protocol/password_specifics.pb.h"
 #include "sync/protocol/sync.pb.h"
 #include "sync/protocol/sync_enums.pb.h"
 #include "sync/sessions/sync_session_context.h"
 #include "sync/syncable/blob.h"
 #include "sync/syncable/directory.h"
 #include "sync/test/engine/mock_connection_manager.h"
 #include "sync/test/engine/test_directory_setter_upper.h"
@@ skipping 224 matching lines @@
   SyncerProtoUtil::AddRequestBirthday(directory(), &msg);
   EXPECT_FALSE(msg.has_store_birthday());
 
   directory()->set_store_birthday("meat");
   SyncerProtoUtil::AddRequestBirthday(directory(), &msg);
   EXPECT_EQ(msg.store_birthday(), "meat");
 }
 
 class DummyConnectionManager : public ServerConnectionManager {
  public:
-  DummyConnectionManager()
-      : ServerConnectionManager("unused", 0, false, false),
+  DummyConnectionManager(CancelationSignal* signal)
+      : ServerConnectionManager("unused", 0, false, false, signal),
         send_error_(false),
         access_denied_(false) {}
 
   virtual ~DummyConnectionManager() {}
   virtual bool PostBufferWithCachedAuth(
       PostBufferParams* params,
       ScopedServerStatusWatcher* watcher) OVERRIDE {
     if (send_error_) {
       return false;
     }
@@ skipping 14 matching lines @@
   void set_access_denied(bool denied) {
     access_denied_ = denied;
   }
 
  private:
   bool send_error_;
   bool access_denied_;
 };
 
 TEST_F(SyncerProtoUtilTest, PostAndProcessHeaders) {
-  DummyConnectionManager dcm;
+  CancelationSignal signal;
+  DummyConnectionManager dcm(&signal);
   ClientToServerMessage msg;
   SyncerProtoUtil::SetProtocolVersion(&msg);
   msg.set_share("required");
   msg.set_message_contents(ClientToServerMessage::GET_UPDATES);
   sync_pb::ClientToServerResponse response;
 
   dcm.set_send_error(true);
   EXPECT_FALSE(SyncerProtoUtil::PostAndProcessHeaders(&dcm, NULL,
       msg, &response));
 
   dcm.set_send_error(false);
   EXPECT_TRUE(SyncerProtoUtil::PostAndProcessHeaders(&dcm, NULL,
       msg, &response));
 
   dcm.set_access_denied(true);
   EXPECT_FALSE(SyncerProtoUtil::PostAndProcessHeaders(&dcm, NULL,
       msg, &response));
 }
 
 }  // namespace syncer