aboutsummaryrefslogtreecommitdiff
path: root/osp/impl/internal_services.h
diff options
context:
space:
mode:
Diffstat (limited to 'osp/impl/internal_services.h')
-rw-r--r--osp/impl/internal_services.h31
1 files changed, 13 insertions, 18 deletions
diff --git a/osp/impl/internal_services.h b/osp/impl/internal_services.h
index 5a1f015a..364c5963 100644
--- a/osp/impl/internal_services.h
+++ b/osp/impl/internal_services.h
@@ -25,9 +25,7 @@
namespace openscreen {
-namespace platform {
class TaskRunner;
-} // namespace platform
namespace osp {
@@ -36,22 +34,21 @@ namespace osp {
// event loop.
// TODO(btolsch): This may be renamed and/or split up once QUIC code lands and
// this use case is more concrete.
-class InternalServices : platform::UdpSocket::Client {
+class InternalServices : UdpSocket::Client {
public:
static std::unique_ptr<ServiceListener> CreateListener(
const MdnsServiceListenerConfig& config,
ServiceListener::Observer* observer,
- platform::TaskRunner* task_runner);
+ TaskRunner* task_runner);
static std::unique_ptr<ServicePublisher> CreatePublisher(
const ServicePublisher::Config& config,
ServicePublisher::Observer* observer,
- platform::TaskRunner* task_runner);
+ TaskRunner* task_runner);
// UdpSocket::Client overrides.
- void OnError(platform::UdpSocket* socket, Error error) override;
- void OnSendError(platform::UdpSocket* socket, Error error) override;
- void OnRead(platform::UdpSocket* socket,
- ErrorOr<platform::UdpPacket> packet) override;
+ void OnError(UdpSocket* socket, Error error) override;
+ void OnSendError(UdpSocket* socket, Error error) override;
+ void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
private:
class InternalPlatformLinkage final : public MdnsPlatformService {
@@ -60,31 +57,29 @@ class InternalServices : platform::UdpSocket::Client {
~InternalPlatformLinkage() override;
std::vector<BoundInterface> RegisterInterfaces(
- const std::vector<platform::NetworkInterfaceIndex>& whitelist) override;
+ const std::vector<NetworkInterfaceIndex>& whitelist) override;
void DeregisterInterfaces(
const std::vector<BoundInterface>& registered_interfaces) override;
private:
InternalServices* const parent_;
- std::vector<platform::UdpSocketUniquePtr> open_sockets_;
+ std::vector<std::unique_ptr<UdpSocket>> open_sockets_;
};
// The TaskRunner provided here should live for the duration of this
// InternalService object's lifetime.
- InternalServices(platform::ClockNowFunctionPtr now_function,
- platform::TaskRunner* task_runner);
+ InternalServices(ClockNowFunctionPtr now_function, TaskRunner* task_runner);
~InternalServices() override;
- void RegisterMdnsSocket(platform::UdpSocket* socket);
- void DeregisterMdnsSocket(platform::UdpSocket* socket);
+ void RegisterMdnsSocket(UdpSocket* socket);
+ void DeregisterMdnsSocket(UdpSocket* socket);
- static InternalServices* ReferenceSingleton(
- platform::TaskRunner* task_runner);
+ static InternalServices* ReferenceSingleton(TaskRunner* task_runner);
static void DereferenceSingleton(void* instance);
MdnsResponderService mdns_service_;
- platform::TaskRunner* const task_runner_;
+ TaskRunner* const task_runner_;
OSP_DISALLOW_COPY_AND_ASSIGN(InternalServices);
};