aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors
diff options
context:
space:
mode:
authoragorodilov <agorodilov@yandex-team.ru>2022-02-10 16:47:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:09 +0300
commitbd5ef432f5cfb1e18851381329d94665a4c22470 (patch)
treeb83306b6e37edeea782e9eed673d89286c4fef35 /library/cpp/actors
parent7a4979e6211c3e78c7f9041d4a9e5d3405343c36 (diff)
downloadydb-bd5ef432f5cfb1e18851381329d94665a4c22470.tar.gz
Restoring authorship annotation for <agorodilov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors')
-rw-r--r--library/cpp/actors/core/mailbox_queue_revolving.h2
-rw-r--r--library/cpp/actors/core/scheduler_cookie.h6
-rw-r--r--library/cpp/actors/dnscachelib/dnscache.cpp6
-rw-r--r--library/cpp/actors/dnscachelib/timekeeper.h6
-rw-r--r--library/cpp/actors/testlib/test_runtime.cpp2
-rw-r--r--library/cpp/actors/util/queue_oneone_inplace.h6
6 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/actors/core/mailbox_queue_revolving.h b/library/cpp/actors/core/mailbox_queue_revolving.h
index e9a139862f..b0e78a18db 100644
--- a/library/cpp/actors/core/mailbox_queue_revolving.h
+++ b/library/cpp/actors/core/mailbox_queue_revolving.h
@@ -56,7 +56,7 @@ namespace NActors {
T Head(bool pop) {
ui64 tag = Max<ui64>();
- T ret = T{};
+ T ret = T{};
ui32 idx = 0;
for (ui32 i = 0; i < TWriteConcurrency; ++i)
diff --git a/library/cpp/actors/core/scheduler_cookie.h b/library/cpp/actors/core/scheduler_cookie.h
index e4bef9acda..2c20ca67f3 100644
--- a/library/cpp/actors/core/scheduler_cookie.h
+++ b/library/cpp/actors/core/scheduler_cookie.h
@@ -23,7 +23,7 @@ namespace NActors {
public:
TSchedulerCookieHolder()
- : Cookie(nullptr)
+ : Cookie(nullptr)
{
}
@@ -58,7 +58,7 @@ namespace NActors {
bool Detach() noexcept {
if (Cookie) {
const bool res = Cookie->Detach();
- Cookie = nullptr;
+ Cookie = nullptr;
return res;
} else {
return false;
@@ -68,7 +68,7 @@ namespace NActors {
bool DetachEvent() noexcept {
if (Cookie) {
const bool res = Cookie->DetachEvent();
- Cookie = nullptr;
+ Cookie = nullptr;
return res;
} else {
return false;
diff --git a/library/cpp/actors/dnscachelib/dnscache.cpp b/library/cpp/actors/dnscachelib/dnscache.cpp
index 6e51cfe1b6..649339ddb2 100644
--- a/library/cpp/actors/dnscachelib/dnscache.cpp
+++ b/library/cpp/actors/dnscachelib/dnscache.cpp
@@ -113,7 +113,7 @@ NAddr::IRemoteAddrPtr TDnsCache::GetAddr(
}
LWPROBE(FamilyMismatch, family, AllowIpV4, AllowIpV6);
- return nullptr;
+ return nullptr;
}
void TDnsCache::GetAllAddresses(
@@ -372,7 +372,7 @@ void TDnsCache::GHBNCallback(void* arg, int status, int, struct hostent* info) {
if (status == ARES_SUCCESS) {
if (info->h_addrtype == AF_INET) {
p->second.AddrsV4.clear();
- for (int i = 0; info->h_addr_list[i] != nullptr; i++) {
+ for (int i = 0; info->h_addr_list[i] != nullptr; i++) {
p->second.AddrsV4.push_back(*(TIpHost*)(info->h_addr_list[i]));
}
/* It is possible to ask ares for IPv6 and have IPv4 addrs instead,
@@ -383,7 +383,7 @@ void TDnsCache::GHBNCallback(void* arg, int status, int, struct hostent* info) {
AtomicSet(p->second.InProgressV4, 0);
} else if (info->h_addrtype == AF_INET6) {
p->second.AddrsV6.clear();
- for (int i = 0; info->h_addr_list[i] != nullptr; i++) {
+ for (int i = 0; info->h_addr_list[i] != nullptr; i++) {
p->second.AddrsV6.push_back(*(struct in6_addr*)(info->h_addr_list[i]));
}
} else {
diff --git a/library/cpp/actors/dnscachelib/timekeeper.h b/library/cpp/actors/dnscachelib/timekeeper.h
index a189f8247d..0528d8549c 100644
--- a/library/cpp/actors/dnscachelib/timekeeper.h
+++ b/library/cpp/actors/dnscachelib/timekeeper.h
@@ -37,7 +37,7 @@ public:
}
}
if (!ConstTime) {
- gettimeofday(&CurrentTime, nullptr);
+ gettimeofday(&CurrentTime, nullptr);
Thread.Start();
}
}
@@ -62,9 +62,9 @@ private:
do {
/* Race condition may occur here but locking looks too expensive */
- gettimeofday(&owner->CurrentTime, nullptr);
+ gettimeofday(&owner->CurrentTime, nullptr);
} while (!owner->Exit.WaitT(TDuration::MicroSeconds(UpdateInterval)));
- return nullptr;
+ return nullptr;
}
};
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index 2252cff5cb..6fa25b9965 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -869,7 +869,7 @@ namespace NActors {
// first step - find good enough mailbox
ui32 hint = 0;
- TMailboxHeader *mailbox = nullptr;
+ TMailboxHeader *mailbox = nullptr;
{
ui32 hintBackoff = 0;
diff --git a/library/cpp/actors/util/queue_oneone_inplace.h b/library/cpp/actors/util/queue_oneone_inplace.h
index 15c0f382d3..d7ec8bb21c 100644
--- a/library/cpp/actors/util/queue_oneone_inplace.h
+++ b/library/cpp/actors/util/queue_oneone_inplace.h
@@ -35,7 +35,7 @@ public:
ReadPosition = 0;
return Next();
}
- return T{};
+ return T{};
}
};
@@ -62,7 +62,7 @@ public:
struct TCleanDestructor {
static inline void Destroy(TOneOneQueueInplace<T, TSize>* x) noexcept {
- while (x->Pop() != nullptr)
+ while (x->Pop() != nullptr)
continue;
delete x;
}
@@ -102,7 +102,7 @@ public:
ReadPosition = 0;
return Head();
}
- return T{};
+ return T{};
}
T Pop() {