diff options
author | RaNaN <Mast3rRaNaN@hotmail.de> | 2010-03-30 17:51:38 +0200 |
---|---|---|
committer | RaNaN <Mast3rRaNaN@hotmail.de> | 2010-03-30 17:51:38 +0200 |
commit | 4a99e86c462e09e3e050a9e0204e602ce8ebe30b (patch) | |
tree | 932dbe90a9c852a45b783efaf13eb811997d73fe /module/web/ServerThread.py | |
parent | fixes #64 (diff) | |
download | pyload-4a99e86c462e09e3e050a9e0204e602ce8ebe30b.tar.xz |
configuration assistent, some fixes
Diffstat (limited to 'module/web/ServerThread.py')
-rw-r--r-- | module/web/ServerThread.py | 27 |
1 files changed, 16 insertions, 11 deletions
diff --git a/module/web/ServerThread.py b/module/web/ServerThread.py index 0fbb65dfa..718dd6136 100644 --- a/module/web/ServerThread.py +++ b/module/web/ServerThread.py @@ -6,7 +6,7 @@ from subprocess import PIPE from subprocess import Popen from subprocess import call from sys import version_info -from sys import stdout +from cStringIO import StringIO import threading class WebServer(threading.Thread): @@ -23,10 +23,11 @@ class WebServer(threading.Thread): host = self.pycore.config['webinterface']['host'] port = self.pycore.config['webinterface']['port'] path = join(self.pycore.path, "module", "web") + out = StringIO() if not exists(join(self.pycore.path, "module", "web", "pyload.db")): print "########## IMPORTANT ###########" - print "### Database for Webinterface doesnt exitst, it will not be available." + print "### Database for Webinterface does not exitst, it will not be available." print "### Please run: python %s syncdb" % join(self.pycore.path, "module", "web", "manage.py") print "### You have to add at least one User, to gain access to webinterface: python %s createsuperuser" % join(self.pycore.path, "module", "web", "manage.py") print "### Dont forget to restart pyLoad if you are done." @@ -107,10 +108,10 @@ class WebServer(threading.Thread): new_config.close() command = ['python', join(self.pycore.path, "module", "web", "manage.py"), "runfcgi", "daemonize=false", "method=threaded", "host=127.0.0.1", "port=9295"] - self.p = Popen(command, stderr=PIPE, stdin=PIPE, stdout=Output(stdout)) + self.p = Popen(command, stderr=Output(out), stdin=PIPE, stdout=Output(out)) command2 = ['nginx', '-c', join(path, "servers", "nginx.conf"),] - self.p2 = Popen(command2, stderr=PIPE, stdin=PIPE, stdout=Output(stdout)) + self.p2 = Popen(command2, stderr=PIPE, stdin=PIPE, stdout=Output(out)) elif self.server == "lighttpd": @@ -139,21 +140,21 @@ class WebServer(threading.Thread): new_config.close() command = ['python', join(self.pycore.path, "module", "web", "manage.py"), "runfcgi", "daemonize=false", "method=threaded", "host=127.0.0.1", "port=9295"] - self.p = Popen(command, stderr=PIPE, stdin=PIPE, stdout=Output(stdout)) + self.p = Popen(command, stderr=Output(out), stdin=PIPE, stdout=Output(out)) command2 = ['lighttpd', '-D', '-f', join(path, "servers", "lighttpd.conf")] - self.p2 = Popen(command2, stderr=PIPE, stdin=PIPE, stdout=Output(stdout)) + self.p2 = Popen(command2, stderr=PIPE, stdin=PIPE, stdout=Output(out)) elif self.server == "builtin": self.pycore.logger.info("Starting django builtin Webserver: %s:%s" % (host, port)) command = ['python', join(self.pycore.path, "module", "web", "run_server.py"), "%s:%s" % (host, port)] - self.p = Popen(command, stderr=Output(stdout), stdin=PIPE, stdout=Output(stdout)) + self.p = Popen(command, stderr=Output(out), stdin=Output(out), stdout=Output(out)) else: #run fastcgi on port command = ['python', join(self.pycore.path, "module", "web", "manage.py"), "runfcgi", "daemonize=false", "method=threaded", "host=127.0.0.1", "port=%s" % port] - self.p = Popen(command, stderr=PIPE, stdin=PIPE, stdout=Output(stdout)) + self.p = Popen(command, stderr=Output(out), stdin=PIPE, stdout=Output(out)) def quit(self): @@ -173,11 +174,15 @@ class WebServer(threading.Thread): self.running = False class Output: - def __init__(self, stream): + def __init__(self, stream): self.stream = stream - def write(self, data): # Do nothing + + def fileno(self): + return 1 + + def write(self, data): # Do nothing return None #self.stream.write(data) #self.stream.flush() - def __getattr__(self, attr): + def __getattr__(self, attr): return getattr(self.stream, attr)
\ No newline at end of file |