import p2pool, p2pool.data as p2pool_data
class WorkerBridge(worker_interface.WorkerBridge):
- def __init__(self, my_pubkey_hash, net, donation_percentage, bitcoind_work, best_block_header, merged_urls, best_share_var, tracker, my_share_hashes, my_doa_share_hashes, worker_fee, p2p_node, submit_block, set_best_share, broadcast_share, block_height_var):
+ def __init__(self, my_pubkey_hash, net, donation_percentage, bitcoind_work, best_block_header, merged_urls, best_share_var, tracker, my_share_hashes, my_doa_share_hashes, worker_fee, p2p_node, submit_block, set_best_share, broadcast_share):
worker_interface.WorkerBridge.__init__(self)
self.recent_shares_ts_work = []
self.submit_block = submit_block
self.set_best_share = set_best_share
self.broadcast_share = broadcast_share
- self.block_height_var = block_height_var
self.pseudoshare_received = variable.Event()
self.share_received = variable.Event()
time=bb['timestamp'] + 600, # better way?
transactions=[],
merkle_link=bitcoin_data.calculate_merkle_link([None], 0),
- subsidy=net.PARENT.SUBSIDY_FUNC(self.block_height_var.value),
+ subsidy=net.PARENT.SUBSIDY_FUNC(self.bitcoind_work.value['height']),
last_update=self.bitcoind_work.value['last_update'],
)
# Share -> NewShare only valid if 85% of hashes in [net.CHAIN_LENGTH*9//10, net.CHAIN_LENGTH] for new version
if self.tracker.get_height(previous_share.hash) < self.net.CHAIN_LENGTH:
share_type = p2pool_data.Share
+ elif time.time() < 1351383661 and self.net.NAME == 'bitcoin':
+ share_type = p2pool_data.Share
else:
counts = p2pool_data.get_desired_version_counts(self.tracker,
self.tracker.get_nth_parent_hash(previous_share.hash, self.net.CHAIN_LENGTH*9//10), self.net.CHAIN_LENGTH//10)