wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

formatting fixes

This commit is contained in:
Nim Wijetunga 2021-02-10 13:19:59 -05:00
parent 7acfeda955
commit 270a18f089
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
fdbclient/NativeAPI.actor.cpp
View File

@ -2221,9 +2221,7 @@ ACTOR Future<Void> watchStorageServerResp(Key key, Database cx) {
loop {
try {
state Reference<WatchMetadata> metadata = cx->getWatchMetadata(key);
if (!metadata.isValid()) {
return Void();
}
if (!metadata.isValid()) return Void();
Version watchVersion = wait(watchValue(Future<Version>(metadata->version), key, metadata->value, cx, metadata->info, metadata->tags));
@ -2243,6 +2241,7 @@ ACTOR Future<Void> watchStorageServerResp(Key key, Database cx) {
if (e.code() == error_code_operation_cancelled) {
throw e;
}
Reference<WatchMetadata> metadata = cx->getWatchMetadata(key);
if (!metadata.isValid()) {
return Void();
@ -2259,7 +2258,6 @@ ACTOR Future<Void> sameVersionDiffValue(Version ver, Key key, Optional<Value> va
state ReadYourWritesTransaction tr(cx);
try {
tr.setOption( FDBTransactionOptions::READ_SYSTEM_KEYS );
state Optional<Value> valSS = wait(tr.get(key));
Reference<WatchMetadata> metadata = cx->getWatchMetadata(key);
@ -2280,10 +2278,7 @@ ACTOR Future<Void> sameVersionDiffValue(Version ver, Key key, Optional<Value> va
if (valSS != value) return Void(); // if val_3 != val_2
metadata = cx->getWatchMetadata(key);
if (metadata.isValid()) { // if val_3 == val_2
wait(success(metadata->watchPromise.getFuture()));
}
wait(success(metadata->watchPromise.getFuture())); // val_3 == val_2
return Void();
}