aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/local_executor
diff options
context:
space:
mode:
authorilyzhin <ilyzhin@yandex-team.ru>2022-02-10 16:51:00 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:51:00 +0300
commit69f832f0edfcdb994d569f8529b2bd26aa0742a4 (patch)
treed80c4f9a33ef4227efcb24aa3888f85118862be4 /library/cpp/threading/local_executor
parent9164d180a5c1f96e8d270f59bba1fbc7102889fd (diff)
downloadydb-69f832f0edfcdb994d569f8529b2bd26aa0742a4.tar.gz
Restoring authorship annotation for <ilyzhin@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/local_executor')
-rw-r--r--library/cpp/threading/local_executor/local_executor.h10
1 files changed, 5 insertions, 5 deletions
diff --git a/library/cpp/threading/local_executor/local_executor.h b/library/cpp/threading/local_executor/local_executor.h
index c1c824f67c..df0b8333fc 100644
--- a/library/cpp/threading/local_executor/local_executor.h
+++ b/library/cpp/threading/local_executor/local_executor.h
@@ -75,9 +75,9 @@ namespace NPar {
//
template <typename TBlockCount>
TExecRangeParams& SetBlockCount(TBlockCount blockCount) {
- Y_ASSERT(SafeIntegerCast<int>(blockCount) > 0 || FirstId == LastId);
- BlockSize = FirstId == LastId ? 0 : CeilDiv(LastId - FirstId, SafeIntegerCast<int>(blockCount));
- BlockCount = BlockSize == 0 ? 0 : CeilDiv(LastId - FirstId, BlockSize);
+ Y_ASSERT(SafeIntegerCast<int>(blockCount) > 0 || FirstId == LastId);
+ BlockSize = FirstId == LastId ? 0 : CeilDiv(LastId - FirstId, SafeIntegerCast<int>(blockCount));
+ BlockCount = BlockSize == 0 ? 0 : CeilDiv(LastId - FirstId, BlockSize);
BlockEqualToThreads = false;
return *this;
}
@@ -86,9 +86,9 @@ namespace NPar {
//
template <typename TBlockSize>
TExecRangeParams& SetBlockSize(TBlockSize blockSize) {
- Y_ASSERT(SafeIntegerCast<int>(blockSize) > 0 || FirstId == LastId);
+ Y_ASSERT(SafeIntegerCast<int>(blockSize) > 0 || FirstId == LastId);
BlockSize = SafeIntegerCast<int>(blockSize);
- BlockCount = BlockSize == 0 ? 0 : CeilDiv(LastId - FirstId, BlockSize);
+ BlockCount = BlockSize == 0 ? 0 : CeilDiv(LastId - FirstId, BlockSize);
BlockEqualToThreads = false;
return *this;
}