// Copyright 2020 Google LLC // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // https://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. #ifndef PLATFORM_IMPL_WINDOWS_WIFI_HOTSPOT_SERVER_SOCKET_H_ #define PLATFORM_IMPL_WINDOWS_WIFI_HOTSPOT_SERVER_SOCKET_H_ // Windows headers #include #include #include // Standard C/C++ headers #include #include #include #include #include #include // Nearby connections headers #include "absl/base/thread_annotations.h" #include "absl/functional/any_invocable.h" #include "absl/synchronization/mutex.h" #include "internal/platform/cancellation_flag.h" #include "internal/platform/exception.h" #include "internal/platform/implementation/wifi_hotspot.h" #include "internal/platform/implementation/windows/nearby_server_socket.h" #include "internal/platform/wifi_credential.h" namespace nearby::windows { // WifiHotspotServerSocket provides the support to server socket, this server // socket accepts connection from clients. class WifiHotspotServerSocket : public api::WifiHotspotServerSocket { public: WifiHotspotServerSocket() = default; WifiHotspotServerSocket(WifiHotspotServerSocket&&) = default; ~WifiHotspotServerSocket() override = default; WifiHotspotServerSocket& operator=(WifiHotspotServerSocket&&) = default; int GetPort() const override { return server_socket_.GetPort(); } // Blocks until either: // - at least one incoming connection request is available, or // - ServerSocket is closed. // On success, returns connected socket, ready to exchange data. // Returns nullptr on error. // Once error is reported, it is permanent, and ServerSocket has to be closed. std::unique_ptr Accept() override; // Called by the server side of a connection before passing ownership of // WifiHotspotServerSocker to user, to track validity of a pointer to this // server socket. void SetCloseNotifier(absl::AnyInvocable notifier) { server_socket_.SetCloseNotifier(std::move(notifier)); } // Returns Exception::kIo on error, Exception::kSuccess otherwise. Exception Close() override { server_socket_.Close(); return {Exception::kSuccess}; } void PopulateHotspotCredentials( HotspotCredentials& hotspot_credentials) override; // Binds to local port bool Listen(int port); private: NearbyServerSocket server_socket_; }; } // namespace nearby::windows #endif // PLATFORM_IMPL_WINDOWS_WIFI_HOTSPOT_SERVER_SOCKET_H_