diff options
Diffstat (limited to 'module/remote/ThriftBackend.py')
-rw-r--r-- | module/remote/ThriftBackend.py | 36 |
1 files changed, 11 insertions, 25 deletions
diff --git a/module/remote/ThriftBackend.py b/module/remote/ThriftBackend.py index b4a2bb25e..16917cfc9 100644 --- a/module/remote/ThriftBackend.py +++ b/module/remote/ThriftBackend.py @@ -1,29 +1,15 @@ # -*- coding: utf-8 -*- -""" - This program is free software; you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation; either version 3 of the License, - or (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. - See the GNU General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program; if not, see <http://www.gnu.org/licenses/>. - - @author: mkaay, RaNaN -""" +# @author: RaNaN, mkaay + from os.path import exists -from module.remote.RemoteManager import BackendBase +from pyload.manager.Remote import BackendBase -from thriftbackend.Processor import Processor -from thriftbackend.Protocol import ProtocolFactory -from thriftbackend.Socket import ServerSocket -from thriftbackend.Transport import TransportFactory -#from thriftbackend.Transport import TransportFactoryCompressed +from pyload.remote.thriftbackend.Processor import Processor +from pyload.remote.thriftbackend.Protocol import ProtocolFactory +from pyload.remote.thriftbackend.Socket import ServerSocket +from pyload.remote.thriftbackend.Transport import TransportFactory +#from pyload.remote.thriftbackend.Transport import TransportFactoryCompressed from thrift.server import TServer @@ -46,11 +32,11 @@ class ThriftBackend(BackendBase): # tfactory = TransportFactoryCompressed() tfactory = TransportFactory() pfactory = ProtocolFactory() - + self.server = TServer.TThreadedServer(processor, transport, tfactory, pfactory) #self.server = TNonblockingServer.TNonblockingServer(processor, transport, tfactory, pfactory) - + #server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory) - + def serve(self): self.server.serve() |