| #!/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() |