Imported Upstream version 1.0.0
[platform/upstream/iotivity.git] / service / simulator / src / client-controller / get_request_generator.h
1 /******************************************************************
2  *
3  * Copyright 2015 Samsung Electronics All Rights Reserved.
4  *
5  *
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
21 #ifndef GET_REQUEST_GEN_H_
22 #define GET_REQUEST_GEN_H_
23
24 #include "auto_request_gen.h"
25 #include "query_param_generator.h"
26
27 class GETRequestGenerator : public AutoRequestGeneration
28 {
29     public:
30         GETRequestGenerator(int id, RequestSenderSP &requestSender, ProgressStateCallback callback);
31
32         GETRequestGenerator(int id, RequestSenderSP &requestSender,
33                             const std::map<std::string, std::vector<std::string>> &queryParams,
34                             ProgressStateCallback callback);
35
36         void startSending();
37         void stopSending();
38
39     private:
40         void SendAllRequests();
41         void onResponseReceived(SimulatorResult result, SimulatorResourceModelSP repModel);
42         void completed();
43
44         QPGenerator m_queryParamGen;
45         std::mutex m_statusLock;
46         bool m_status;
47         bool m_stopRequested;
48         std::shared_ptr<std::thread> m_thread;
49 };
50
51 typedef std::shared_ptr<GETRequestGenerator> GETRequestGeneratorSP;
52
53 #endif