environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def init_hub(self):
        """construct"""
        client_iface = "%s://%s:" % (self.client_transport, self.client_ip) + "%i"
        engine_iface = "%s://%s:" % (self.engine_transport, self.engine_ip) + "%i"

        ctx = self.context
        loop = self.loop

        # Registrar socket
        q = ZMQStream(ctx.socket(zmq.ROUTER), loop)
        q.bind(client_iface % self.regport)
        self.log.info("Hub listening on %s for registration.", client_iface % self.regport)
        if self.client_ip != self.engine_ip:
            q.bind(engine_iface % self.regport)
            self.log.info("Hub listening on %s for registration.", engine_iface % self.regport)

        ### Engine connections ###

        # heartbeat
        hpub = ctx.socket(zmq.PUB)
        hpub.bind(engine_iface % self.hb[0])
        hrep = ctx.socket(zmq.ROUTER)
        hrep.bind(engine_iface % self.hb[1])
        self.heartmonitor = HeartMonitor(loop=loop, config=self.config, log=self.log,
                                pingstream=ZMQStream(hpub,loop),
                                pongstream=ZMQStream(hrep,loop)
                            )

        ### Client connections ###
        # Notifier socket
        n = ZMQStream(ctx.socket(zmq.PUB), loop)
        n.bind(client_iface%self.notifier_port)

        ### build and launch the queues ###

        # monitor socket
        sub = ctx.socket(zmq.SUB)
        sub.setsockopt(zmq.SUBSCRIBE, b"")
        sub.bind(self.monitor_url)
        sub.bind('inproc://monitor')
        sub = ZMQStream(sub, loop)

        # connect the db
        db_class = _db_shortcuts.get(self.db_class.lower(), self.db_class)
        self.log.info('Hub using DB backend: %r', (db_class.split('.')[-1]))
        self.db = import_item(str(db_class))(session=self.session.session,
                                            config=self.config, log=self.log)
        time.sleep(.25)
        try:
            scheme = self.config.TaskScheduler.scheme_name
        except AttributeError:
            from .scheduler import TaskScheduler
            scheme = TaskScheduler.scheme_name.get_default_value()
        # build connection dicts
        self.engine_info = {
            'control' : engine_iface%self.control[1],
            'mux': engine_iface%self.mux[1],
            'heartbeat': (engine_iface%self.hb[0], engine_iface%self.hb[1]),
            'task' : engine_iface%self.task[1],
            'iopub' : engine_iface%self.iopub[1],
            # 'monitor' : engine_iface%self.mon_port,
            }

        self.client_info = {
            'control' : client_iface%self.control[0],
            'mux': client_iface%self.mux[0],
            'task' : (scheme, client_iface%self.task[0]),
            'iopub' : client_iface%self.iopub[0],
            'notification': client_iface%self.notifier_port
            }
        self.log.debug("Hub engine addrs: %s", self.engine_info)
        self.log.debug("Hub client addrs: %s", self.client_info)

        # resubmit stream
        r = ZMQStream(ctx.socket(zmq.DEALER), loop)
        url = util.disambiguate_url(self.client_info['task'][-1])
        r.setsockopt(zmq.IDENTITY, self.session.bsession)
        r.connect(url)

        self.hub = Hub(loop=loop, session=self.session, monitor=sub, heartmonitor=self.heartmonitor,
                query=q, notifier=n, resubmit=r, db=self.db,
                engine_info=self.engine_info, client_info=self.client_info,
                log=self.log)
def init_hub(self):
        """construct"""
        client_iface = "%s://%s:" % (self.client_transport, self.client_ip) + "%i"
        engine_iface = "%s://%s:" % (self.engine_transport, self.engine_ip) + "%i"

        ctx = self.context
        loop = self.loop

        # Registrar socket
        q = ZMQStream(ctx.socket(zmq.ROUTER), loop)
        q.bind(client_iface % self.regport)
        self.log.info("Hub listening on %s for registration.", client_iface % self.regport)
        if self.client_ip != self.engine_ip:
            q.bind(engine_iface % self.regport)
            self.log.info("Hub listening on %s for registration.", engine_iface % self.regport)

        ### Engine connections ###

        # heartbeat
        hpub = ctx.socket(zmq.PUB)
        hpub.bind(engine_iface % self.hb[0])
        hrep = ctx.socket(zmq.ROUTER)
        hrep.bind(engine_iface % self.hb[1])
        self.heartmonitor = HeartMonitor(loop=loop, config=self.config, log=self.log,
                                pingstream=ZMQStream(hpub,loop),
                                pongstream=ZMQStream(hrep,loop)
                            )

        ### Client connections ###
        # Notifier socket
        n = ZMQStream(ctx.socket(zmq.PUB), loop)
        n.bind(client_iface%self.notifier_port)

        ### build and launch the queues ###

        # monitor socket
        sub = ctx.socket(zmq.SUB)
        sub.setsockopt(zmq.SUBSCRIBE, b"")
        sub.bind(self.monitor_url)
        sub.bind('inproc://monitor')
        sub = ZMQStream(sub, loop)

        # connect the db
        db_class = _db_shortcuts.get(self.db_class.lower(), self.db_class)
        self.log.info('Hub using DB backend: %r', (db_class.split('.')[-1]))
        self.db = import_item(str(db_class))(session=self.session.session,
                                            config=self.config, log=self.log)
        time.sleep(.25)
        try:
            scheme = self.config.TaskScheduler.scheme_name
        except AttributeError:
            from .scheduler import TaskScheduler
            scheme = TaskScheduler.scheme_name.get_default_value()
        # build connection dicts
        self.engine_info = {
            'control' : engine_iface%self.control[1],
            'mux': engine_iface%self.mux[1],
            'heartbeat': (engine_iface%self.hb[0], engine_iface%self.hb[1]),
            'task' : engine_iface%self.task[1],
            'iopub' : engine_iface%self.iopub[1],
            # 'monitor' : engine_iface%self.mon_port,
            }

        self.client_info = {
            'control' : client_iface%self.control[0],
            'mux': client_iface%self.mux[0],
            'task' : (scheme, client_iface%self.task[0]),
            'iopub' : client_iface%self.iopub[0],
            'notification': client_iface%self.notifier_port
            }
        self.log.debug("Hub engine addrs: %s", self.engine_info)
        self.log.debug("Hub client addrs: %s", self.client_info)

        # resubmit stream
        r = ZMQStream(ctx.socket(zmq.DEALER), loop)
        url = util.disambiguate_url(self.client_info['task'][-1])
        r.setsockopt(zmq.IDENTITY, self.session.bsession)
        r.connect(url)

        self.hub = Hub(loop=loop, session=self.session, monitor=sub, heartmonitor=self.heartmonitor,
                query=q, notifier=n, resubmit=r, db=self.db,
                engine_info=self.engine_info, client_info=self.client_info,
                log=self.log)
