]> git.proxmox.com Git - ceph.git/blobdiff - ceph/src/jaegertracing/thrift/tutorial/py.twisted/PythonServer.py
import quincy beta 17.1.0
[ceph.git] / ceph / src / jaegertracing / thrift / tutorial / py.twisted / PythonServer.py
diff --git a/ceph/src/jaegertracing/thrift/tutorial/py.twisted/PythonServer.py b/ceph/src/jaegertracing/thrift/tutorial/py.twisted/PythonServer.py
deleted file mode 100755 (executable)
index 034e4a3..0000000
+++ /dev/null
@@ -1,97 +0,0 @@
-#!/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.
-#
-
-import glob
-import sys
-sys.path.append('gen-py.twisted')
-sys.path.insert(0, glob.glob('../../lib/py/build/lib*')[0])
-
-from tutorial import Calculator
-from tutorial.ttypes import InvalidOperation, Operation
-
-from shared.ttypes import SharedStruct
-
-from zope.interface import implements
-from twisted.internet import reactor
-
-from thrift.transport import TTwisted
-from thrift.protocol import TBinaryProtocol
-
-
-class CalculatorHandler:
-    implements(Calculator.Iface)
-
-    def __init__(self):
-        self.log = {}
-
-    def ping(self):
-        print('ping()')
-
-    def add(self, n1, n2):
-        print('add(%d,%d)' % (n1, n2))
-        return n1 + n2
-
-    def calculate(self, logid, work):
-        print('calculate(%d, %r)' % (logid, work))
-
-        if work.op == Operation.ADD:
-            val = work.num1 + work.num2
-        elif work.op == Operation.SUBTRACT:
-            val = work.num1 - work.num2
-        elif work.op == Operation.MULTIPLY:
-            val = work.num1 * work.num2
-        elif work.op == Operation.DIVIDE:
-            if work.num2 == 0:
-                x = InvalidOperation()
-                x.whatOp = work.op
-                x.why = 'Cannot divide by 0'
-                raise x
-            val = work.num1 / work.num2
-        else:
-            x = InvalidOperation()
-            x.whatOp = work.op
-            x.why = 'Invalid operation'
-            raise x
-
-        log = SharedStruct()
-        log.key = logid
-        log.value = '%d' % (val)
-        self.log[logid] = log
-
-        return val
-
-    def getStruct(self, key):
-        print('getStruct(%d)' % (key))
-        return self.log[key]
-
-    def zip(self):
-        print('zip()')
-
-
-if __name__ == '__main__':
-    handler = CalculatorHandler()
-    processor = Calculator.Processor(handler)
-    pfactory = TBinaryProtocol.TBinaryProtocolFactory()
-    server = reactor.listenTCP(
-        9090,
-        TTwisted.ThriftServerFactory(processor, pfactory),
-        interface="127.0.0.1")
-    reactor.run()