summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/poller_tcp.cpp
diff options
context:
space:
mode:
authorAlexander Rutkovsky <[email protected]>2022-02-10 16:47:39 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:47:39 +0300
commitf3646f91e0de459836a7800b9ce3e8dc57a2ab3a (patch)
tree25c1423200152570c1f8307e5b8304b9bc3840c5 /library/cpp/actors/interconnect/poller_tcp.cpp
parentfccc62e9bfdce9be2fe7e0f23479da3a5512211a (diff)
Restoring authorship annotation for Alexander Rutkovsky <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/poller_tcp.cpp')
-rw-r--r--library/cpp/actors/interconnect/poller_tcp.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/actors/interconnect/poller_tcp.cpp b/library/cpp/actors/interconnect/poller_tcp.cpp
index 8267df31eae..5eb7fa854ca 100644
--- a/library/cpp/actors/interconnect/poller_tcp.cpp
+++ b/library/cpp/actors/interconnect/poller_tcp.cpp
@@ -1,6 +1,6 @@
-#include "poller_tcp.h"
-
-namespace NInterconnect {
+#include "poller_tcp.h"
+
+namespace NInterconnect {
TPollerThreads::TPollerThreads(size_t units, bool useSelect)
: Units(units)
{
@@ -8,28 +8,28 @@ namespace NInterconnect {
for (auto& unit : Units)
unit = TPollerUnit::Make(useSelect);
}
-
+
TPollerThreads::~TPollerThreads() {
}
-
+
void TPollerThreads::Start() {
for (const auto& unit : Units)
unit->Start();
}
-
+
void TPollerThreads::Stop() {
for (const auto& unit : Units)
unit->Stop();
}
-
+
void TPollerThreads::StartRead(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) {
auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()];
unit->StartReadOperation(s, std::move(operation));
}
-
+
void TPollerThreads::StartWrite(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) {
auto& unit = Units[THash<SOCKET>()(s->GetDescriptor()) % Units.size()];
unit->StartWriteOperation(s, std::move(operation));
}
-
-}
+
+}