Skip to content

Commit

Permalink
Fix format issue
Browse files Browse the repository at this point in the history
Signed-off-by: yibin <huyibin@pingcap.com>
  • Loading branch information
yibin87 committed May 26, 2022
1 parent cbc998b commit 606b704
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dbms/src/Flash/Mpp/ExchangeReceiver.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ class AsyncRequestHandler : public UnaryCallback<bool>
case AsyncRequestStage::WAIT_MAKE_READER:
{
// Use lock to ensure reader is created already in reactor thread
std::unique_lock lock(mu);
std::unique_lock lock(mu);
if (!ok)
reader.reset();
notifyReactor();
Expand Down Expand Up @@ -232,7 +232,7 @@ class AsyncRequestHandler : public UnaryCallback<bool>
{
stage = AsyncRequestStage::WAIT_MAKE_READER;
// Use lock to ensure async reader is unreachable from grpc thread before this function returns
std::unique_lock lock(mu);
std::unique_lock lock(mu);
rpc_context->makeAsyncReader(*request, reader, thisAsUnaryCallback());
}

Expand Down

0 comments on commit 606b704

Please sign in to comment.