• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*-------------------------------------------------------------------------
2  * drawElements Quality Program Test Executor
3  * ------------------------------------------
4  *
5  * Copyright 2014 The Android Open Source Project
6  *
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  *
19  *//*!
20  * \file
21  * \brief Tcp/Ip link that manages execserver process.
22  *//*--------------------------------------------------------------------*/
23 
24 #include "xeLocalTcpIpLink.hpp"
25 #include "deClock.h"
26 #include "deThread.h"
27 
28 #include <sstream>
29 
30 enum
31 {
32 	SERVER_START_TIMEOUT	= 1000,
33 	SERVER_START_IDLE_SLEEP	= 50
34 };
35 
36 namespace xe
37 {
38 
LocalTcpIpLink(void)39 LocalTcpIpLink::LocalTcpIpLink (void)
40 	: m_process(DE_NULL)
41 {
42 }
43 
~LocalTcpIpLink(void)44 LocalTcpIpLink::~LocalTcpIpLink (void)
45 {
46 	stop();
47 }
48 
start(const char * execServerPath,const char * workDir,int port)49 void LocalTcpIpLink::start (const char* execServerPath, const char* workDir, int port)
50 {
51 	XE_CHECK(!m_process);
52 
53 	std::ostringstream cmdLine;
54 	cmdLine << execServerPath << " --single --port=" << port;
55 
56 	m_process = deProcess_create();
57 	XE_CHECK(m_process);
58 
59 	if (deProcess_start(m_process, cmdLine.str().c_str(), workDir) != DE_TRUE)
60 	{
61 		std::string err = deProcess_getLastError(m_process);
62 		deProcess_destroy(m_process);
63 		m_process = DE_NULL;
64 
65 		XE_FAIL((std::string("Failed to start ExecServer '") + execServerPath + "' : " + err).c_str());
66 	}
67 
68 	try
69 	{
70 		de::SocketAddress address;
71 		address.setFamily	(DE_SOCKETFAMILY_INET4);
72 		address.setProtocol	(DE_SOCKETPROTOCOL_TCP);
73 		address.setHost		("127.0.0.1");
74 		address.setPort		(port);
75 
76 		// Wait until server has started - \todo [2012-07-19 pyry] This could be improved by having server to signal when it is ready.
77 		deUint64 waitStart = deGetMicroseconds();
78 		for (;;)
79 		{
80 			if (!deProcess_isRunning(m_process))
81 				XE_FAIL("ExecServer died");
82 
83 			try
84 			{
85 				m_link.connect(address);
86 				break;
87 			}
88 			catch (const de::SocketError&)
89 			{
90 				if (deGetMicroseconds()-waitStart > SERVER_START_TIMEOUT*1000)
91 					XE_FAIL("Server start timeout");
92 
93 				deSleep(SERVER_START_IDLE_SLEEP);
94 			}
95 		}
96 
97 		// Close stdout/stderr or otherwise process will hang once OS pipe buffers are full.
98 		// \todo [2012-07-19 pyry] Read and store stdout/stderr from execserver.
99 		XE_CHECK(deProcess_closeStdOut(m_process));
100 		XE_CHECK(deProcess_closeStdErr(m_process));
101 	}
102 	catch (const std::exception&)
103 	{
104 		stop();
105 		throw;
106 	}
107 }
108 
stop(void)109 void LocalTcpIpLink::stop (void)
110 {
111 	if (m_process)
112 	{
113 		try
114 		{
115 			m_link.disconnect();
116 		}
117 		catch (...)
118 		{
119 			// Silently ignore since this is called in destructor.
120 		}
121 
122 		// \note --single flag is used so execserver should kill itself once one connection is handled.
123 		//		 This is here to make sure it dies even in case of hang.
124 		deProcess_terminate		(m_process);
125 		deProcess_waitForFinish	(m_process);
126 		deProcess_destroy		(m_process);
127 
128 		m_process = DE_NULL;
129 	}
130 }
131 
reset(void)132 void LocalTcpIpLink::reset (void)
133 {
134 	m_link.reset();
135 }
136 
getState(void) const137 CommLinkState LocalTcpIpLink::getState (void) const
138 {
139 	if (!m_process)
140 		return COMMLINKSTATE_ERROR;
141 	else
142 		return m_link.getState();
143 }
144 
getState(std::string & error) const145 CommLinkState LocalTcpIpLink::getState (std::string& error) const
146 {
147 	if (!m_process)
148 	{
149 		error = "Not started";
150 		return COMMLINKSTATE_ERROR;
151 	}
152 	else
153 		return m_link.getState();
154 }
155 
setCallbacks(StateChangedFunc stateChangedCallback,LogDataFunc testLogDataCallback,LogDataFunc infoLogDataCallback,void * userPtr)156 void LocalTcpIpLink::setCallbacks (StateChangedFunc stateChangedCallback, LogDataFunc testLogDataCallback, LogDataFunc infoLogDataCallback, void* userPtr)
157 {
158 	m_link.setCallbacks(stateChangedCallback, testLogDataCallback, infoLogDataCallback, userPtr);
159 }
160 
startTestProcess(const char * name,const char * params,const char * workingDir,const char * caseList)161 void LocalTcpIpLink::startTestProcess (const char* name, const char* params, const char* workingDir, const char* caseList)
162 {
163 	if (m_process)
164 		m_link.startTestProcess(name, params, workingDir, caseList);
165 	else
166 		XE_FAIL("Not started");
167 }
168 
stopTestProcess(void)169 void LocalTcpIpLink::stopTestProcess (void)
170 {
171 	if (m_process)
172 		m_link.stopTestProcess();
173 	else
174 		XE_FAIL("Not started");
175 }
176 
177 } // xe
178