Searched refs:SocketStream (Results 1 – 16 of 16) sorted by relevance
18 SocketStream::SocketStream(Socket* socket) : socket_(nullptr) { in SocketStream() function in rtc::SocketStream22 SocketStream::~SocketStream() { in ~SocketStream()26 void SocketStream::Attach(Socket* socket) { in Attach()31 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); in Attach()32 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); in Attach()33 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); in Attach()34 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent); in Attach()38 Socket* SocketStream::Detach() { in Detach()50 StreamState SocketStream::GetState() const { in GetState()63 StreamResult SocketStream::Read(rtc::ArrayView<uint8_t> buffer, in Read()[all …]
24 class SocketStream : public StreamInterface, public sigslot::has_slots<> {26 explicit SocketStream(Socket* socket);27 ~SocketStream() override;29 SocketStream(const SocketStream&) = delete;30 SocketStream& operator=(const SocketStream&) = delete;
261 std::make_unique<rtc::SocketStream>(socket)); in DoHandshake()
26 class SocketStream : public NonSeekableReaderWriter {28 SocketStream() = default;30 explicit SocketStream(int connection_fd) : connection_fd_(connection_fd) { in SocketStream() function37 SocketStream& operator=(SocketStream&& other) {41 SocketStream(SocketStream&& other) noexcept { MoveFrom(std::move(other)); } in SocketStream() function42 SocketStream(const SocketStream&) = delete;43 SocketStream& operator=(const SocketStream&) = delete;45 ~SocketStream() override { Close(); } in ~SocketStream()69 explicit ConnectionOwnership(SocketStream* socket_stream) in ConnectionOwnership()83 SocketStream* socket_stream_;[all …]
31 Result<SocketStream> server_stream = Status::Unavailable(); in RunConnectTest()34 SocketStream client; in RunConnectTest()68 Result<SocketStream> server_stream = Status::Unavailable(); in TEST()71 SocketStream client; in TEST()85 void ExchangeData(SocketStream& stream1, SocketStream& stream2) { in ExchangeData()128 Result<SocketStream> server_stream = Status::Unavailable(); in TEST()131 SocketStream client; in TEST()145 Result<SocketStream> server_stream1 = Status::Unavailable(); in TEST()146 Result<SocketStream> server_stream2 = Status::Unavailable(); in TEST()147 Result<SocketStream> server_stream3 = Status::Unavailable(); in TEST()[all …]
100 Status SocketStream::SocketStream::Connect(const char* host, uint16_t port) { in Connect()154 int SocketStream::SetSockOpt(int level, in SetSockOpt()165 bool SocketStream::IsReady() { in IsReady()170 void SocketStream::Close() { in Close()192 Status SocketStream::DoWrite(span<const std::byte> data) { in DoWrite()224 StatusWithSize SocketStream::DoRead(ByteSpan dest) { in DoRead()262 int SocketStream::TakeConnection() { in TakeConnection()267 int SocketStream::TakeConnectionWithLockHeld() { in TakeConnectionWithLockHeld()286 void SocketStream::ReleaseConnection() { in ReleaseConnection()291 void SocketStream::ReleaseConnectionWithLockHeld() { in ReleaseConnectionWithLockHeld()[all …]
186 .. cpp:class:: SocketStream : public NonSeekableReaderWriter188 ``SocketStream`` wraps posix-style TCP sockets with the :cpp:class:`Reader`195 :cpp:class:`SocketStream` for each accepted client connection.
29 stream::SocketStream& GetStream() { in GetStream()34 static stream::SocketStream socket_stream; in GetStream()
166 Result<stream::SocketStream> stream = server_socket_.Accept(); in Serve()229 stream::SocketStream socket_stream_;
40 stream::SocketStream socket_stream;
133 stream::SocketStream stream_;
138 // pw::stream::SocketStream doesn't accept host domain name as input. Thus we174 pw::stream::SocketStream socket_stream;
617 # SocketStream supports those platforms.
112 - :cpp:class:`pw::stream::SocketStream` -- Supports reading from and writing to
970 ``SocketStream`` and ``StdioStream`` are an implementations of that
594 * The new ``pw::stream::SocketStream::IsReady()`` method indicates