| Index: components/invalidation/p2p_invalidator.cc
|
| diff --git a/components/invalidation/p2p_invalidator.cc b/components/invalidation/p2p_invalidator.cc
|
| index c583d440faabfa77ff4f48ea9e82e917d6b43282..9ab02fdb11c1cb12dbe2553fce62c23f275c9fef 100644
|
| --- a/components/invalidation/p2p_invalidator.cc
|
| +++ b/components/invalidation/p2p_invalidator.cc
|
| @@ -159,7 +159,7 @@ void P2PInvalidator::RegisterHandler(InvalidationHandler* handler) {
|
| registrar_.RegisterHandler(handler);
|
| }
|
|
|
| -void P2PInvalidator::UpdateRegisteredIds(InvalidationHandler* handler,
|
| +bool P2PInvalidator::UpdateRegisteredIds(InvalidationHandler* handler,
|
| const ObjectIdSet& ids) {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| ObjectIdSet new_ids;
|
| @@ -168,12 +168,14 @@ void P2PInvalidator::UpdateRegisteredIds(InvalidationHandler* handler,
|
| old_ids.begin(), old_ids.end(),
|
| std::inserter(new_ids, new_ids.end()),
|
| ObjectIdLessThan());
|
| - registrar_.UpdateRegisteredIds(handler, ids);
|
| + if (!registrar_.UpdateRegisteredIds(handler, ids))
|
| + return false;
|
| const P2PNotificationData notification_data(
|
| invalidator_client_id_,
|
| send_notification_target_,
|
| ObjectIdInvalidationMap::InvalidateAll(ids));
|
| SendNotificationData(notification_data);
|
| + return true;
|
| }
|
|
|
| void P2PInvalidator::UnregisterHandler(InvalidationHandler* handler) {
|
|
|