call site 0 for execnet.Channel.setcallback
execnet/testing/test_rsync.py - line 127
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
   def test_callback(self):
       dest = self.dest1
       source = self.source
       source.ensure("existant").write("a" * 100)
       source.ensure("existant2").write("a" * 10)
       total = {}
       def callback(cmd, lgt, channel):
           total[(cmd, lgt)] = True
   
       rsync = RSync(source, callback=callback)
       #rsync = RSync()
->     rsync.add_target(gw, dest)
       rsync.send()
   
       assert total == {("list", 110):True, ("ack", 100):True, ("ack", 10):True}
execnet/rsync.py - line 142
131
132
133
134
135
136
137
138
139
140
141
142
143
144
   def add_target(self, gateway, destdir, 
                  finishedcallback=None, **options):
       """ Adds a remote target specified via a 'gateway'
               and a remote destination directory. 
           """
       assert finishedcallback is None or callable(finishedcallback)
       for name in options:
           assert name in ('delete',)
       def itemcallback(req):
           self._receivequeue.put((channel, req))
       channel = gateway.remote_exec(REMOTE_SOURCE)
->     channel.setcallback(itemcallback, endmarker = None)
       channel.send((str(destdir), options))
       self._channels[channel] = finishedcallback