1
- available_commands = ["quit" , "list" , "start" , "kill" , "status" , "restart" , "clear" ]
1
+ import logging as log
2
+ available_commands = ["quit" , "list" , "start" , "kill" , "status" , "restart" , "clear" , "keepalive" ]
2
3
3
4
def handle_input (command , worker , server = None ):
4
5
command = command .strip ()
@@ -10,6 +11,16 @@ def handle_input(command, worker, server=None):
10
11
output = eval ("%s" % command [0 ])(worker , command , server )
11
12
return True , output
12
13
14
+ def keepalive (worker , args = None , server = None ):
15
+ if len (args ) < 3 :
16
+ return "You must specify a value. Example : keepalive 1 true"
17
+ id = int (args [1 ])
18
+ service = worker .getService (id )
19
+ if service is None :
20
+ return "There isn't such service"
21
+ service .keepAlive = bool (args [2 ])
22
+ return args [2 ]
23
+
13
24
def restart (worker , args = None , server = None ):
14
25
worker .restart ()
15
26
return "Worker restarted"
@@ -42,7 +53,7 @@ def status(worker, args=None, server=None):
42
53
def list (worker , args = None , server = None ):
43
54
strlist = ""
44
55
for service in worker .services :
45
- strlist += "[%i] | %s | Alive : %s\n " % (service .id , service .name , service .isAlive ())
56
+ strlist += "[%i] | %s | Alive : %s | keepAlive : %s \n " % (service .id , service .name , service .isAlive (), service . keepAlive )
46
57
return strlist
47
58
48
59
def start (worker , args = None , server = None ):
@@ -52,7 +63,7 @@ def start(worker, args=None, server=None):
52
63
if service is None :
53
64
return "There isn't such service"
54
65
if not service .isAlive ():
55
- service .restart ()
66
+ service .start ()
56
67
return "service started"
57
68
else :
58
69
log .warning ("Service %i is already running" % id )
0 commit comments