-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsmallServer.py
52 lines (43 loc) · 1.47 KB
/
smallServer.py
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
import json
import socket
import threading
import SocketServer
import subprocess
from subprocess import call
def get_ip_address():
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect(("8.8.8.8", 80))
return s.getsockname()[0]
class ThreadedDeviceRequestHandler(SocketServer.BaseRequestHandler):
def handle(self):
dev_data = self.request.recv(1024)
print dev_data
data = json.loads(dev_data)
if data['command'] == 'start':
print 'start servers'
deluged = subprocess.Popen('deluged', shell=True)
deluge_web = subprocess.Popen('deluge-web &', shell=True)
deluged.wait()
deluge_web.wait()
elif data['command'] == 'stop':
print 'Killing servers'
call (["pkill deluge"], shell=True)
else:
print 'Not a command'
return
class ThreadedDeviceServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
pass
if __name__ == '__main__':
ip = get_ip_address()
port = 5050
print 'IPADDR:' + ip + ' on Port:' + str(port)
address = (ip, port) # let the kernel give us a port
server = ThreadedDeviceServer(address, ThreadedDeviceRequestHandler)
server.allow_reuse_address = True
t = threading.Thread(target=server.serve_forever)
t.setDaemon(True) # don't hang on exit
t.start()
print 'Server loop running in thread:', t.getName()
# Don't exit
while True:
pass