(self, hashes)
| 525 | # Send a getdata message to our peer to request the object with the given |
| 526 | # hash |
| 527 | def sendgetdata(self, hashes): |
| 528 | if len(hashes) == 0: |
| 529 | return |
| 530 | logger.debug('sending getdata to retrieve %i objects', len(hashes)) |
| 531 | payload = encodeVarint(len(hashes)) + ''.join(hashes) |
| 532 | self.sendDataThreadQueue.put((0, 'sendRawData', protocol.CreatePacket('getdata', payload)), False) |
| 533 | |
| 534 | |
| 535 | # We have received a getdata request from our peer |
no test coverage detected