ResponderImpl.h 1.27 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
/*
 * Copyright 2015 Institut Laue-Langevin
 *
 * Licensed under the EUPL, Version 1.1 only (the "License");
 * You may not use this work except in compliance with the Licence.
 * You may obtain a copy of the Licence at:
 *
 * http://joinup.ec.europa.eu/software/page/eupl
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the Licence is distributed on an "AS IS" basis,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the Licence for the specific language governing permissions and
 * limitations under the Licence.
 */

#ifndef CAMEO_RESPONDERIMPL_H_
#define CAMEO_RESPONDERIMPL_H_

20
21
#include "GenericWaitingImpl.h"
#include "zmq.hpp"
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#include <string>
#include <vector>
#include <memory>

namespace cameo {

namespace application {
	class This;
}

class RequestImpl;

class ResponderImpl {

public:
	ResponderImpl(application::This * application, int responderPort, const std::string& name);
	~ResponderImpl();

	void cancel();
	WaitingImpl * waiting();

	std::unique_ptr<RequestImpl> receive();
	void terminate();

	application::This * m_application;
	int m_responderPort;
	std::string m_name;
	std::unique_ptr<zmq::socket_t> m_responder;
	bool m_canceled;

	static const std::string RESPONDER_PREFIX;
};

}

#endif