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 |