1 #ifndef _XEBATCHEXECUTOR_HPP
2 #define _XEBATCHEXECUTOR_HPP
3 /*-------------------------------------------------------------------------
4  * drawElements Quality Program Test Executor
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 Test batch executor.
24  *//*--------------------------------------------------------------------*/
25 
26 #include "xeDefs.hpp"
27 #include "xeBatchResult.hpp"
28 #include "xeCommLink.hpp"
29 #include "xeTestLogParser.hpp"
30 #include "xeCallQueue.hpp"
31 
32 #include <string>
33 #include <vector>
34 
35 namespace xe
36 {
37 
38 struct TargetConfiguration
39 {
TargetConfigurationxe::TargetConfiguration40 	TargetConfiguration (void)
41 		: maxCasesPerSession(1000)
42 	{
43 	}
44 
45 	std::string		binaryName;
46 	std::string		workingDir;
47 	std::string		cmdLineArgs;
48 	int				maxCasesPerSession;
49 };
50 
51 class BatchExecutorLogHandler : public TestLogHandler
52 {
53 public:
54 							BatchExecutorLogHandler		(BatchResult* batchResult);
55 							~BatchExecutorLogHandler	(void);
56 
57 	void					setSessionInfo				(const SessionInfo& sessionInfo);
58 
59 	TestCaseResultPtr		startTestCaseResult			(const char* casePath);
60 	void					testCaseResultUpdated		(const TestCaseResultPtr& resultData);
61 	void					testCaseResultComplete		(const TestCaseResultPtr& resultData);
62 
63 private:
64 	BatchResult*			m_batchResult;
65 };
66 
67 class BatchExecutor
68 {
69 public:
70 							BatchExecutor		(const TargetConfiguration& config, CommLink* commLink, const TestNode* root, const TestSet& testSet, BatchResult* batchResult, InfoLog* infoLog);
71 							~BatchExecutor		(void);
72 
73 	void					run					(void);
74 	void					cancel				(void); //!< Cancel current run(), can be called from any thread.
75 
76 private:
77 							BatchExecutor		(const BatchExecutor& other);
78 	BatchExecutor&			operator=			(const BatchExecutor& other);
79 
80 	bool					iterate				(void);
81 
82 	void					onStateChanged		(CommLinkState state, const char* message);
83 	void					onTestLogData		(const deUint8* bytes, int numBytes);
84 	void					onInfoLogData		(const deUint8* bytes, int numBytes);
85 
86 	void					launchTestSet		(const TestSet& testSet);
87 
88 	// Callbacks for CommLink.
89 	static void				enqueueStateChanged	(void* userPtr, CommLinkState state, const char* message);
90 	static void				enqueueTestLogData	(void* userPtr, const deUint8* bytes, int numBytes);
91 	static void				enqueueInfoLogData	(void* userPtr, const deUint8* bytes, int numBytes);
92 
93 	// Called in CallQueue dispatch.
94 	static void				dispatchStateChanged	(CallReader data);
95 	static void				dispatchTestLogData		(CallReader data);
96 	static void				dispatchInfoLogData		(CallReader data);
97 
98 	enum State
99 	{
100 		STATE_NOT_STARTED,
101 		STATE_STARTED,
102 		STATE_FINISHED,
103 
104 		STATE_LAST
105 	};
106 
107 	TargetConfiguration		m_config;
108 	CommLink*				m_commLink;
109 
110 	const TestNode*			m_root;
111 	const TestSet&			m_testSet;
112 
113 	BatchExecutorLogHandler	m_logHandler;
114 	BatchResult*			m_batchResult;
115 	InfoLog*				m_infoLog;
116 
117 	State					m_state;
118 	TestSet					m_casesToExecute;
119 
120 	TestLogParser			m_testLogParser;
121 
122 	CallQueue				m_dispatcher;
123 };
124 
125 } // xe
126 
127 #endif // _XEBATCHEXECUTOR_HPP
128