| #!/usr/bin/env python |
| |
| # |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| # |
| from __future__ import division |
| import sys, glob, time |
| sys.path.insert(0, glob.glob('../../lib/py/build/lib.*')[0]) |
| from optparse import OptionParser |
| |
| parser = OptionParser() |
| parser.add_option('--genpydir', type='string', dest='genpydir', |
| default='gen-py', |
| help='include this local directory in sys.path for locating generated code') |
| parser.add_option("--port", type="int", dest="port", |
| help="port number for server to listen on") |
| parser.add_option("--zlib", action="store_true", dest="zlib", |
| help="use zlib wrapper for compressed transport") |
| parser.add_option("--ssl", action="store_true", dest="ssl", |
| help="use SSL for encrypted transport") |
| parser.add_option('-v', '--verbose', action="store_const", |
| dest="verbose", const=2, |
| help="verbose output") |
| parser.add_option('-q', '--quiet', action="store_const", |
| dest="verbose", const=0, |
| help="minimal output") |
| parser.add_option('--proto', dest="proto", type="string", |
| help="protocol to use, one of: accel, binary, compact") |
| parser.set_defaults(port=9090, verbose=1, proto='binary') |
| options, args = parser.parse_args() |
| |
| sys.path.insert(0, options.genpydir) |
| |
| from ThriftTest import ThriftTest |
| from ThriftTest.ttypes import * |
| from thrift.transport import TTransport |
| from thrift.transport import TSocket |
| from thrift.transport import TZlibTransport |
| from thrift.protocol import TBinaryProtocol |
| from thrift.protocol import TCompactProtocol |
| from thrift.server import TServer, TNonblockingServer, THttpServer |
| |
| PROT_FACTORIES = {'binary': TBinaryProtocol.TBinaryProtocolFactory, |
| 'accel': TBinaryProtocol.TBinaryProtocolAcceleratedFactory, |
| 'compact': TCompactProtocol.TCompactProtocolFactory} |
| |
| class TestHandler: |
| |
| def testVoid(self): |
| if options.verbose > 1: |
| print 'testVoid()' |
| |
| def testString(self, str): |
| if options.verbose > 1: |
| print 'testString(%s)' % str |
| return str |
| |
| def testByte(self, byte): |
| if options.verbose > 1: |
| print 'testByte(%d)' % byte |
| return byte |
| |
| def testI16(self, i16): |
| if options.verbose > 1: |
| print 'testI16(%d)' % i16 |
| return i16 |
| |
| def testI32(self, i32): |
| if options.verbose > 1: |
| print 'testI32(%d)' % i32 |
| return i32 |
| |
| def testI64(self, i64): |
| if options.verbose > 1: |
| print 'testI64(%d)' % i64 |
| return i64 |
| |
| def testDouble(self, dub): |
| if options.verbose > 1: |
| print 'testDouble(%f)' % dub |
| return dub |
| |
| def testStruct(self, thing): |
| if options.verbose > 1: |
| print 'testStruct({%s, %d, %d, %d})' % (thing.string_thing, thing.byte_thing, thing.i32_thing, thing.i64_thing) |
| return thing |
| |
| def testException(self, str): |
| if options.verbose > 1: |
| print 'testException(%s)' % str |
| if str == 'Xception': |
| x = Xception() |
| x.errorCode = 1001 |
| x.message = str |
| raise x |
| elif str == "throw_undeclared": |
| raise ValueError("Exception test PASSES.") |
| |
| def testOneway(self, seconds): |
| if options.verbose > 1: |
| print 'testOneway(%d) => sleeping...' % seconds |
| time.sleep(seconds / 3) # be quick |
| if options.verbose > 1: |
| print 'done sleeping' |
| |
| def testNest(self, thing): |
| if options.verbose > 1: |
| print 'testNest(%s)' % thing |
| return thing |
| |
| def testMap(self, thing): |
| if options.verbose > 1: |
| print 'testMap(%s)' % thing |
| return thing |
| |
| def testSet(self, thing): |
| if options.verbose > 1: |
| print 'testSet(%s)' % thing |
| return thing |
| |
| def testList(self, thing): |
| if options.verbose > 1: |
| print 'testList(%s)' % thing |
| return thing |
| |
| def testEnum(self, thing): |
| if options.verbose > 1: |
| print 'testEnum(%s)' % thing |
| return thing |
| |
| def testTypedef(self, thing): |
| if options.verbose > 1: |
| print 'testTypedef(%s)' % thing |
| return thing |
| |
| def testMapMap(self, thing): |
| if options.verbose > 1: |
| print 'testMapMap(%s)' % thing |
| return thing |
| |
| def testMulti(self, arg0, arg1, arg2, arg3, arg4, arg5): |
| if options.verbose > 1: |
| print 'testMulti(%s)' % [arg0, arg1, arg2, arg3, arg4, arg5] |
| x = Xtruct(byte_thing=arg0, i32_thing=arg1, i64_thing=arg2) |
| return x |
| |
| # set up the protocol factory form the --proto option |
| pfactory_cls = PROT_FACTORIES.get(options.proto, None) |
| if pfactory_cls is None: |
| raise AssertionError('Unknown --proto option: %s' % options.proto) |
| pfactory = pfactory_cls() |
| |
| # get the server type (TSimpleServer, TNonblockingServer, etc...) |
| if len(args) > 1: |
| raise AssertionError('Only one server type may be specified, not multiple types.') |
| server_type = args[0] |
| |
| # Set up the handler and processor objects |
| handler = TestHandler() |
| processor = ThriftTest.Processor(handler) |
| |
| # Handle THttpServer as a special case |
| if server_type == 'THttpServer': |
| server =THttpServer.THttpServer(processor, ('', options.port), pfactory) |
| server.serve() |
| sys.exit(0) |
| |
| # set up server transport and transport factory |
| host = None |
| if options.ssl: |
| from thrift.transport import TSSLSocket |
| transport = TSSLSocket.TSSLServerSocket(host, options.port, certfile='test_cert.pem') |
| else: |
| transport = TSocket.TServerSocket(host, options.port) |
| tfactory = TTransport.TBufferedTransportFactory() |
| |
| # if --zlib, then wrap server transport, and use a different transport factory |
| if options.zlib: |
| transport = TZlibTransport.TZlibTransport(transport) # wrap with zlib |
| tfactory = TZlibTransport.TZlibTransportFactory() |
| |
| # do server-specific setup here: |
| if server_type == "TNonblockingServer": |
| server = TNonblockingServer.TNonblockingServer(processor, transport, inputProtocolFactory=pfactory) |
| elif server_type == "TProcessPoolServer": |
| import signal |
| from thrift.server import TProcessPoolServer |
| server = TProcessPoolServer.TProcessPoolServer(processor, transport, tfactory, pfactory) |
| server.setNumWorkers(5) |
| def set_alarm(): |
| def clean_shutdown(signum, frame): |
| for worker in server.workers: |
| if options.verbose > 0: |
| print 'Terminating worker: %s' % worker |
| worker.terminate() |
| if options.verbose > 0: |
| print 'Requesting server to stop()' |
| try: |
| server.stop() |
| except: |
| pass |
| signal.signal(signal.SIGALRM, clean_shutdown) |
| signal.alarm(2) |
| set_alarm() |
| else: |
| # look up server class dynamically to instantiate server |
| ServerClass = getattr(TServer, server_type) |
| server = ServerClass(processor, transport, tfactory, pfactory) |
| # enter server main loop |
| server.serve() |