|
| 1 | +License and copyright for files modified by this patch: |
| 2 | + |
| 3 | +SPDX-License-Identifier: MIT |
| 4 | +Copyright (c) 2015 François-Xavier Bourlet ( [email protected]) |
| 5 | + |
| 6 | +Index: zerorpc-0.6.3/zerorpc/context.py |
| 7 | +=================================================================== |
| 8 | +--- zerorpc-0.6.3.orig/zerorpc/context.py |
| 9 | ++++ zerorpc-0.6.3/zerorpc/context.py |
| 10 | +@@ -23,9 +23,6 @@ |
| 11 | + # SOFTWARE. |
| 12 | + |
| 13 | + |
| 14 | +-from __future__ import absolute_import |
| 15 | +-from future.utils import tobytes |
| 16 | +- |
| 17 | + import uuid |
| 18 | + import random |
| 19 | + |
| 20 | +@@ -103,7 +100,7 @@ class Context(zmq.Context): |
| 21 | + return Context._instance |
| 22 | + |
| 23 | + def _reset_msgid(self): |
| 24 | +- self._msg_id_base = tobytes(uuid.uuid4().hex)[8:] |
| 25 | ++ self._msg_id_base = uuid.uuid4().hex[8:].encode('ascii') |
| 26 | + self._msg_id_counter = random.randrange(0, 2 ** 32) |
| 27 | + self._msg_id_counter_stop = random.randrange(self._msg_id_counter, 2 ** 32) |
| 28 | + |
| 29 | +@@ -112,7 +109,7 @@ class Context(zmq.Context): |
| 30 | + self._reset_msgid() |
| 31 | + else: |
| 32 | + self._msg_id_counter = (self._msg_id_counter + 1) |
| 33 | +- return tobytes('{0:08x}'.format(self._msg_id_counter)) + self._msg_id_base |
| 34 | ++ return f'{self._msg_id_counter:08x}'.encode('ascii') + self._msg_id_base |
| 35 | + |
| 36 | + def register_middleware(self, middleware_instance): |
| 37 | + registered_count = 0 |
| 38 | +Index: zerorpc-0.6.3/zerorpc/core.py |
| 39 | +=================================================================== |
| 40 | +--- zerorpc-0.6.3.orig/zerorpc/core.py |
| 41 | ++++ zerorpc-0.6.3/zerorpc/core.py |
| 42 | +@@ -23,10 +23,8 @@ |
| 43 | + # SOFTWARE. |
| 44 | + |
| 45 | + |
| 46 | +-from __future__ import absolute_import |
| 47 | + from builtins import str |
| 48 | + from builtins import zip |
| 49 | +-from future.utils import iteritems |
| 50 | + |
| 51 | + import sys |
| 52 | + import traceback |
| 53 | +@@ -67,7 +65,7 @@ class ServerBase(object): |
| 54 | + self._inject_builtins() |
| 55 | + self._heartbeat_freq = heartbeat |
| 56 | + |
| 57 | +- for (k, functor) in iteritems(self._methods): |
| 58 | ++ for (k, functor) in self._methods.items(): |
| 59 | + if not isinstance(functor, DecoratorBase): |
| 60 | + self._methods[k] = rep(functor) |
| 61 | + |
| 62 | +@@ -102,11 +100,11 @@ class ServerBase(object): |
| 63 | + return r |
| 64 | + |
| 65 | + def _zerorpc_inspect(self): |
| 66 | +- methods = dict((m, f) for m, f in iteritems(self._methods) |
| 67 | ++ methods = dict((m, f) for m, f in self._methods.items() |
| 68 | + if not m.startswith('_')) |
| 69 | + detailled_methods = dict((m, |
| 70 | + dict(args=self._format_args_spec(f._zerorpc_args()), |
| 71 | +- doc=f._zerorpc_doc())) for (m, f) in iteritems(methods)) |
| 72 | ++ doc=f._zerorpc_doc())) for (m, f) in methods.items()) |
| 73 | + return {'name': self._name, |
| 74 | + 'methods': detailled_methods} |
| 75 | + |
0 commit comments