call site 0 for _thread.NamedThreadPool.__init__
test/rsession/testing/test_hostmanage.py - line 209
201
202
203
204
205
206
207
208
209
210
211
212
213
   def test_hostmanager_init_rsync_topdir_explicit(self):
       dir2 = self.source.ensure("dir1", "dir2", dir=1)
       dir2.ensure("hello")
       hm = self.gethostmanager(
           dist_hosts = ["localhost:%s" % self.dest],
           dist_rsync_roots = [str(self.source)]
       )
       assert hm.config.topdir == self.source
->     hm.init_rsync([].append)
       dest = self.dest.join(self.source.basename)
       assert dest.join("dir1").check()
       assert dest.join("dir1", "dir2").check()
       assert dest.join("dir1", "dir2", 'hello').check()
test/rsession/hostmanage.py - line 143
141
142
143
144
145
146
147
148
149
150
151
152
153
154
   def init_rsync(self, reporter):
       ignores = self.config.getvalue_pathlist("dist_rsync_ignore")
->     self.prepare_gateways(reporter)
       # send each rsync root
       for root in self.roots:
           rsync = HostRSync(root, ignores=ignores, 
                             verbose=self.config.option.verbose)
           if self._addrel: 
               destrelpath = ""
           else:
               destrelpath = root.basename
           for host in self.hosts:
               rsync.add_target_host(host, destrelpath, reporter)
           rsync.send(raises=False)
test/rsession/hostmanage.py - line 137
134
135
136
137
138
139
   def prepare_gateways(self, reporter):
       python = self.config.getvalue("dist_remotepython")
       for host in self.hosts:
->         host.initgateway(python=python)
           reporter(repevent.HostGatewayReady(host, self.roots))
           host.gw.host = host
test/rsession/hostmanage.py - line 41
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
   def initgateway(self, python="python"):
       if self.hostname == "localhost":
->         self.gw = py.execnet.PopenGateway(python=python)
       else:
           self.gw = py.execnet.SshGateway(self.hostname, 
                                           remotepython=python)
       if self.inplacelocal:
           self.gw.remote_exec(py.code.Source(
               sethomedir, "sethomedir()"
           )).waitclose()
           self.gw_remotepath = None
       else:
           assert self.relpath
           channel = self.gw.remote_exec(py.code.Source(
               gethomedir,
               sethomedir, "sethomedir()", 
               getpath_relto_home, """
                   channel.send(getpath_relto_home(%r))
               """ % self.relpath,
           ))
           self.gw_remotepath = channel.receive()
execnet/register.py - line 65
60
61
62
63
64
65
   def __init__(self, python=sys.executable):
       """ instantiate a gateway to a subprocess 
               started with the given 'python' executable. 
           """
       cmd = '%s -u -c "exec input()"' % python
->     super(PopenGateway, self).__init__(cmd)
execnet/register.py - line 54
51
52
53
54
   def __init__(self, cmd):
       infile, outfile = os.popen2(cmd)
       io = inputoutput.Popen2IO(infile, outfile)
->     super(PopenCmdGateway, self).__init__(io=io)
execnet/register.py - line 31
29
30
31
   def __init__(self, io):
       self._remote_bootstrap_gateway(io)
->     super(InstallableGateway, self).__init__(io=io, _startcount=1) 
execnet/gateway.py - line 51
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
   def __init__(self, io, execthreads=None, _startcount=2): 
       """ initialize core gateway, using the given 
               inputoutput object and 'execthreads' execution
               threads. 
           """
       global registered_cleanup
       self._execpool = WorkerPool(maxthreads=execthreads)
       self._io = io
       self._outgoing = Queue.Queue()
       self._channelfactory = ChannelFactory(self, _startcount)
       if not registered_cleanup:
           atexit.register(cleanup_atexit)
           registered_cleanup = True
       _active_sendqueues[self._outgoing] = True
       self._pool = NamedThreadPool(receiver = self._thread_receiver, 
->                                  sender = self._thread_sender)