#ifndef _XEBATCHEXECUTOR_HPP
#define _XEBATCHEXECUTOR_HPP
/*-------------------------------------------------------------------------
 * 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 Test batch executor.
 *//*--------------------------------------------------------------------*/

#include "xeDefs.hpp"
#include "xeBatchResult.hpp"
#include "xeCommLink.hpp"
#include "xeTestLogParser.hpp"
#include "xeCallQueue.hpp"

#include <string>
#include <vector>

namespace xe
{

struct TargetConfiguration
{
	TargetConfiguration (void)
		: maxCasesPerSession(1000)
	{
	}

	std::string		binaryName;
	std::string		workingDir;
	std::string		cmdLineArgs;
	int				maxCasesPerSession;
};

class BatchExecutorLogHandler : public TestLogHandler
{
public:
							BatchExecutorLogHandler		(BatchResult* batchResult);
							~BatchExecutorLogHandler	(void);

	void					setSessionInfo				(const SessionInfo& sessionInfo);

	TestCaseResultPtr		startTestCaseResult			(const char* casePath);
	void					testCaseResultUpdated		(const TestCaseResultPtr& resultData);
	void					testCaseResultComplete		(const TestCaseResultPtr& resultData);

private:
	BatchResult*			m_batchResult;
};

class BatchExecutor
{
public:
							BatchExecutor		(const TargetConfiguration& config, CommLink* commLink, const TestNode* root, const TestSet& testSet, BatchResult* batchResult, InfoLog* infoLog);
							~BatchExecutor		(void);

	void					run					(void);
	void					cancel				(void); //!< Cancel current run(), can be called from any thread.

private:
							BatchExecutor		(const BatchExecutor& other);
	BatchExecutor&			operator=			(const BatchExecutor& other);

	bool					iterate				(void);

	void					onStateChanged		(CommLinkState state, const char* message);
	void					onTestLogData		(const deUint8* bytes, size_t numBytes);
	void					onInfoLogData		(const deUint8* bytes, size_t numBytes);

	void					launchTestSet		(const TestSet& testSet);

	// Callbacks for CommLink.
	static void				enqueueStateChanged	(void* userPtr, CommLinkState state, const char* message);
	static void				enqueueTestLogData	(void* userPtr, const deUint8* bytes, size_t numBytes);
	static void				enqueueInfoLogData	(void* userPtr, const deUint8* bytes, size_t numBytes);

	// Called in CallQueue dispatch.
	static void				dispatchStateChanged	(CallReader& data);
	static void				dispatchTestLogData		(CallReader& data);
	static void				dispatchInfoLogData		(CallReader& data);

	enum State
	{
		STATE_NOT_STARTED,
		STATE_STARTED,
		STATE_FINISHED,

		STATE_LAST
	};

	TargetConfiguration		m_config;
	CommLink*				m_commLink;

	const TestNode*			m_root;
	const TestSet&			m_testSet;

	BatchExecutorLogHandler	m_logHandler;
	BatchResult*			m_batchResult;
	InfoLog*				m_infoLog;

	State					m_state;
	TestSet					m_casesToExecute;

	TestLogParser			m_testLogParser;

	CallQueue				m_dispatcher;
};

} // xe

#endif // _XEBATCHEXECUTOR_HPP