Skip to content

Commit

Permalink
fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
sfc-gh-jslocum committed Jan 11, 2023
1 parent aa0c52d commit e08d8f5
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions fdbserver/storageserver.actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3352,8 +3352,8 @@ ACTOR Future<Void> changeFeedStreamQ(StorageServer* data, ChangeFeedStreamReques
wait(onReady);

// keep this as not state variable so it is freed after sending to reduce memory
Future<std::pair<ChangeFeedStreamReply, bool>> feedReplyFuture =
getChangeFeedMutations(data, feedInfo, req, false, atLatest, doFilterMutations, commonFeedPrefixLength, &feedDiskReadState);
Future<std::pair<ChangeFeedStreamReply, bool>> feedReplyFuture = getChangeFeedMutations(
data, feedInfo, req, false, atLatest, doFilterMutations, commonFeedPrefixLength, &feedDiskReadState);
if (atLatest && !removeUID && !feedReplyFuture.isReady()) {
data->changeFeedClientVersions[req.reply.getEndpoint().getPrimaryAddress()][req.id] =
blockedVersion.present() ? blockedVersion.get() : data->prevVersion;
Expand Down Expand Up @@ -3387,8 +3387,7 @@ ACTOR Future<Void> changeFeedStreamQ(StorageServer* data, ChangeFeedStreamReques
clientVersions.erase(req.id);
removeUID = false;
} else {
clientVersions[req.id] =
feedReply.mutations.back().version;
clientVersions[req.id] = feedReply.mutations.back().version;
}
}

Expand Down

0 comments on commit e08d8f5

Please sign in to comment.