Home
last modified time | relevance | path

Searched refs:endpoint_id_ (Results 1 – 9 of 9) sorted by relevance

/external/openscreen/osp/public/
Dmessage_demuxer_unittest.cc49 const uint64_t endpoint_id_ = 13; member in openscreen::osp::__anonfc0f06370111::MessageDemuxerTest
63 endpoint_id_, msgs::Type::kPresentationConnectionOpenRequest, in TEST_F()
68 demuxer_.OnStreamData(endpoint_id_ + 1, 14, buffer_.data(), buffer_.size()); in TEST_F()
74 OnStreamMessage(endpoint_id_, connection_id_, in TEST_F()
84 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
90 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
96 constexpr uint64_t endpoint_id_ = 13; in TEST_F() local
99 endpoint_id_, msgs::Type::kPresentationConnectionOpenRequest, in TEST_F()
107 OnStreamMessage(endpoint_id_, connection_id_, in TEST_F()
118 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
[all …]
Dprotocol_connection.h81 uint64_t endpoint_id() const { return endpoint_id_; } in endpoint_id()
88 uint64_t endpoint_id_;
Dprotocol_connection.cc11 : endpoint_id_(endpoint_id), id_(id) {} in ProtocolConnection()
Dmessage_demuxer.h60 uint64_t endpoint_id_; variable
/external/openscreen/osp/impl/quic/
Dquic_service_common.cc100 endpoint_id_ = parent_->OnCryptoHandshakeComplete(this, connection_id); in OnCryptoHandshakeComplete()
102 << endpoint_id_; in OnCryptoHandshakeComplete()
108 OSP_VLOG << "Incoming QUIC stream from endpoint " << endpoint_id_; in OnIncomingStream()
116 OSP_VLOG << "QUIC connection closed for endpoint " << endpoint_id_; in OnConnectionClosed()
117 parent_->OnConnectionClosed(endpoint_id_, connection_id); in OnConnectionClosed()
125 parent_, endpoint_id_, stream_id); in NextStreamDelegate()
136 parent_->OnDataReceived(endpoint_id_, stream_pair.connection_id, in OnReceived()
141 OSP_VLOG << "QUIC stream closed for endpoint " << endpoint_id_; in OnClose()
146 parent_->OnDataReceived(endpoint_id_, stream_pair.connection_id, nullptr, 0); in OnClose()
Dquic_service_common.h121 uint64_t endpoint_id_; variable
/external/openscreen/osp/impl/
Dmessage_demuxer.cc84 endpoint_id_(endpoint_id), in MessageWatch()
91 endpoint_id_(other.endpoint_id_), in MessageWatch()
105 parent_->StopWatchingMessageType(endpoint_id_, message_type_); in ~MessageWatch()
115 swap(endpoint_id_, other.endpoint_id_); in operator =()
/external/openscreen/osp/public/presentation/
Dpresentation_connection.h135 OSP_CHECK(endpoint_id_); in endpoint_id()
136 return endpoint_id_.value(); in endpoint_id()
182 absl::optional<uint64_t> endpoint_id_; variable
/external/openscreen/osp/impl/presentation/
Dpresentation_connection.cc67 endpoint_id_ = endpoint_id; in OnConnected()