aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/coreconn.h
diff options
context:
space:
mode:
authorvladimir <vladimir@yandex-team.ru>2022-02-10 16:50:28 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:28 +0300
commit3e7ff6e4ee637c04455854159e84850e613ebc16 (patch)
tree1ea1786a47f104a0657e0f935ce63dcaeec3fd26 /library/cpp/messagebus/coreconn.h
parentdad82c0e0157ebad6bfd7cf0e5fb3c15c42922b3 (diff)
downloadydb-3e7ff6e4ee637c04455854159e84850e613ebc16.tar.gz
Restoring authorship annotation for <vladimir@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/coreconn.h')
-rw-r--r--library/cpp/messagebus/coreconn.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/library/cpp/messagebus/coreconn.h b/library/cpp/messagebus/coreconn.h
index fca228d82e..36f6e90165 100644
--- a/library/cpp/messagebus/coreconn.h
+++ b/library/cpp/messagebus/coreconn.h
@@ -1,8 +1,8 @@
#pragma once
-//////////////////////////////////////////////////////////////
-/// \file
-/// \brief Definitions for asynchonous connection queue
+//////////////////////////////////////////////////////////////
+/// \file
+/// \brief Definitions for asynchonous connection queue
#include "base.h"
#include "event_loop.h"
@@ -21,7 +21,7 @@
#include <util/string/util.h>
#include <util/system/condvar.h>
#include <util/system/mutex.h>
-#include <util/system/thread.h>
+#include <util/system/thread.h>
#include <util/thread/lfqueue.h>
#include <deque>
@@ -38,12 +38,12 @@ namespace NBus {
class TBusConnection;
class TBusConnectionFactory;
class TBusServerFactory;
-
+
using TBusConnectionList = TList<TBusConnection*>;
-
+
/// @throw yexception
EIpVersion MakeIpVersion(bool allowIpv4, bool allowIpv6);
-
+
inline bool WouldBlock() {
int syserr = LastSystemError();
return syserr == EAGAIN || syserr == EINPROGRESS || syserr == EWOULDBLOCK || syserr == EINTR;