def request_headers_and_sync(self, locator, hashstop=0):
    self.clear_block_announcement()
    self.get_headers(locator, hashstop)
    wait_until(self.received_block_announcement, timeout=30, lock=mininode_lock)
    self.clear_block_announcement()
def request_headers_and_sync(self, locator, hashstop=0):
    self.clear_block_announcement()
    self.get_headers(locator, hashstop)
    wait_until(self.received_block_announcement, timeout=30, lock=mininode_lock)
    self.clear_block_announcement()