(self, host, port)
| 29 | |
| 30 | class ThriftBackend(BackendBase): |
| 31 | def setup(self, host, port): |
| 32 | processor = Processor(self.core.api) |
| 33 | |
| 34 | key = None |
| 35 | cert = None |
| 36 | |
| 37 | if self.core.config['ssl']['activated']: |
| 38 | if exists(self.core.config['ssl']['cert']) and exists(self.core.config['ssl']['key']): |
| 39 | self.core.log.info(_("Using SSL ThriftBackend")) |
| 40 | key = self.core.config['ssl']['key'] |
| 41 | cert = self.core.config['ssl']['cert'] |
| 42 | |
| 43 | transport = ServerSocket(port, host, key, cert) |
| 44 | |
| 45 | |
| 46 | # tfactory = TransportFactoryCompressed() |
| 47 | tfactory = TransportFactory() |
| 48 | pfactory = ProtocolFactory() |
| 49 | |
| 50 | self.server = TServer.TThreadedServer(processor, transport, tfactory, pfactory) |
| 51 | #self.server = TNonblockingServer.TNonblockingServer(processor, transport, tfactory, pfactory) |
| 52 | |
| 53 | #server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory) |
| 54 | |
| 55 | def serve(self): |
| 56 | self.server.serve() |
nothing calls this directly
no test coverage detected