aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/event_loop.h
diff options
context:
space:
mode:
authornga <nga@yandex-team.ru>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:09 +0300
commit1f553f46fb4f3c5eec631352cdd900a0709016af (patch)
treea231fba2c03b440becaea6c86a2702d0bfb0336e /library/cpp/messagebus/event_loop.h
parentc4de7efdedc25b49cbea74bd589eecb61b55b60a (diff)
downloadydb-1f553f46fb4f3c5eec631352cdd900a0709016af.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/event_loop.h')
-rw-r--r--library/cpp/messagebus/event_loop.h22
1 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/event_loop.h b/library/cpp/messagebus/event_loop.h
index d5b0a53b0c..b313ba02a4 100644
--- a/library/cpp/messagebus/event_loop.h
+++ b/library/cpp/messagebus/event_loop.h
@@ -3,12 +3,12 @@
#include <util/generic/object_counter.h>
#include <util/generic/ptr.h>
#include <util/network/init.h>
-#include <util/network/socket.h>
+#include <util/network/socket.h>
namespace NEventLoop {
struct IEventHandler
: public TAtomicRefCount<IEventHandler> {
- virtual void HandleEvent(SOCKET socket, void* cookie) = 0;
+ virtual void HandleEvent(SOCKET socket, void* cookie) = 0;
virtual ~IEventHandler() {
}
};
@@ -17,8 +17,8 @@ namespace NEventLoop {
class TEventLoop;
- // TODO: make TChannel itself a pointer
- // to avoid confusion with Drop and Unregister
+ // TODO: make TChannel itself a pointer
+ // to avoid confusion with Drop and Unregister
class TChannel
: public TAtomicRefCount<TChannel> {
public:
@@ -32,15 +32,15 @@ namespace NEventLoop {
void Unregister();
SOCKET GetSocket() const;
- TSocket GetSocketPtr() const;
+ TSocket GetSocketPtr() const;
private:
class TImpl;
friend class TEventLoop;
- TObjectCounter<TChannel> ObjectCounter;
-
- TChannel(TImpl*);
+ TObjectCounter<TChannel> ObjectCounter;
+
+ TChannel(TImpl*);
private:
THolder<TImpl> Impl;
@@ -55,7 +55,7 @@ namespace NEventLoop {
void Run();
void Stop();
- bool IsRunning();
+ bool IsRunning();
TChannelPtr Register(TSocket socket, TEventHandlerPtr, void* cookie = nullptr);
@@ -63,8 +63,8 @@ namespace NEventLoop {
class TImpl;
friend class TChannel;
- TObjectCounter<TEventLoop> ObjectCounter;
-
+ TObjectCounter<TEventLoop> ObjectCounter;
+
private:
THolder<TImpl> Impl;
};