mrtoth/baseimage-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/baseimage-tutorial-framework synced 2024-10-05 08:23:36 +00:00
Code Issues Releases Wiki Activity

Move ZMQConnectorBase to networking

Browse Source
This commit is contained in:
Bálint Bokros 2018-02-13 17:44:48 +01:00
parent dbc2d1c0ea
commit f5a8230d3b
6 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/tfw/networking/controller_connector.py
View File

@ -3,7 +3,7 @@ from zmq.eventloop import ioloop
from zmq.eventloop.zmqstream import ZMQStream from zmq.eventloop.zmqstream import ZMQStream
from tfw.config import tfwenv from tfw.config import tfwenv
from tfw.util import ZMQConnectorBase from tfw.networking.zmq_connector_base import ZMQConnectorBase
ioloop.install() ioloop.install()

2
lib/tfw/networking/event_handlers/server_connector.py
View File

@ -4,7 +4,7 @@ from zmq.eventloop.zmqstream import ZMQStream
from tfw.networking.serialization import serialize_all from tfw.networking.serialization import serialize_all
from tfw.config import tfwenv from tfw.config import tfwenv
from tfw.util import ZMQConnectorBase from tfw.networking.zmq_connector_base import ZMQConnectorBase
class ServerDownlinkConnector(ZMQConnectorBase): class ServerDownlinkConnector(ZMQConnectorBase):

2
lib/tfw/networking/server/event_handler_connector.py
View File

@ -5,7 +5,7 @@ from tfw.networking.serialization import serialize_all
from tfw.config import tfwenv from tfw.config import tfwenv
from tfw.config.logs import logging from tfw.config.logs import logging
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
from tfw.util import ZMQConnectorBase from tfw.networking.zmq_connector_base import ZMQConnectorBase
class EventHandlerDownlinkConnector(ZMQConnectorBase): class EventHandlerDownlinkConnector(ZMQConnectorBase):

2
lib/tfw/networking/solvable_connector.py
View File

@ -2,7 +2,7 @@ import zmq
from zmq.eventloop import ioloop from zmq.eventloop import ioloop
from tfw.config import tfwenv from tfw.config import tfwenv
from tfw.util import ZMQConnectorBase from tfw.networking.zmq_connector_base import ZMQConnectorBase
from tfw.networking.serialization import serialize_all, deserialize_all from tfw.networking.serialization import serialize_all, deserialize_all
ioloop.install() ioloop.install()

6
lib/tfw/networking/zmq_connector_base.py Normal file
View File

@ -0,0 +1,6 @@
import zmq
class ZMQConnectorBase:
def __init__(self, zmq_context=None):
self._zmq_context = zmq_context or zmq.Context.instance()

7
lib/tfw/util.py
View File

@ -1,4 +1,4 @@
import xmlrpc.client, zmq import xmlrpc.client
from contextlib import suppress from contextlib import suppress
from xmlrpc.client import Fault as SupervisorFault from xmlrpc.client import Fault as SupervisorFault
from time import time, sleep from time import time, sleep
@ -30,11 +30,6 @@ class SupervisorMixin:
self.start_process() self.start_process()
class ZMQConnectorBase:
def __init__(self, zmq_context=None):
self._zmq_context = zmq_context or zmq.Context.instance()
class RateLimiter: class RateLimiter:
def __init__(self, rate_per_second): def __init__(self, rate_per_second):
self.min_interval = 1 / float(rate_per_second) self.min_interval = 1 / float(rate_per_second)