def init_hub ( self ) : client_iface = "%s://%s:" % ( self . client_transport , self . client_ip ) + "%i" engine_iface = "%s://%s:" % ( self . engine_transport , self . engine_ip ) + "%i" ctx = self . context loop = self . loop # Registrar socket q = ZMQStream ( ctx . socket ( zmq . ROUTER ) , loop ) q . bind ( client_iface % self . regport ) self . log . info ( "Hub listening on %s for registration." , client_iface % self . regport ) if self . client_ip != self . engine_ip : q . bind ( engine_iface % self . regport ) self . log . info ( "Hub listening on %s for registration." , engine_iface % self . regport ) ### Engine connections ### # heartbeat hpub = ctx . socket ( zmq . PUB ) hpub . bind ( engine_iface % self . hb [ 0 ] ) hrep = ctx . socket ( zmq . ROUTER ) hrep . bind ( engine_iface % self . hb [ 1 ] ) self . heartmonitor = HeartMonitor ( loop = loop , config = self . config , log = self . log , pingstream = ZMQStream ( hpub , loop ) , pongstream = ZMQStream ( hrep , loop ) ) ### Client connections ### # Notifier socket n = ZMQStream ( ctx . socket ( zmq . PUB ) , loop ) n . bind ( client_iface % self . notifier_port ) ### build and launch the queues ### # monitor socket sub = ctx . socket ( zmq . SUB ) sub . setsockopt ( zmq . SUBSCRIBE , b"" ) sub . bind ( self . monitor_url ) sub . bind ( 'inproc://monitor' ) sub = ZMQStream ( sub , loop ) # connect the db db_class = _db_shortcuts . get ( self . db_class . lower ( ) , self . db_class ) self . log . info ( 'Hub using DB backend: %r' , ( db_class . split ( '.' ) [ - 1 ] ) ) self . db = import_item ( str ( db_class ) ) ( session = self . session . session , config = self . config , log = self . log ) time . sleep ( .25 ) try : scheme = self . config . TaskScheduler . scheme_name except AttributeError : from . scheduler import TaskScheduler scheme = TaskScheduler . scheme_name . get_default_value ( ) # build connection dicts self . engine_info = { 'control' : engine_iface % self . control [ 1 ] , 'mux' : engine_iface % self . mux [ 1 ] , 'heartbeat' : ( engine_iface % self . hb [ 0 ] , engine_iface % self . hb [ 1 ] ) , 'task' : engine_iface % self . task [ 1 ] , 'iopub' : engine_iface % self . iopub [ 1 ] , # 'monitor' : engine_iface%self.mon_port, } self . client_info = { 'control' : client_iface % self . control [ 0 ] , 'mux' : client_iface % self . mux [ 0 ] , 'task' : ( scheme , client_iface % self . task [ 0 ] ) , 'iopub' : client_iface % self . iopub [ 0 ] , 'notification' : client_iface % self . notifier_port } self . log . debug ( "Hub engine addrs: %s" , self . engine_info ) self . log . debug ( "Hub client addrs: %s" , self . client_info ) # resubmit stream r = ZMQStream ( ctx . socket ( zmq . DEALER ) , loop ) url = util . disambiguate_url ( self . client_info [ 'task' ] [ - 1 ] ) r . setsockopt ( zmq . IDENTITY , self . session . bsession ) r . connect ( url ) self . hub = Hub ( loop = loop , session = self . session , monitor = sub , heartmonitor = self . heartmonitor , query = q , notifier = n , resubmit = r , db = self . db , engine_info = self . engine_info , client_info = self . client_info , log = self . log )
construct
construct