(self, locator)
| 140 | self.send_message(headers_message) |
| 141 | |
| 142 | def send_getblocks(self, locator): |
| 143 | getblocks_message = msg_getblocks() |
| 144 | getblocks_message.locator.vHave = locator |
| 145 | self.send_message(getblocks_message) |
| 146 | |
| 147 | def wait_for_block_announcement(self, block_hash, timeout=60): |
| 148 | test_function = lambda: self.last_blockhash_announced == block_hash |