| 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 "components/invalidation/impl/invalidation_service_android.h" | 5 #include "components/invalidation/impl/invalidation_service_android.h" |
| 6 | 6 |
| 7 #include "base/android/jni_android.h" | 7 #include "base/android/jni_android.h" |
| 8 #include "base/android/jni_array.h" | 8 #include "base/android/jni_array.h" |
| 9 #include "base/android/jni_string.h" | 9 #include "base/android/jni_string.h" |
| 10 #include "base/callback.h" | 10 #include "base/callback.h" |
| 11 #include "components/invalidation/public/object_id_invalidation_map.h" | 11 #include "components/invalidation/public/object_id_invalidation_map.h" |
| 12 #include "google/cacheinvalidation/types.pb.h" | 12 #include "google/cacheinvalidation/types.pb.h" |
| 13 #include "jni/InvalidationService_jni.h" | 13 #include "jni/InvalidationService_jni.h" |
| 14 | 14 |
| 15 using base::android::ConvertJavaStringToUTF8; | 15 using base::android::ConvertJavaStringToUTF8; |
| 16 using base::android::ConvertUTF8ToJavaString; | 16 using base::android::ConvertUTF8ToJavaString; |
| 17 using base::android::JavaRef; | 17 using base::android::JavaRef; |
| 18 using base::android::JavaParamRef; | 18 using base::android::JavaParamRef; |
| 19 | 19 |
| 20 namespace invalidation { | 20 namespace invalidation { |
| 21 | 21 |
| 22 InvalidationServiceAndroid::InvalidationServiceAndroid() | 22 InvalidationServiceAndroid::InvalidationServiceAndroid() |
| 23 : invalidator_state_(syncer::INVALIDATIONS_ENABLED), logger_() { | 23 : invalidator_state_(syncer::INVALIDATIONS_ENABLED), logger_() { |
| 24 DCHECK(CalledOnValidThread()); | 24 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 25 JNIEnv* env = base::android::AttachCurrentThread(); | 25 JNIEnv* env = base::android::AttachCurrentThread(); |
| 26 base::android::ScopedJavaLocalRef<jobject> local_java_ref = | 26 base::android::ScopedJavaLocalRef<jobject> local_java_ref = |
| 27 Java_InvalidationService_create(env, reinterpret_cast<intptr_t>(this)); | 27 Java_InvalidationService_create(env, reinterpret_cast<intptr_t>(this)); |
| 28 java_ref_.Reset(env, local_java_ref.obj()); | 28 java_ref_.Reset(env, local_java_ref.obj()); |
| 29 logger_.OnStateChange(invalidator_state_); | 29 logger_.OnStateChange(invalidator_state_); |
| 30 } | 30 } |
| 31 | 31 |
| 32 InvalidationServiceAndroid::~InvalidationServiceAndroid() { } | 32 InvalidationServiceAndroid::~InvalidationServiceAndroid() { |
| 33 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 34 } |
| 33 | 35 |
| 34 void InvalidationServiceAndroid::RegisterInvalidationHandler( | 36 void InvalidationServiceAndroid::RegisterInvalidationHandler( |
| 35 syncer::InvalidationHandler* handler) { | 37 syncer::InvalidationHandler* handler) { |
| 36 DCHECK(CalledOnValidThread()); | 38 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 37 invalidator_registrar_.RegisterHandler(handler); | 39 invalidator_registrar_.RegisterHandler(handler); |
| 38 logger_.OnRegistration(handler->GetOwnerName()); | 40 logger_.OnRegistration(handler->GetOwnerName()); |
| 39 } | 41 } |
| 40 | 42 |
| 41 bool InvalidationServiceAndroid::UpdateRegisteredInvalidationIds( | 43 bool InvalidationServiceAndroid::UpdateRegisteredInvalidationIds( |
| 42 syncer::InvalidationHandler* handler, | 44 syncer::InvalidationHandler* handler, |
| 43 const syncer::ObjectIdSet& ids) { | 45 const syncer::ObjectIdSet& ids) { |
| 44 DCHECK(CalledOnValidThread()); | 46 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 45 JNIEnv* env = base::android::AttachCurrentThread(); | 47 JNIEnv* env = base::android::AttachCurrentThread(); |
| 46 DCHECK(env); | 48 DCHECK(env); |
| 47 | 49 |
| 48 if (!invalidator_registrar_.UpdateRegisteredIds(handler, ids)) | 50 if (!invalidator_registrar_.UpdateRegisteredIds(handler, ids)) |
| 49 return false; | 51 return false; |
| 50 const syncer::ObjectIdSet& registered_ids = | 52 const syncer::ObjectIdSet& registered_ids = |
| 51 invalidator_registrar_.GetAllRegisteredIds(); | 53 invalidator_registrar_.GetAllRegisteredIds(); |
| 52 | 54 |
| 53 // To call the corresponding method on the Java invalidation service, split | 55 // To call the corresponding method on the Java invalidation service, split |
| 54 // the object ids into object source and object name arrays. | 56 // the object ids into object source and object name arrays. |
| 55 std::vector<int> sources; | 57 std::vector<int> sources; |
| 56 std::vector<std::string> names; | 58 std::vector<std::string> names; |
| 57 syncer::ObjectIdSet::const_iterator id; | 59 syncer::ObjectIdSet::const_iterator id; |
| 58 for (id = registered_ids.begin(); id != registered_ids.end(); ++id) { | 60 for (id = registered_ids.begin(); id != registered_ids.end(); ++id) { |
| 59 sources.push_back(id->source()); | 61 sources.push_back(id->source()); |
| 60 names.push_back(id->name()); | 62 names.push_back(id->name()); |
| 61 } | 63 } |
| 62 | 64 |
| 63 Java_InvalidationService_setRegisteredObjectIds( | 65 Java_InvalidationService_setRegisteredObjectIds( |
| 64 env, java_ref_, base::android::ToJavaIntArray(env, sources), | 66 env, java_ref_, base::android::ToJavaIntArray(env, sources), |
| 65 base::android::ToJavaArrayOfStrings(env, names)); | 67 base::android::ToJavaArrayOfStrings(env, names)); |
| 66 | 68 |
| 67 logger_.OnUpdateIds(invalidator_registrar_.GetSanitizedHandlersIdsMap()); | 69 logger_.OnUpdateIds(invalidator_registrar_.GetSanitizedHandlersIdsMap()); |
| 68 return true; | 70 return true; |
| 69 } | 71 } |
| 70 | 72 |
| 71 void InvalidationServiceAndroid::UnregisterInvalidationHandler( | 73 void InvalidationServiceAndroid::UnregisterInvalidationHandler( |
| 72 syncer::InvalidationHandler* handler) { | 74 syncer::InvalidationHandler* handler) { |
| 73 DCHECK(CalledOnValidThread()); | 75 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 74 invalidator_registrar_.UnregisterHandler(handler); | 76 invalidator_registrar_.UnregisterHandler(handler); |
| 75 logger_.OnUnregistration(handler->GetOwnerName()); | 77 logger_.OnUnregistration(handler->GetOwnerName()); |
| 76 } | 78 } |
| 77 | 79 |
| 78 syncer::InvalidatorState | 80 syncer::InvalidatorState |
| 79 InvalidationServiceAndroid::GetInvalidatorState() const { | 81 InvalidationServiceAndroid::GetInvalidatorState() const { |
| 80 DCHECK(CalledOnValidThread()); | 82 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 81 return invalidator_state_; | 83 return invalidator_state_; |
| 82 } | 84 } |
| 83 | 85 |
| 84 std::string InvalidationServiceAndroid::GetInvalidatorClientId() const { | 86 std::string InvalidationServiceAndroid::GetInvalidatorClientId() const { |
| 85 DCHECK(CalledOnValidThread()); | 87 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 86 JNIEnv* env = base::android::AttachCurrentThread(); | 88 JNIEnv* env = base::android::AttachCurrentThread(); |
| 87 DCHECK(env); | 89 DCHECK(env); |
| 88 | 90 |
| 89 // Ask the Java code to for the invalidator ID it's currently using. | 91 // Ask the Java code to for the invalidator ID it's currently using. |
| 90 base::android::ScopedJavaLocalRef<_jbyteArray*> id_bytes_java = | 92 base::android::ScopedJavaLocalRef<_jbyteArray*> id_bytes_java = |
| 91 Java_InvalidationService_getInvalidatorClientId(env, java_ref_); | 93 Java_InvalidationService_getInvalidatorClientId(env, java_ref_); |
| 92 | 94 |
| 93 // Convert it into a more convenient format for C++. | 95 // Convert it into a more convenient format for C++. |
| 94 std::vector<uint8_t> id_bytes; | 96 std::vector<uint8_t> id_bytes; |
| 95 base::android::JavaByteArrayToByteVector(env, id_bytes_java.obj(), &id_bytes); | 97 base::android::JavaByteArrayToByteVector(env, id_bytes_java.obj(), &id_bytes); |
| 96 std::string id(id_bytes.begin(), id_bytes.end()); | 98 std::string id(id_bytes.begin(), id_bytes.end()); |
| 97 | 99 |
| 98 return id; | 100 return id; |
| 99 } | 101 } |
| 100 | 102 |
| 101 InvalidationLogger* InvalidationServiceAndroid::GetInvalidationLogger() { | 103 InvalidationLogger* InvalidationServiceAndroid::GetInvalidationLogger() { |
| 102 return &logger_; | 104 return &logger_; |
| 103 } | 105 } |
| 104 | 106 |
| 105 void InvalidationServiceAndroid::RequestDetailedStatus( | 107 void InvalidationServiceAndroid::RequestDetailedStatus( |
| 106 base::Callback<void(const base::DictionaryValue&)> return_callback) const { | 108 base::Callback<void(const base::DictionaryValue&)> return_callback) const { |
| 107 } | 109 } |
| 108 | 110 |
| 109 IdentityProvider* InvalidationServiceAndroid::GetIdentityProvider() { | 111 IdentityProvider* InvalidationServiceAndroid::GetIdentityProvider() { |
| 110 return NULL; | 112 return NULL; |
| 111 } | 113 } |
| 112 | 114 |
| 113 void InvalidationServiceAndroid::TriggerStateChangeForTest( | 115 void InvalidationServiceAndroid::TriggerStateChangeForTest( |
| 114 syncer::InvalidatorState state) { | 116 syncer::InvalidatorState state) { |
| 115 DCHECK(CalledOnValidThread()); | 117 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
| 116 invalidator_state_ = state; | 118 invalidator_state_ = state; |
| 117 invalidator_registrar_.UpdateInvalidatorState(invalidator_state_); | 119 invalidator_registrar_.UpdateInvalidatorState(invalidator_state_); |
| 118 } | 120 } |
| 119 | 121 |
| 120 void InvalidationServiceAndroid::Invalidate( | 122 void InvalidationServiceAndroid::Invalidate( |
| 121 JNIEnv* env, | 123 JNIEnv* env, |
| 122 const JavaParamRef<jobject>& obj, | 124 const JavaParamRef<jobject>& obj, |
| 123 jint object_source, | 125 jint object_source, |
| 124 const JavaParamRef<jstring>& java_object_id, | 126 const JavaParamRef<jstring>& java_object_id, |
| 125 jlong version, | 127 jlong version, |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 165 object_invalidation_map); | 167 object_invalidation_map); |
| 166 logger_.OnInvalidation(object_invalidation_map); | 168 logger_.OnInvalidation(object_invalidation_map); |
| 167 } | 169 } |
| 168 | 170 |
| 169 // static | 171 // static |
| 170 bool InvalidationServiceAndroid::RegisterJni(JNIEnv* env) { | 172 bool InvalidationServiceAndroid::RegisterJni(JNIEnv* env) { |
| 171 return RegisterNativesImpl(env); | 173 return RegisterNativesImpl(env); |
| 172 } | 174 } |
| 173 | 175 |
| 174 } // namespace invalidation | 176 } // namespace invalidation |
| OLD | NEW |