diff options
author | Vladimir Gordiychuk <folyga@gmail.com> | 2022-02-10 16:50:21 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:21 +0300 |
commit | e7bf3caf59ff1d3936047c1800d0b9adaba5b647 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/grpc/client/grpc_client_low.h | |
parent | 9315561a79f8c08b28065daf027ef493ae27a6d2 (diff) | |
download | ydb-e7bf3caf59ff1d3936047c1800d0b9adaba5b647.tar.gz |
Restoring authorship annotation for Vladimir Gordiychuk <folyga@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/grpc/client/grpc_client_low.h')
-rw-r--r-- | library/cpp/grpc/client/grpc_client_low.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/grpc/client/grpc_client_low.h b/library/cpp/grpc/client/grpc_client_low.h index 627c88ca67..ab0a0627be 100644 --- a/library/cpp/grpc/client/grpc_client_low.h +++ b/library/cpp/grpc/client/grpc_client_low.h @@ -1320,7 +1320,7 @@ private: }; class TGRpcClientLow - : public IQueueClientContextProvider + : public IQueueClientContextProvider { class TContextImpl; friend class TContextImpl; @@ -1332,7 +1332,7 @@ class TGRpcClientLow }; public: - explicit TGRpcClientLow(size_t numWorkerThread = DEFAULT_NUM_THREADS, bool useCompletionQueuePerThread = false); + explicit TGRpcClientLow(size_t numWorkerThread = DEFAULT_NUM_THREADS, bool useCompletionQueuePerThread = false); ~TGRpcClientLow(); // Tries to stop all currently running requests (via their stop callbacks) @@ -1372,7 +1372,7 @@ public: private: using IThreadRef = std::unique_ptr<IThreadFactory::IThread>; - using CompletionQueueRef = std::unique_ptr<grpc::CompletionQueue>; + using CompletionQueueRef = std::unique_ptr<grpc::CompletionQueue>; void Init(size_t numWorkerThread); inline ECqState GetCqState() const { return (ECqState) AtomicGet(CqState_); } @@ -1384,7 +1384,7 @@ private: void ForgetContext(TContextImpl* context); private: - bool UseCompletionQueuePerThread_; + bool UseCompletionQueuePerThread_; std::vector<CompletionQueueRef> CQS_; std::vector<IThreadRef> WorkerThreads_; TAtomic CqState_ = -1; |