63 class Controller::MessageGroupStreams final
71   MessageGroupStreams(Controller* controller, const std::string& service_id);
112   Controller* const controller_;
131 Controller::MessageGroupStreams::MessageGroupStreams(  in MessageGroupStreams()
132     Controller* controller,  in MessageGroupStreams()  argument
134     : controller_(controller),  in MessageGroupStreams()
141 Controller::MessageGroupStreams::~MessageGroupStreams() = default;
143 uint64_t Controller::MessageGroupStreams::SendStartRequest(  in SendStartRequest()
157 void Controller::MessageGroupStreams::CancelStartRequest(uint64_t request_id) {  in CancelStartRequest()
163 void Controller::MessageGroupStreams::OnMatchedResponse(  in OnMatchedResponse()
177   Controller::ControlledPresentation& presentation =  in OnMatchedResponse()
192 void Controller::MessageGroupStreams::OnError(StartRequest* request,  in OnError()
197 uint64_t Controller::MessageGroupStreams::SendConnectionOpenRequest(  in SendConnectionOpenRequest()
211 void Controller::MessageGroupStreams::CancelConnectionOpenRequest(  in CancelConnectionOpenRequest()
216 void Controller::MessageGroupStreams::OnMatchedResponse(  in OnMatchedResponse()
248 void Controller::MessageGroupStreams::OnError(ConnectionOpenRequest* request,  in OnError()
253 void Controller::MessageGroupStreams::SendConnectionCloseRequest(  in SendConnectionCloseRequest()
265 void Controller::MessageGroupStreams::OnMatchedResponse(  in OnMatchedResponse()
276 void Controller::MessageGroupStreams::OnError(ConnectionCloseRequest* request,  in OnError()
282 void Controller::MessageGroupStreams::SendTerminationRequest(  in SendTerminationRequest()
292 void Controller::MessageGroupStreams::OnMatchedResponse(  in OnMatchedResponse()
302 void Controller::MessageGroupStreams::OnError(TerminationRequest* request,  in OnError()
305 void Controller::MessageGroupStreams::OnConnectionOpened(  in OnConnectionOpened()
329 void Controller::MessageGroupStreams::OnConnectionFailed(uint64_t request_id) {  in OnConnectionFailed()
343 void Controller::MessageGroupStreams::OnConnectionClosed(  in OnConnectionClosed()
351 uint64_t Controller::MessageGroupStreams::GetNextInternalRequestId() {  in GetNextInternalRequestId()
355 Controller::ReceiverWatch::ReceiverWatch() = default;
356 Controller::ReceiverWatch::ReceiverWatch(Controller* controller,  in ReceiverWatch()  argument
359     : urls_(urls), observer_(observer), controller_(controller) {}  in ReceiverWatch()
361 Controller::ReceiverWatch::ReceiverWatch(  in ReceiverWatch()
362     Controller::ReceiverWatch&& other) noexcept {  in ReceiverWatch()
366 Controller::ReceiverWatch::~ReceiverWatch() {  in ~ReceiverWatch()
373 Controller::ReceiverWatch& Controller::ReceiverWatch::operator=(  in operator =()
374     Controller::ReceiverWatch other) {  in operator =()
379 void swap(Controller::ReceiverWatch& a, Controller::ReceiverWatch& b) {  in swap()
386 Controller::ConnectRequest::ConnectRequest() = default;
387 Controller::ConnectRequest::ConnectRequest(Controller* controller,  in ConnectRequest()  argument
394       controller_(controller) {}  in ConnectRequest()
396 Controller::ConnectRequest::ConnectRequest(ConnectRequest&& other) noexcept {  in ConnectRequest()
400 Controller::ConnectRequest::~ConnectRequest() {  in ~ConnectRequest()
408 Controller::ConnectRequest& Controller::ConnectRequest::operator=(  in operator =()
414 void swap(Controller::ConnectRequest& a, Controller::ConnectRequest& b) {  in swap()
422 Controller::Controller(ClockNowFunctionPtr now_function) {  in Controller()  function in openscreen::osp::Controller
445 Controller::~Controller() {  in ~Controller()
450 Controller::ReceiverWatch Controller::RegisterReceiverWatch(  in RegisterReceiverWatch()
457 Controller::ConnectRequest Controller::StartPresentation(  in StartPresentation()
473 Controller::ConnectRequest Controller::ReconnectPresentation(  in ReconnectPresentation()
502 Controller::ConnectRequest Controller::ReconnectConnection(  in ReconnectConnection()
537 Error Controller::CloseConnection(Connection* connection,  in CloseConnection()
555 Error Controller::OnPresentationTerminated(const std::string& presentation_id,  in OnPresentationTerminated()
576 void Controller::OnConnectionDestroyed(Connection* connection) {  in OnConnectionDestroyed()
593 std::string Controller::GetServiceIdForPresentationId(  in GetServiceIdForPresentationId()
602 ProtocolConnection* Controller::GetConnectionRequestGroupStream(  in GetConnectionRequestGroupStream()
608 void Controller::OnError(ServiceListenerError) {}  in OnError()
609 void Controller::OnMetrics(ServiceListener::Metrics) {}  in OnMetrics()
611 class Controller::TerminationListener final
614   TerminationListener(Controller* controller,
628   Controller* const controller_;
633 Controller::TerminationListener::TerminationListener(  in TerminationListener()
634     Controller* controller,  in TerminationListener()  argument
637     : controller_(controller), presentation_id_(presentation_id) {  in TerminationListener()
646 Controller::TerminationListener::~TerminationListener() = default;
648 ErrorOr<size_t> Controller::TerminationListener::OnStreamMessage(  in OnStreamMessage()
681 std::string Controller::MakePresentationId(const std::string& url,  in MakePresentationId()
692 void Controller::AddConnection(Connection* connection) {  in AddConnection()
696 void Controller::OpenConnection(  in OpenConnection()
727 void Controller::TerminatePresentationById(const std::string& presentation_id) {  in TerminatePresentationById()
737 void Controller::CancelReceiverWatch(const std::vector<std::string>& urls,  in CancelReceiverWatch()
742 void Controller::CancelConnectRequest(const std::string& service_id,  in CancelConnectRequest()
755 void Controller::OnStarted() {}  in OnStarted()
756 void Controller::OnStopped() {}  in OnStopped()
757 void Controller::OnSuspended() {}  in OnSuspended()
758 void Controller::OnSearching() {}  in OnSearching()
760 void Controller::OnReceiverAdded(const ServiceInfo& info) {  in OnReceiverAdded()
770 void Controller::OnReceiverChanged(const ServiceInfo& info) {  in OnReceiverChanged()
776 void Controller::OnReceiverRemoved(const ServiceInfo& info) {  in OnReceiverRemoved()
782 void Controller::OnAllReceiversRemoved() {  in OnAllReceiversRemoved()