continue
#if p2pool_init.DEBUG:
# print "Sending share %s to %r" % (p2pool.format_hash(share.hash), peer.addr)
- peer.send_shares([share])
+ peer.sendShares([share])
share.flag_shared()
def p2p_shares(shares, peer=None):
break
shares.append(share)
print 'Sending %i shares to %s:%i' % (len(shares), peer.addr[0], peer.addr[1])
- peer.send_shares(shares)
+ peer.sendShares(shares)
print 'Joining p2pool network using TCP port %i...' % (args.p2pool_port,)
shares.append(share)
self.node.handle_shares(shares, self)
- def send_shares(self, shares):
+ def sendShares(self, shares):
share1bs = []
share1as = []
# XXX doesn't need to send full block when it's not urgent