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
|
# This module must not depend on any other non-stdlib module to prevent
# circular import problems.
class ProcessStates:
STOPPED = 0
STARTING = 10
RUNNING = 20
BACKOFF = 30
STOPPING = 40
EXITED = 100
FATAL = 200
UNKNOWN = 1000
STOPPED_STATES = (ProcessStates.STOPPED,
ProcessStates.EXITED,
ProcessStates.FATAL,
ProcessStates.UNKNOWN)
RUNNING_STATES = (ProcessStates.RUNNING,
ProcessStates.BACKOFF,
ProcessStates.STARTING)
def getProcessStateDescription(code):
return _process_states_by_code.get(code)
class SupervisorStates:
FATAL = 2
RUNNING = 1
RESTARTING = 0
SHUTDOWN = -1
def getSupervisorStateDescription(code):
return _supervisor_states_by_code.get(code)
class EventListenerStates:
READY = 10 # the process ready to be sent an event from supervisor
BUSY = 20 # event listener is processing an event sent to it by supervisor
ACKNOWLEDGED = 30 # the event listener processed an event
UNKNOWN = 40 # the event listener is in an unknown state
def getEventListenerStateDescription(code):
return _eventlistener_states_by_code.get(code)
# below is an optimization for internal use in this module only
def _names_by_code(states):
d = {}
for name in states.__dict__:
if not name.startswith('__'):
code = getattr(states, name)
d[code] = name
return d
_process_states_by_code = _names_by_code(ProcessStates)
_supervisor_states_by_code = _names_by_code(SupervisorStates)
_eventlistener_states_by_code = _names_by_code(EventListenerStates)
|
