| /external/openscreen/osp/impl/ |
| D | message_demuxer.cc | 74 constexpr size_t MessageDemuxer::kDefaultBufferLimit;
76 MessageDemuxer::MessageWatch::MessageWatch() = default;
78 MessageDemuxer::MessageWatch::MessageWatch(MessageDemuxer* parent, in MessageWatch()
87 MessageDemuxer::MessageWatch::MessageWatch( in MessageWatch()
88 MessageDemuxer::MessageWatch&& other) noexcept in MessageWatch()
96 MessageDemuxer::MessageWatch::~MessageWatch() { in ~MessageWatch()
110 MessageDemuxer::MessageWatch& MessageDemuxer::MessageWatch::operator=( in operator =()
120 MessageDemuxer::MessageDemuxer(ClockNowFunctionPtr now_function, in MessageDemuxer() function in openscreen::osp::MessageDemuxer
126 MessageDemuxer::~MessageDemuxer() = default;
128 MessageDemuxer::MessageWatch MessageDemuxer::WatchMessageType( in WatchMessageType()
[all …]
|
| D | protocol_connection_client_factory.cc | 21 MessageDemuxer* demuxer, in Create()
|
| D | protocol_connection_server_factory.cc | 22 MessageDemuxer* demuxer, in Create()
|
| /external/openscreen/osp/public/ |
| D | message_demuxer.h | 25 class MessageDemuxer {
47 MessageWatch(MessageDemuxer* parent,
58 MessageDemuxer* parent_ = nullptr;
66 MessageDemuxer(ClockNowFunctionPtr now_function, size_t buffer_limit);
67 ~MessageDemuxer();
122 void StopWatching(MessageDemuxer::MessageWatch* watch);
|
| D | message_demuxer_unittest.cc | 56 MessageDemuxer demuxer_{FakeClock::now, MessageDemuxer::kDefaultBufferLimit};
62 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
88 watch = MessageDemuxer::MessageWatch(); in TEST_F()
98 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
129 MessageDemuxer::MessageWatch watch = demuxer_.SetDefaultMessageTypeWatch( in TEST_F()
157 MessageDemuxer::MessageWatch default_watch = in TEST_F()
162 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
218 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
234 MessageDemuxer::MessageWatch init_watch = demuxer_.WatchMessageType( in TEST_F()
259 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
[all …]
|
| D | protocol_connection_server.h | 75 MessageDemuxer* message_demuxer() const { return demuxer_; } in message_demuxer()
86 explicit ProtocolConnectionServer(MessageDemuxer* demuxer,
91 MessageDemuxer* const demuxer_;
|
| D | protocol_connection_client.h | 92 MessageDemuxer* message_demuxer() const { return demuxer_; } in message_demuxer()
104 MessageDemuxer* demuxer,
111 MessageDemuxer* const demuxer_;
|
| D | request_response_handler.h | 58 class RequestResponseHandler : public MessageDemuxer::MessageCallback {
83 response_watch_ = MessageDemuxer::MessageWatch(); in Reset()
135 response_watch_ = MessageDemuxer::MessageWatch(); in CancelMessage()
185 response_watch_ = MessageDemuxer::MessageWatch(); in OnStreamMessage()
221 MessageDemuxer::MessageWatch response_watch_;
|
| D | protocol_connection_client_factory.h | 21 MessageDemuxer* demuxer,
|
| D | protocol_connection_server_factory.h | 23 MessageDemuxer* demuxer,
|
| D | protocol_connection_server.cc | 10 ProtocolConnectionServer::ProtocolConnectionServer(MessageDemuxer* demuxer, in ProtocolConnectionServer()
|
| D | protocol_connection_client.cc | 36 MessageDemuxer* demuxer, in ProtocolConnectionClient()
|
| /external/openscreen/osp/public/presentation/ |
| D | presentation_receiver.h | 61 class Receiver final : public MessageDemuxer::MessageCallback,
114 MessageDemuxer::MessageWatch terminate_watch;
143 MessageDemuxer::MessageWatch availability_watch_;
144 MessageDemuxer::MessageWatch initiation_watch_;
145 MessageDemuxer::MessageWatch connection_watch_;
|
| D | presentation_connection.h | 186 class ConnectionManager final : public MessageDemuxer::MessageCallback {
188 explicit ConnectionManager(MessageDemuxer* demuxer);
209 MessageDemuxer::MessageWatch message_watch_;
210 MessageDemuxer::MessageWatch close_request_watch_;
211 MessageDemuxer::MessageWatch close_event_watch_;
|
| /external/openscreen/osp/impl/quic/testing/ |
| D | quic_test_support.cc | 23 controller_demuxer = std::make_unique<MessageDemuxer>( in FakeQuicBridge()
24 now_function, MessageDemuxer::kDefaultBufferLimit); in FakeQuicBridge()
25 receiver_demuxer = std::make_unique<MessageDemuxer>( in FakeQuicBridge()
26 now_function, MessageDemuxer::kDefaultBufferLimit); in FakeQuicBridge()
|
| D | quic_test_support.h | 65 std::unique_ptr<MessageDemuxer> controller_demuxer;
66 std::unique_ptr<MessageDemuxer> receiver_demuxer;
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_common.h | 33 MessageDemuxer* GetServerDemuxer();
34 MessageDemuxer* GetClientDemuxer();
|
| D | presentation_common.cc | 19 MessageDemuxer* GetServerDemuxer() { in GetServerDemuxer()
25 MessageDemuxer* GetClientDemuxer() { in GetClientDemuxer()
|
| D | url_availability_requester.h | 79 MessageDemuxer::MessageCallback {
134 MessageDemuxer::MessageWatch response_watch;
136 MessageDemuxer::MessageWatch event_watch;
|
| D | presentation_controller_unittest.cc | 108 availability_watch_ = MessageDemuxer::MessageWatch(); in TearDown()
253 MessageDemuxer::MessageWatch start_presentation_watch = in StartPresentation()
297 MessageDemuxer::MessageWatch availability_watch_;
405 MessageDemuxer::MessageWatch terminate_presentation_watch = in TEST_F()
457 MessageDemuxer::MessageWatch close_request_watch = in TEST_F()
477 MessageDemuxer::MessageWatch close_request_watch = in TEST_F()
490 MessageDemuxer::MessageWatch connection_open_watch = in TEST_F()
|
| D | presentation_receiver_unittest.cc | 115 MessageDemuxer::MessageWatch availability_watch = in TEST_F()
158 MessageDemuxer::MessageWatch initiation_watch = in TEST_F()
|
| /external/openscreen/osp/public/testing/ |
| D | message_demuxer_test_support.h | 15 class MockMessageCallback final : public MessageDemuxer::MessageCallback {
|
| /external/openscreen/osp/demo/ |
| D | osp_demo.cc | 432 MessageDemuxer demuxer(Clock::now, MessageDemuxer::kDefaultBufferLimit); in ListenerDemo()
534 MessageDemuxer demuxer(Clock::now, MessageDemuxer::kDefaultBufferLimit); in PublisherDemo()
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_server.h | 37 MessageDemuxer* demuxer,
|
| D | quic_client.h | 43 QuicClient(MessageDemuxer* demuxer,
|