FilesExpand file tree

 master

/

factory.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

79 lines (63 loc) · 2.94 KB

 master

/

factory.py

Copy path

Top

File metadata and controls

• Code
• Blame

79 lines (63 loc) · 2.94 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

"""Base config factories.

Authors:

* Min RK

"""

#-----------------------------------------------------------------------------

# Copyright (C) 2010-2011 The IPython Development Team

#

# Distributed under the terms of the BSD License. The full license is in

# the file COPYING, distributed as part of this software.

#-----------------------------------------------------------------------------

#-----------------------------------------------------------------------------

# Imports

#-----------------------------------------------------------------------------

import logging

import os

import zmq

from zmq.eventloop.ioloop import IOLoop

from IPython.config.configurable import Configurable

from IPython.utils.localinterfaces import LOCALHOST

from IPython.utils.traitlets import Integer, Instance, Unicode

from IPython.parallel.util import select_random_ports

from IPython.kernel.zmq.session import Session, SessionFactory

#-----------------------------------------------------------------------------

# Classes

#-----------------------------------------------------------------------------

class RegistrationFactory(SessionFactory):

"""The Base Configurable for objects that involve registration."""

url = Unicode('', config=True,

help="""The 0MQ url used for registration. This sets transport, ip, and port

in one variable. For example: url='tcp://%s:12345' or

url='epgm://*:90210'"""

% LOCALHOST) # url takes precedence over ip,regport,transport

transport = Unicode('tcp', config=True,

help="""The 0MQ transport for communications. This will likely be

the default of 'tcp', but other values include 'ipc', 'epgm', 'inproc'.""")

ip = Unicode(LOCALHOST, config=True,

help="""The IP address for registration. This is generally either

'127.0.0.1' for loopback only or '*' for all interfaces.

[default: '%s']""" % LOCALHOST)

regport = Integer(config=True,

help="""The port on which the Hub listens for registration.""")

def _regport_default(self):

return select_random_ports(1)[0]

def __init__(self, **kwargs):

super(RegistrationFactory, self).__init__(**kwargs)

self._propagate_url()

self._rebuild_url()

self.on_trait_change(self._propagate_url, 'url')

self.on_trait_change(self._rebuild_url, 'ip')

self.on_trait_change(self._rebuild_url, 'transport')

self.on_trait_change(self._rebuild_url, 'regport')

def _rebuild_url(self):

self.url = "%s://%s:%i"%(self.transport, self.ip, self.regport)

def _propagate_url(self):

"""Ensure self.url contains full transport://interface:port"""

if self.url:

iface = self.url.split('://',1)

if len(iface) == 2:

self.transport,iface = iface

iface = iface.split(':')

self.ip = iface[0]

if iface[1]:

self.regport = int(iface[1])