diff options
Diffstat (limited to 'osp/impl/mdns_responder_service.cc')
-rw-r--r-- | osp/impl/mdns_responder_service.cc | 36 |
1 files changed, 16 insertions, 20 deletions
diff --git a/osp/impl/mdns_responder_service.cc b/osp/impl/mdns_responder_service.cc index 347f1254..aca15e18 100644 --- a/osp/impl/mdns_responder_service.cc +++ b/osp/impl/mdns_responder_service.cc @@ -13,8 +13,6 @@ #include "util/logging.h" #include "util/trace_logging.h" -using openscreen::platform::TraceCategory; - namespace openscreen { namespace osp { namespace { @@ -33,8 +31,8 @@ std::string ServiceIdFromServiceInstanceName( } // namespace MdnsResponderService::MdnsResponderService( - platform::ClockNowFunctionPtr now_function, - platform::TaskRunner* task_runner, + ClockNowFunctionPtr now_function, + TaskRunner* task_runner, const std::string& service_name, const std::string& service_protocol, std::unique_ptr<MdnsResponderAdapterFactory> mdns_responder_factory, @@ -51,7 +49,7 @@ void MdnsResponderService::SetServiceConfig( const std::string& hostname, const std::string& instance, uint16_t port, - const std::vector<platform::NetworkInterfaceIndex> whitelist, + const std::vector<NetworkInterfaceIndex> whitelist, const std::map<std::string, std::string>& txt_data) { OSP_DCHECK(!hostname.empty()); OSP_DCHECK(!instance.empty()); @@ -63,8 +61,8 @@ void MdnsResponderService::SetServiceConfig( service_txt_data_ = txt_data; } -void MdnsResponderService::OnRead(platform::UdpSocket* socket, - ErrorOr<platform::UdpPacket> packet) { +void MdnsResponderService::OnRead(UdpSocket* socket, + ErrorOr<UdpPacket> packet) { TRACE_SCOPED(TraceCategory::mDNS, "MdnsResponderService::OnRead"); if (!mdns_responder_) { return; @@ -74,12 +72,11 @@ void MdnsResponderService::OnRead(platform::UdpSocket* socket, HandleMdnsEvents(); } -void MdnsResponderService::OnSendError(platform::UdpSocket* socket, - Error error) { +void MdnsResponderService::OnSendError(UdpSocket* socket, Error error) { mdns_responder_->OnSendError(socket, std::move(error)); } -void MdnsResponderService::OnError(platform::UdpSocket* socket, Error error) { +void MdnsResponderService::OnError(UdpSocket* socket, Error error) { mdns_responder_->OnError(socket, std::move(error)); } @@ -334,7 +331,7 @@ void MdnsResponderService::StopListening() { } network_scoped_domain_to_host_.clear(); for (const auto& service : service_by_name_) { - platform::UdpSocket* const socket = service.second->ptr_socket; + UdpSocket* const socket = service.second->ptr_socket; mdns_responder_->StopSrvQuery(socket, service.first); mdns_responder_->StopTxtQuery(socket, service.first); } @@ -429,7 +426,7 @@ bool MdnsResponderService::HandlePtrEvent( InstanceNameSet* modified_instance_names) { bool events_possible = false; const auto& instance_name = ptr_event.service_instance; - platform::UdpSocket* const socket = ptr_event.header.socket; + UdpSocket* const socket = ptr_event.header.socket; auto entry = service_by_name_.find(ptr_event.service_instance); switch (ptr_event.header.response_type) { case QueryEventHeader::Type::kAddedNoCache: @@ -481,7 +478,7 @@ bool MdnsResponderService::HandleSrvEvent( bool events_possible = false; auto& domain_name = srv_event.domain_name; const auto& instance_name = srv_event.service_instance; - platform::UdpSocket* const socket = srv_event.header.socket; + UdpSocket* const socket = srv_event.header.socket; auto entry = service_by_name_.find(srv_event.service_instance); if (entry == service_by_name_.end()) return events_possible; @@ -568,7 +565,7 @@ bool MdnsResponderService::HandleTxtEvent( } bool MdnsResponderService::HandleAddressEvent( - platform::UdpSocket* socket, + UdpSocket* socket, QueryEventHeader::Type response_type, const DomainName& domain_name, bool a_event, @@ -619,14 +616,14 @@ bool MdnsResponderService::HandleAaaaEvent( } MdnsResponderService::HostInfo* MdnsResponderService::AddOrGetHostInfo( - platform::UdpSocket* socket, + UdpSocket* socket, const DomainName& domain_name) { return &network_scoped_domain_to_host_[NetworkScopedDomainName{socket, domain_name}]; } MdnsResponderService::HostInfo* MdnsResponderService::GetHostInfo( - platform::UdpSocket* socket, + UdpSocket* socket, const DomainName& domain_name) { auto kv = network_scoped_domain_to_host_.find( NetworkScopedDomainName{socket, domain_name}); @@ -642,16 +639,15 @@ bool MdnsResponderService::IsServiceReady(const ServiceInstance& instance, !instance.txt_info.empty() && (host->v4_address || host->v6_address)); } -platform::NetworkInterfaceIndex -MdnsResponderService::GetNetworkInterfaceIndexFromSocket( - const platform::UdpSocket* socket) const { +NetworkInterfaceIndex MdnsResponderService::GetNetworkInterfaceIndexFromSocket( + const UdpSocket* socket) const { auto it = std::find_if( bound_interfaces_.begin(), bound_interfaces_.end(), [socket](const MdnsPlatformService::BoundInterface& interface) { return interface.socket == socket; }); if (it == bound_interfaces_.end()) - return platform::kInvalidNetworkInterfaceIndex; + return kInvalidNetworkInterfaceIndex; return it->interface_info.index; } |