call site 0 for test.config.get_collector_trail
test/rsession/testing/test_rsession.py - line 161
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
   def test_setup_teardown_run_ssh(self):
       hosts = [HostInfo('localhost:%s' % self.dest)]
       allevents = []
           
       hm = HostManager(self.config, hosts=hosts)
       nodes = hm.setup_hosts(allevents.append)
           
       from py.__.test.rsession.testing.test_executor \
           import ItemTestPassing, ItemTestFailing, ItemTestSkipping
           
       itempass = self.getexample("pass")
       itemfail = self.getexample("fail")
       itemskip = self.getexample("skip")
       itemprint = self.getexample("print")
   
       # actually run some tests
       for node in nodes:
           node.send(itempass)
->         node.send(itemfail)
           node.send(itemskip)
           node.send(itemprint)
   
       hm.teardown_hosts(allevents.append, [node.channel for node in nodes], nodes)
   
       events = [i for i in allevents 
                       if isinstance(i, repevent.ReceivedItemOutcome)]
       passed = [i for i in events 
                       if i.outcome.passed]
       skipped = [i for i in events 
                       if i.outcome.skipped]
       assert len(passed) == 2 * len(nodes)
       assert len(skipped) == len(nodes)
       assert len(events) == 4 * len(nodes)
       # one of passed for each node has non-empty stdout
       passed_stdout = [i for i in passed if i.outcome.stdout.find('samfing') != -1]
       assert len(passed_stdout) == len(nodes), passed
test/rsession/master.py - line 32
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
   def send(self, item):
       try:
           if item is StopIteration:
               self.channel.send(42)
           else:
               self.pending.insert(0, item)
           #itemspec = item.listnames()[1:]
->             self.channel.send(item._get_collector_trail())
               # send start report
               self.reporter(repevent.SendItem(self.channel, item))
       except IOError:
           print "Sending error, channel IOError"
           print self.channel._getremoteerror()
           # XXX: this should go as soon as we'll have proper detection
           #      of hanging nodes and such
           raise
test/collect.py - line 239
236
237
238
239
   def _get_collector_trail(self):
       """ Shortcut
           """
->     return self._config.get_collector_trail(self)