Fix atomic ssbo xor test am: f0fa05e898 am: b426d8bfad am: 580f143209 am: 73a16f417e
[platform/upstream/VK-GL-CTS.git] / executor / xeLocalTcpIpLink.cpp
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
39 LocalTcpIpLink::LocalTcpIpLink (void)
40         : m_process(DE_NULL)
41 {
42 }
43
44 LocalTcpIpLink::~LocalTcpIpLink (void)
45 {
46         stop();
47 }
48
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
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
132 void LocalTcpIpLink::reset (void)
133 {
134         m_link.reset();
135 }
136
137 CommLinkState LocalTcpIpLink::getState (void) const
138 {
139         if (!m_process)
140                 return COMMLINKSTATE_ERROR;
141         else
142                 return m_link.getState();
143 }
144
145 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
156 void LocalTcpIpLink::setCallbacks (StateChangedFunc stateChangedCallback, LogDataFunc testLogDataCallback, LogDataFunc infoLogDataCallback, void* userPtr)
157 {
158         m_link.setCallbacks(stateChangedCallback, testLogDataCallback, infoLogDataCallback, userPtr);
159 }
160
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
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