Import dEQP.
Import drawElements Quality Program from an internal repository.
Bug: 17388917
Change-Id: Ic109fe4a57e31b2a816113d90fbdf51a43e7abeb
diff --git a/executor/xeLocalTcpIpLink.cpp b/executor/xeLocalTcpIpLink.cpp
new file mode 100644
index 0000000..0550582
--- /dev/null
+++ b/executor/xeLocalTcpIpLink.cpp
@@ -0,0 +1,177 @@
+/*-------------------------------------------------------------------------
+ * drawElements Quality Program Test Executor
+ * ------------------------------------------
+ *
+ * Copyright 2014 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ *//*!
+ * \file
+ * \brief Tcp/Ip link that manages execserver process.
+ *//*--------------------------------------------------------------------*/
+
+#include "xeLocalTcpIpLink.hpp"
+#include "deClock.h"
+#include "deThread.h"
+
+#include <sstream>
+
+enum
+{
+ SERVER_START_TIMEOUT = 1000,
+ SERVER_START_IDLE_SLEEP = 50
+};
+
+namespace xe
+{
+
+LocalTcpIpLink::LocalTcpIpLink (void)
+ : m_process(DE_NULL)
+{
+}
+
+LocalTcpIpLink::~LocalTcpIpLink (void)
+{
+ stop();
+}
+
+void LocalTcpIpLink::start (const char* execServerPath, const char* workDir, int port)
+{
+ XE_CHECK(!m_process);
+
+ std::ostringstream cmdLine;
+ cmdLine << execServerPath << " --single --port=" << port;
+
+ m_process = deProcess_create();
+ XE_CHECK(m_process);
+
+ if (deProcess_start(m_process, cmdLine.str().c_str(), workDir) != DE_TRUE)
+ {
+ std::string err = deProcess_getLastError(m_process);
+ deProcess_destroy(m_process);
+ m_process = DE_NULL;
+
+ XE_FAIL((std::string("Failed to start server: ") + err).c_str());
+ }
+
+ try
+ {
+ de::SocketAddress address;
+ address.setFamily (DE_SOCKETFAMILY_INET4);
+ address.setProtocol (DE_SOCKETPROTOCOL_TCP);
+ address.setHost ("127.0.0.1");
+ address.setPort (port);
+
+ // Wait until server has started - \todo [2012-07-19 pyry] This could be improved by having server to signal when it is ready.
+ deUint64 waitStart = deGetMicroseconds();
+ for (;;)
+ {
+ if (!deProcess_isRunning(m_process))
+ XE_FAIL("ExecServer died");
+
+ try
+ {
+ m_link.connect(address);
+ break;
+ }
+ catch (const de::SocketError&)
+ {
+ if (deGetMicroseconds()-waitStart > SERVER_START_TIMEOUT*1000)
+ XE_FAIL("Server start timeout");
+
+ deSleep(SERVER_START_IDLE_SLEEP);
+ }
+ }
+
+ // Close stdout/stderr or otherwise process will hang once OS pipe buffers are full.
+ // \todo [2012-07-19 pyry] Read and store stdout/stderr from execserver.
+ XE_CHECK(deProcess_closeStdOut(m_process));
+ XE_CHECK(deProcess_closeStdErr(m_process));
+ }
+ catch (const std::exception&)
+ {
+ stop();
+ throw;
+ }
+}
+
+void LocalTcpIpLink::stop (void)
+{
+ if (m_process)
+ {
+ try
+ {
+ m_link.disconnect();
+ }
+ catch (...)
+ {
+ // Silently ignore since this is called in destructor.
+ }
+
+ // \note --single flag is used so execserver should kill itself once one connection is handled.
+ // This is here to make sure it dies even in case of hang.
+ deProcess_terminate (m_process);
+ deProcess_waitForFinish (m_process);
+ deProcess_destroy (m_process);
+
+ m_process = DE_NULL;
+ }
+}
+
+void LocalTcpIpLink::reset (void)
+{
+ m_link.reset();
+}
+
+CommLinkState LocalTcpIpLink::getState (void) const
+{
+ if (!m_process)
+ return COMMLINKSTATE_ERROR;
+ else
+ return m_link.getState();
+}
+
+CommLinkState LocalTcpIpLink::getState (std::string& error) const
+{
+ if (!m_process)
+ {
+ error = "Not started";
+ return COMMLINKSTATE_ERROR;
+ }
+ else
+ return m_link.getState();
+}
+
+void LocalTcpIpLink::setCallbacks (StateChangedFunc stateChangedCallback, LogDataFunc testLogDataCallback, LogDataFunc infoLogDataCallback, void* userPtr)
+{
+ m_link.setCallbacks(stateChangedCallback, testLogDataCallback, infoLogDataCallback, userPtr);
+}
+
+void LocalTcpIpLink::startTestProcess (const char* name, const char* params, const char* workingDir, const char* caseList)
+{
+ if (m_process)
+ m_link.startTestProcess(name, params, workingDir, caseList);
+ else
+ XE_FAIL("Not started");
+}
+
+void LocalTcpIpLink::stopTestProcess (void)
+{
+ if (m_process)
+ m_link.stopTestProcess();
+ else
+ XE_FAIL("Not started");
+}
+
+} // xe