| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/sync/test/integration/sync_test.h" | 5 #include "chrome/browser/sync/test/integration/sync_test.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 91 const char kSyncServerCommandLine[] = "sync-server-command-line"; | 91 const char kSyncServerCommandLine[] = "sync-server-command-line"; |
| 92 } | 92 } |
| 93 | 93 |
| 94 namespace { | 94 namespace { |
| 95 | 95 |
| 96 // Helper class that checks whether a sync test server is running or not. | 96 // Helper class that checks whether a sync test server is running or not. |
| 97 class SyncServerStatusChecker : public net::URLFetcherDelegate { | 97 class SyncServerStatusChecker : public net::URLFetcherDelegate { |
| 98 public: | 98 public: |
| 99 SyncServerStatusChecker() : running_(false) {} | 99 SyncServerStatusChecker() : running_(false) {} |
| 100 | 100 |
| 101 virtual void OnURLFetchComplete(const net::URLFetcher* source) override { | 101 void OnURLFetchComplete(const net::URLFetcher* source) override { |
| 102 std::string data; | 102 std::string data; |
| 103 source->GetResponseAsString(&data); | 103 source->GetResponseAsString(&data); |
| 104 running_ = | 104 running_ = |
| 105 (source->GetStatus().status() == net::URLRequestStatus::SUCCESS && | 105 (source->GetStatus().status() == net::URLRequestStatus::SUCCESS && |
| 106 source->GetResponseCode() == 200 && data.find("ok") == 0); | 106 source->GetResponseCode() == 200 && data.find("ok") == 0); |
| 107 base::MessageLoop::current()->Quit(); | 107 base::MessageLoop::current()->Quit(); |
| 108 } | 108 } |
| 109 | 109 |
| 110 bool running() const { return running_; } | 110 bool running() const { return running_; } |
| 111 | 111 |
| 112 private: | 112 private: |
| 113 bool running_; | 113 bool running_; |
| 114 }; | 114 }; |
| 115 | 115 |
| 116 bool IsEncryptionComplete(const ProfileSyncService* service) { | 116 bool IsEncryptionComplete(const ProfileSyncService* service) { |
| 117 return service->EncryptEverythingEnabled() && !service->encryption_pending(); | 117 return service->EncryptEverythingEnabled() && !service->encryption_pending(); |
| 118 } | 118 } |
| 119 | 119 |
| 120 // Helper class to wait for encryption to complete. | 120 // Helper class to wait for encryption to complete. |
| 121 class EncryptionChecker : public SingleClientStatusChangeChecker { | 121 class EncryptionChecker : public SingleClientStatusChangeChecker { |
| 122 public: | 122 public: |
| 123 explicit EncryptionChecker(ProfileSyncService* service) | 123 explicit EncryptionChecker(ProfileSyncService* service) |
| 124 : SingleClientStatusChangeChecker(service) {} | 124 : SingleClientStatusChangeChecker(service) {} |
| 125 | 125 |
| 126 virtual bool IsExitConditionSatisfied() override { | 126 bool IsExitConditionSatisfied() override { |
| 127 return IsEncryptionComplete(service()); | 127 return IsEncryptionComplete(service()); |
| 128 } | 128 } |
| 129 | 129 |
| 130 virtual std::string GetDebugMessage() const override { | 130 std::string GetDebugMessage() const override { return "Encryption"; } |
| 131 return "Encryption"; | |
| 132 } | |
| 133 }; | 131 }; |
| 134 | 132 |
| 135 void SetupNetworkCallback( | 133 void SetupNetworkCallback( |
| 136 base::WaitableEvent* done, | 134 base::WaitableEvent* done, |
| 137 net::URLRequestContextGetter* url_request_context_getter) { | 135 net::URLRequestContextGetter* url_request_context_getter) { |
| 138 url_request_context_getter->GetURLRequestContext()-> | 136 url_request_context_getter->GetURLRequestContext()-> |
| 139 set_cookie_store(new net::CookieMonster(NULL, NULL)); | 137 set_cookie_store(new net::CookieMonster(NULL, NULL)); |
| 140 done->Signal(); | 138 done->Signal(); |
| 141 } | 139 } |
| 142 | 140 |
| (...skipping 781 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 924 BrowserThread::PostTask( | 922 BrowserThread::PostTask( |
| 925 BrowserThread::IO, FROM_HERE, | 923 BrowserThread::IO, FROM_HERE, |
| 926 base::Bind(&SetupNetworkCallback, &done, | 924 base::Bind(&SetupNetworkCallback, &done, |
| 927 make_scoped_refptr(context_getter))); | 925 make_scoped_refptr(context_getter))); |
| 928 done.Wait(); | 926 done.Wait(); |
| 929 } | 927 } |
| 930 | 928 |
| 931 fake_server::FakeServer* SyncTest::GetFakeServer() const { | 929 fake_server::FakeServer* SyncTest::GetFakeServer() const { |
| 932 return fake_server_.get(); | 930 return fake_server_.get(); |
| 933 } | 931 } |
| OLD | NEW |