#ifndef WebSocketServer_h
#define WebSocketServer_h
#if ENABLE(INSPECTOR_SERVER)
#include <memory>
#include <wtf/Deque.h>
#include <wtf/text/WTFString.h>
#if USE(SOUP)
#include <gio/gio.h>
#include <wtf/gobject/GRefPtr.h>
#endif
namespace WebCore {
class SocketStreamHandle;
}
namespace WebKit {
class WebSocketServerClient;
class WebSocketServerConnection;
class WebSocketServer {
public:
enum ServerState { Closed, Listening };
explicit WebSocketServer(WebSocketServerClient*);
virtual ~WebSocketServer();
bool listen(const String& bindAddress, unsigned short port);
String bindAddress() const { return m_bindAddress; };
unsigned short port() const { return m_port; };
ServerState serverState() const { return m_state; };
void close();
WebSocketServerClient* client() const { return m_client; }
void didAcceptConnection(std::unique_ptr<WebSocketServerConnection>);
private:
void didCloseWebSocketServerConnection(WebSocketServerConnection*);
void platformInitialize();
bool platformListen(const String& bindAddress, unsigned short port);
void platformClose();
ServerState m_state;
Deque<std::unique_ptr<WebSocketServerConnection>> m_connections;
WebSocketServerClient* m_client;
String m_bindAddress;
unsigned short m_port;
#if USE(SOUP)
GRefPtr<GSocketService> m_socketService;
#endif
friend class WebSocketServerConnection;
};
}
#endif // ENABLE(INSPECTOR_SERVER)
#endif // WebSocketServer_h