X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=acceptor.h;h=fe62c31396d119ea97addc6bdafae262fef8d452;hp=f173e5b647e68d9c4d8cad2ac64e99b7c4523dd0;hb=6544fa0ec3f3a501bcb89ea977756911bd7f3ebd;hpb=3f82e5f8ede16a712aa0bcd0913d2d8e3689742c

diff --git a/acceptor.h b/acceptor.h
index f173e5b..fe62c31 100644
--- a/acceptor.h
+++ b/acceptor.h
@@ -1,10 +1,38 @@
 #ifndef _ACCEPTOR_H
 #define _ACCEPTOR_H
 
-int create_server_socket(int port);
+#include <netinet/in.h>
+
+#include "thread.h"
+
+enum SocketType {
+	TCP_SOCKET,
+	UDP_SOCKET,
+};
+int create_server_socket(const sockaddr_in6 &addr, SocketType socket_type);
+
+class AcceptorProto;
+
+sockaddr_in6 create_any_address(int port);
+sockaddr_in6 extract_address_from_acceptor_proto(const AcceptorProto &proto);
 
 // A thread that accepts new connections on a given socket,
 // and hands them off to the server pool.
-void *acceptor_thread_run(void *arg);
+class Acceptor : public Thread {
+public:
+	Acceptor(int server_sock, const sockaddr_in6 &addr);
+
+	// Serialization/deserialization.
+	Acceptor(const AcceptorProto &serialized);
+	AcceptorProto serialize() const;
+
+	void close_socket();
+
+private:
+	virtual void do_work();
+
+	int server_sock;
+	sockaddr_in6 addr;
+};
 
 #endif  // !defined(_ACCEPTOR_H)