diff options
author | alexvru <alexvru@ydb.tech> | 2023-04-25 13:50:27 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-04-25 13:50:27 +0300 |
commit | 962dae07e71621bd25c81feee4c6f3355c94a73c (patch) | |
tree | a083a671f2eb0d1ded6208ae8037dc16e395c513 /library/cpp/actors/interconnect/interconnect_stream.h | |
parent | e33f5f1a073db44a35c1616b2f391751779a866f (diff) | |
download | ydb-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.h | 7 |
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 { |