summaryrefslogtreecommitdiffstats
path: root/src/uscxml/plugins/element/postpone/PostponeElement.h
blob: f0c42c092cd9c46324f807d4c87dffaa4a97a778 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
#ifndef POSTPONEELEMENT_H_WN8EIYYI
#define POSTPONEELEMENT_H_WN8EIYYI

#include <uscxml/Interpreter.h>
#include <list>

#ifdef BUILD_AS_PLUGINS
#include "uscxml/plugins/Plugins.h"
#endif

namespace uscxml {

class PostponeElement : public ExecutableContentImpl {
public:
	struct Postponed {
		Postponed(const Event& event, const std::string& until, long timeout, bool chaining = false) :
			event(event), until(until), timeout(timeout), chaining(chaining) {}
		Event event;
		std::string until;
		uint64_t timeout;
		bool chaining;
	};

	PostponeElement() {}
	virtual ~PostponeElement() {}
	boost::shared_ptr<ExecutableContentImpl> create(InterpreterImpl* interpreter);

	std::string getLocalName() {
		return "postpone";
	}

	std::string getNamespace() {
		return "http://www.w3.org/2005/07/scxml";
	}

	bool processChildren() {
		return false;
	}

	void enterElement(const Arabica::DOM::Node<std::string>& node);
	void exitElement(const Arabica::DOM::Node<std::string>& node);

protected:
	// once per interpreter
	class Resubmitter : public InterpreterMonitor {
	public:
		Resubmitter(InterpreterImpl* interpreter) {
			interpreter->addMonitor(this);
		}

		static Resubmitter* getInstance(InterpreterImpl* interpreter);
		static void postpone(const Event& event, std::string until, uint64_t timeout, bool chained, InterpreterImpl* interpreter);

		// InterpreterMonitor
		void onStableConfiguration(Interpreter interpreter);
		void afterCompletion(Interpreter interpreter);

		std::list<Postponed> _postponedEvents;
		static std::map<Interpreter, Resubmitter*> _instances;
		static tthread::recursive_mutex _accessLock;

	};
};

#ifdef BUILD_AS_PLUGINS
PLUMA_INHERIT_PROVIDER(PostponeElement, ExecutableContentImpl);
#endif

}

#endif /* end of include guard: POSTPONEELEMENT_H_WN8EIYYI */