Skip to content

Commit 965ac2f

Browse files
authored
Port some small code changes from firebase/firebase-js-sdk#7474 to be consistent with the web sdk (#5177)
1 parent f15e429 commit 965ac2f

File tree

2 files changed

+10
-9
lines changed

2 files changed

+10
-9
lines changed

firebase-firestore/src/main/java/com/google/firebase/firestore/remote/TestingHooks.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import com.google.auto.value.AutoValue;
2424
import com.google.firebase.firestore.ListenerRegistration;
2525
import com.google.firebase.firestore.model.DatabaseId;
26+
import com.google.firebase.firestore.remote.WatchChangeAggregator.BloomFilterApplicationStatus;
2627
import com.google.firestore.v1.BloomFilter;
2728
import java.util.concurrent.CopyOnWriteArrayList;
2829
import java.util.concurrent.atomic.AtomicReference;
@@ -168,13 +169,13 @@ static ExistenceFilterMismatchInfo from(
168169
ExistenceFilter existenceFilter,
169170
DatabaseId databaseId,
170171
@Nullable com.google.firebase.firestore.remote.BloomFilter bloomFilter,
171-
boolean bloomFilterApplied) {
172+
BloomFilterApplicationStatus bloomFilterStatus) {
172173
return create(
173174
localCacheCount,
174175
existenceFilter.getCount(),
175176
databaseId.getProjectId(),
176177
databaseId.getDatabaseId(),
177-
ExistenceFilterBloomFilterInfo.from(bloomFilter, bloomFilterApplied, existenceFilter));
178+
ExistenceFilterBloomFilterInfo.from(bloomFilter, bloomFilterStatus, existenceFilter));
178179
}
179180
}
180181

@@ -214,15 +215,15 @@ static ExistenceFilterBloomFilterInfo create(
214215
@Nullable
215216
static ExistenceFilterBloomFilterInfo from(
216217
@Nullable com.google.firebase.firestore.remote.BloomFilter bloomFilter,
217-
boolean bloomFilterApplied,
218+
BloomFilterApplicationStatus bloomFilterStatus,
218219
ExistenceFilter existenceFilter) {
219220
BloomFilter unchangedNames = existenceFilter.getUnchangedNames();
220221
if (unchangedNames == null) {
221222
return null;
222223
}
223224
return create(
224225
bloomFilter,
225-
bloomFilterApplied,
226+
/*bloomFilterApplied=*/ bloomFilterStatus == BloomFilterApplicationStatus.SUCCESS,
226227
unchangedNames.getHashCount(),
227228
unchangedNames.getBits().getBitmap().size(),
228229
unchangedNames.getBits().getPadding());

firebase-firestore/src/main/java/com/google/firebase/firestore/remote/WatchChangeAggregator.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public interface TargetMetadataProvider {
8585
private static final String LOG_TAG = "WatchChangeAggregator";
8686

8787
/** The bloom filter application status while handling existence filter mismatch. */
88-
private enum BloomFilterApplicationStatus {
88+
enum BloomFilterApplicationStatus {
8989
SUCCESS,
9090
SKIPPED,
9191
FALSE_POSITIVE
@@ -218,9 +218,9 @@ public void handleExistenceFilter(ExistenceFilterWatchChange watchChange) {
218218
// Apply bloom filter to identify and mark removed documents.
219219
BloomFilter bloomFilter = this.parseBloomFilter(watchChange);
220220
BloomFilterApplicationStatus status =
221-
bloomFilter == null
222-
? BloomFilterApplicationStatus.SKIPPED
223-
: this.applyBloomFilter(bloomFilter, watchChange, currentSize);
221+
bloomFilter != null
222+
? this.applyBloomFilter(bloomFilter, watchChange, currentSize)
223+
: BloomFilterApplicationStatus.SKIPPED;
224224

225225
if (status != BloomFilterApplicationStatus.SUCCESS) {
226226
// If bloom filter application fails, we reset the mapping and
@@ -242,7 +242,7 @@ public void handleExistenceFilter(ExistenceFilterWatchChange watchChange) {
242242
watchChange.getExistenceFilter(),
243243
targetMetadataProvider.getDatabaseId(),
244244
bloomFilter,
245-
/*bloomFilterApplied=*/ status == BloomFilterApplicationStatus.SUCCESS));
245+
status));
246246
}
247247
}
248248
}

0 commit comments

Comments
 (0)