Restoring authorship annotation for <akastornov@yandex-team.ru>. Commit 1 of 2.

1 files changed, 89 insertions, 89 deletions

diff --git a/contrib/libs/grpc/src/cpp/server/dynamic_thread_pool.cc b/contrib/libs/grpc/src/cpp/server/dynamic_thread_pool.cc
index 77c5d6a263..ffb232c847 100644
--- a/contrib/libs/grpc/src/cpp/server/dynamic_thread_pool.cc
+++ b/contrib/libs/grpc/src/cpp/server/dynamic_thread_pool.cc
@@ -1,124 +1,124 @@
-/*
- *
+/* 
+ * 
  * Copyright 2015 gRPC authors.
- *
+ * 
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- *
+ * 
  *     http://www.apache.org/licenses/LICENSE-2.0
- *
+ * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- *
- */
-
+ * 
+ */ 
+ 
 #include "src/cpp/server/dynamic_thread_pool.h"
 
 #include <grpc/support/log.h>
 #include <grpcpp/impl/codegen/sync.h>
-
+ 
 #include "src/core/lib/gprpp/thd.h"
 
-namespace grpc {
+namespace grpc { 
 
-DynamicThreadPool::DynamicThread::DynamicThread(DynamicThreadPool* pool)
-    : pool_(pool),
+DynamicThreadPool::DynamicThread::DynamicThread(DynamicThreadPool* pool) 
+    : pool_(pool), 
       thd_("grpcpp_dynamic_pool",
            [](void* th) {
              static_cast<DynamicThreadPool::DynamicThread*>(th)->ThreadFunc();
            },
            this) {
   thd_.Start();
-}
+} 
 DynamicThreadPool::DynamicThread::~DynamicThread() { thd_.Join(); }
-
-void DynamicThreadPool::DynamicThread::ThreadFunc() {
-  pool_->ThreadFunc();
-  // Now that we have killed ourselves, we should reduce the thread count
+ 
+void DynamicThreadPool::DynamicThread::ThreadFunc() { 
+  pool_->ThreadFunc(); 
+  // Now that we have killed ourselves, we should reduce the thread count 
   grpc_core::MutexLock lock(&pool_->mu_);
-  pool_->nthreads_--;
-  // Move ourselves to dead list
-  pool_->dead_threads_.push_back(this);
-
-  if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) {
+  pool_->nthreads_--; 
+  // Move ourselves to dead list 
+  pool_->dead_threads_.push_back(this); 
+ 
+  if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) { 
     pool_->shutdown_cv_.Signal();
-  }
-}
-
-void DynamicThreadPool::ThreadFunc() {
-  for (;;) {
-    // Wait until work is available or we are shutting down.
+  } 
+} 
+ 
+void DynamicThreadPool::ThreadFunc() { 
+  for (;;) { 
+    // Wait until work is available or we are shutting down. 
     grpc_core::ReleasableMutexLock lock(&mu_);
-    if (!shutdown_ && callbacks_.empty()) {
-      // If there are too many threads waiting, then quit this thread
-      if (threads_waiting_ >= reserve_threads_) {
-        break;
-      }
-      threads_waiting_++;
+    if (!shutdown_ && callbacks_.empty()) { 
+      // If there are too many threads waiting, then quit this thread 
+      if (threads_waiting_ >= reserve_threads_) { 
+        break; 
+      } 
+      threads_waiting_++; 
       cv_.Wait(&mu_);
-      threads_waiting_--;
-    }
-    // Drain callbacks before considering shutdown to ensure all work
-    // gets completed.
-    if (!callbacks_.empty()) {
-      auto cb = callbacks_.front();
-      callbacks_.pop();
+      threads_waiting_--; 
+    } 
+    // Drain callbacks before considering shutdown to ensure all work 
+    // gets completed. 
+    if (!callbacks_.empty()) { 
+      auto cb = callbacks_.front(); 
+      callbacks_.pop(); 
       lock.Unlock();
-      cb();
-    } else if (shutdown_) {
-      break;
-    }
-  }
-}
-
-DynamicThreadPool::DynamicThreadPool(int reserve_threads)
-    : shutdown_(false),
-      reserve_threads_(reserve_threads),
-      nthreads_(0),
-      threads_waiting_(0) {
-  for (int i = 0; i < reserve_threads_; i++) {
+      cb(); 
+    } else if (shutdown_) { 
+      break; 
+    } 
+  } 
+} 
+ 
+DynamicThreadPool::DynamicThreadPool(int reserve_threads) 
+    : shutdown_(false), 
+      reserve_threads_(reserve_threads), 
+      nthreads_(0), 
+      threads_waiting_(0) { 
+  for (int i = 0; i < reserve_threads_; i++) { 
     grpc_core::MutexLock lock(&mu_);
-    nthreads_++;
-    new DynamicThread(this);
-  }
-}
-
-void DynamicThreadPool::ReapThreads(std::list<DynamicThread*>* tlist) {
-  for (auto t = tlist->begin(); t != tlist->end(); t = tlist->erase(t)) {
-    delete *t;
-  }
-}
-
-DynamicThreadPool::~DynamicThreadPool() {
+    nthreads_++; 
+    new DynamicThread(this); 
+  } 
+} 
+ 
+void DynamicThreadPool::ReapThreads(std::list<DynamicThread*>* tlist) { 
+  for (auto t = tlist->begin(); t != tlist->end(); t = tlist->erase(t)) { 
+    delete *t; 
+  } 
+} 
+ 
+DynamicThreadPool::~DynamicThreadPool() { 
   grpc_core::MutexLock lock(&mu_);
-  shutdown_ = true;
+  shutdown_ = true; 
   cv_.Broadcast();
-  while (nthreads_ != 0) {
+  while (nthreads_ != 0) { 
     shutdown_cv_.Wait(&mu_);
-  }
-  ReapThreads(&dead_threads_);
-}
-
-void DynamicThreadPool::Add(const std::function<void()>& callback) {
+  } 
+  ReapThreads(&dead_threads_); 
+} 
+ 
+void DynamicThreadPool::Add(const std::function<void()>& callback) { 
   grpc_core::MutexLock lock(&mu_);
-  // Add works to the callbacks list
-  callbacks_.push(callback);
-  // Increase pool size or notify as needed
-  if (threads_waiting_ == 0) {
-    // Kick off a new thread
-    nthreads_++;
-    new DynamicThread(this);
-  } else {
+  // Add works to the callbacks list 
+  callbacks_.push(callback); 
+  // Increase pool size or notify as needed 
+  if (threads_waiting_ == 0) { 
+    // Kick off a new thread 
+    nthreads_++; 
+    new DynamicThread(this); 
+  } else { 
     cv_.Signal();
-  }
-  // Also use this chance to harvest dead threads
-  if (!dead_threads_.empty()) {
-    ReapThreads(&dead_threads_);
-  }
-}
-
-}  // namespace grpc
+  } 
+  // Also use this chance to harvest dead threads 
+  if (!dead_threads_.empty()) { 
+    ReapThreads(&dead_threads_); 
+  } 
+} 
+ 
+}  // namespace grpc