OLD | NEW |
---|---|
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "base/bind.h" | 5 #include "base/bind.h" |
6 #include "base/location.h" | 6 #include "base/location.h" |
7 #include "base/macros.h" | 7 #include "base/macros.h" |
8 #include "base/memory/ptr_util.h" | 8 #include "base/memory/ptr_util.h" |
9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
10 #include "base/threading/thread_task_runner_handle.h" | 10 #include "base/threading/thread_task_runner_handle.h" |
(...skipping 301 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
312 core_, | 312 core_, |
313 gcm_driver_->IsConnected())); | 313 gcm_driver_->IsConnected())); |
314 | 314 |
315 subscribed_for_incoming_messages_ = true; | 315 subscribed_for_incoming_messages_ = true; |
316 } | 316 } |
317 | 317 |
318 void GCMInvalidationBridge::ShutdownHandler() { | 318 void GCMInvalidationBridge::ShutdownHandler() { |
319 // Nothing to do. | 319 // Nothing to do. |
320 } | 320 } |
321 | 321 |
322 void GCMInvalidationBridge::OnStoreReset() { | |
323 // Nothing to do here since CacheInvalidation doesn't locally persist | |
324 // registration ID, instead it just re-registers on every startup. | |
Peter Beverloo
2016/11/03 17:28:57
What about GCMNetworkChannel::registration_id_?
johnme
2016/11/08 19:22:41
Done - this was a little more involved, as I had t
| |
325 } | |
326 | |
322 void GCMInvalidationBridge::OnMessage(const std::string& app_id, | 327 void GCMInvalidationBridge::OnMessage(const std::string& app_id, |
323 const gcm::IncomingMessage& message) { | 328 const gcm::IncomingMessage& message) { |
324 gcm::MessageData::const_iterator it; | 329 gcm::MessageData::const_iterator it; |
325 std::string content; | 330 std::string content; |
326 std::string echo_token; | 331 std::string echo_token; |
327 it = message.data.find(kContentKey); | 332 it = message.data.find(kContentKey); |
328 if (it != message.data.end()) | 333 if (it != message.data.end()) |
329 content = it->second; | 334 content = it->second; |
330 it = message.data.find(kEchoTokenKey); | 335 it = message.data.find(kEchoTokenKey); |
331 if (it != message.data.end()) | 336 if (it != message.data.end()) |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
368 | 373 |
369 void GCMInvalidationBridge::OnDisconnected() { | 374 void GCMInvalidationBridge::OnDisconnected() { |
370 core_thread_task_runner_->PostTask( | 375 core_thread_task_runner_->PostTask( |
371 FROM_HERE, | 376 FROM_HERE, |
372 base::Bind(&GCMInvalidationBridge::Core::OnConnectionStateChanged, | 377 base::Bind(&GCMInvalidationBridge::Core::OnConnectionStateChanged, |
373 core_, | 378 core_, |
374 false)); | 379 false)); |
375 } | 380 } |
376 | 381 |
377 } // namespace invalidation | 382 } // namespace invalidation |
OLD | NEW |