1#ifndef _XSTCPSERVER_HPP
2#define _XSTCPSERVER_HPP
3/*-------------------------------------------------------------------------
4 * drawElements Quality Program Execution Server
5 * ---------------------------------------------
6 *
7 * Copyright 2014 The Android Open Source Project
8 *
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
12 *
13 *      http://www.apache.org/licenses/LICENSE-2.0
14 *
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
20 *
21 *//*!
22 * \file
23 * \brief TCP Server.
24 *//*--------------------------------------------------------------------*/
25
26#include "xsDefs.hpp"
27#include "deSocket.hpp"
28#include "deThread.hpp"
29#include "deMutex.hpp"
30
31#include <vector>
32
33namespace xs
34{
35
36class ConnectionHandler;
37
38class TcpServer
39{
40public:
41									TcpServer				(deSocketFamily family, int port);
42	virtual							~TcpServer				(void);
43
44	virtual ConnectionHandler*		createHandler			(de::Socket* socket, const de::SocketAddress& clientAddress) = DE_NULL;
45
46	virtual void					runServer				(void);
47	void							stopServer				(void);
48
49	virtual void					connectionDone			(ConnectionHandler* handler);
50
51protected:
52	de::Socket						m_socket;
53
54private:
55									TcpServer				(const TcpServer& other);
56	TcpServer&						operator=				(const TcpServer& other);
57
58	void							addLiveConnection		(ConnectionHandler* handler);
59	void							deleteDoneConnections	(void);
60
61	de::Mutex						m_connectionListLock;
62	std::vector<ConnectionHandler*>	m_liveConnections;
63	std::vector<ConnectionHandler*>	m_doneConnections;
64};
65
66class ConnectionHandler : public de::Thread
67{
68public:
69						ConnectionHandler		(TcpServer* server, de::Socket* socket) : m_server(server), m_socket(socket) {}
70	virtual				~ConnectionHandler		(void);
71
72	void				run						(void);
73
74protected:
75	virtual void		handle					(void) = DE_NULL;
76
77protected:
78	TcpServer*			m_server;
79	de::Socket*			m_socket;
80};
81
82} // xs
83
84#endif // _XSTCPSERVER_HPP
85