OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "google_apis/gcm/gcm_client_impl.h" | 5 #include "google_apis/gcm/gcm_client_impl.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/files/file_path.h" | 8 #include "base/files/file_path.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
(...skipping 268 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
279 // TODO(fgorski): Reset the checkin timer. | 279 // TODO(fgorski): Reset the checkin timer. |
280 } | 280 } |
281 } | 281 } |
282 } | 282 } |
283 | 283 |
284 void GCMClientImpl::SetDeviceCredentialsCallback(bool success) { | 284 void GCMClientImpl::SetDeviceCredentialsCallback(bool success) { |
285 // TODO(fgorski): This is one of the signals that store needs a rebuild. | 285 // TODO(fgorski): This is one of the signals that store needs a rebuild. |
286 DCHECK(success); | 286 DCHECK(success); |
287 } | 287 } |
288 | 288 |
289 void GCMClientImpl::CheckOut() { | 289 void GCMClientImpl::Stop() { |
290 device_checkin_info_.Reset(); | 290 device_checkin_info_.Reset(); |
291 mcs_client_.reset(); | 291 mcs_client_.reset(); |
292 gcm_store_->Destroy(base::Bind(&GCMClientImpl::OnGCMStoreDestroyed, | |
293 weak_ptr_factory_.GetWeakPtr())); | |
294 checkin_request_.reset(); | 292 checkin_request_.reset(); |
295 pending_registrations_.clear(); | 293 pending_registrations_.clear(); |
296 state_ = INITIALIZED; | 294 state_ = INITIALIZED; |
| 295 gcm_store_->Close(); |
| 296 } |
| 297 |
| 298 void GCMClientImpl::CheckOut() { |
| 299 Stop(); |
| 300 gcm_store_->Destroy(base::Bind(&GCMClientImpl::OnGCMStoreDestroyed, |
| 301 weak_ptr_factory_.GetWeakPtr())); |
297 } | 302 } |
298 | 303 |
299 void GCMClientImpl::Register(const std::string& app_id, | 304 void GCMClientImpl::Register(const std::string& app_id, |
300 const std::string& cert, | 305 const std::string& cert, |
301 const std::vector<std::string>& sender_ids) { | 306 const std::vector<std::string>& sender_ids) { |
302 DCHECK_EQ(state_, READY); | 307 DCHECK_EQ(state_, READY); |
303 RegistrationRequest::RequestInfo request_info( | 308 RegistrationRequest::RequestInfo request_info( |
304 device_checkin_info_.android_id, | 309 device_checkin_info_.android_id, |
305 device_checkin_info_.secret, | 310 device_checkin_info_.secret, |
306 app_id, | 311 app_id, |
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
505 if (iter != incoming_message.data.end()) | 510 if (iter != incoming_message.data.end()) |
506 message_id = iter->second; | 511 message_id = iter->second; |
507 delegate->OnMessageSendError(app_id, message_id, SERVER_ERROR); | 512 delegate->OnMessageSendError(app_id, message_id, SERVER_ERROR); |
508 } | 513 } |
509 | 514 |
510 void GCMClientImpl::SetMCSClientForTesting(scoped_ptr<MCSClient> mcs_client) { | 515 void GCMClientImpl::SetMCSClientForTesting(scoped_ptr<MCSClient> mcs_client) { |
511 mcs_client_ = mcs_client.Pass(); | 516 mcs_client_ = mcs_client.Pass(); |
512 } | 517 } |
513 | 518 |
514 } // namespace gcm | 519 } // namespace gcm |
OLD | NEW |