aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_stream.h
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2023-04-25 13:50:27 +0300
committeralexvru <alexvru@ydb.tech>2023-04-25 13:50:27 +0300
commit962dae07e71621bd25c81feee4c6f3355c94a73c (patch)
treea083a671f2eb0d1ded6208ae8037dc16e395c513 /library/cpp/actors/interconnect/interconnect_stream.h
parente33f5f1a073db44a35c1616b2f391751779a866f (diff)
downloadydb-962dae07e71621bd25c81feee4c6f3355c94a73c.tar.gz
Support XDC streams
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_stream.h')
-rw-r--r--library/cpp/actors/interconnect/interconnect_stream.h7
1 files changed, 7 insertions, 0 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_stream.h b/library/cpp/actors/interconnect/interconnect_stream.h
index 3ba7914f77..55438fef10 100644
--- a/library/cpp/actors/interconnect/interconnect_stream.h
+++ b/library/cpp/actors/interconnect/interconnect_stream.h
@@ -14,6 +14,10 @@
#include <sys/uio.h>
+namespace NActors {
+ class TPollerToken;
+}
+
namespace NInterconnect {
class TSocket: public NActors::TSharedDescriptor, public TNonCopyable {
protected:
@@ -63,6 +67,8 @@ namespace NInterconnect {
void SetSendBufferSize(i32 len) const;
ui32 GetSendBufferSize() const;
+
+ virtual void Request(NActors::TPollerToken& token, bool read, bool write);
};
class TSecureSocketContext {
@@ -114,6 +120,7 @@ namespace NInterconnect {
bool WantRead() const;
bool WantWrite() const;
+ virtual void Request(NActors::TPollerToken& token, bool read, bool write) override;
};
class TDatagramSocket: public TSocket {