Added a potential bugfix for Persistent getwork connections

c00w · Aug 19, 2011 · b637dd4 · b637dd4
1 parent 529f399
commit b637dd4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lp.py b/lp.py
@@ -75,7 +75,7 @@ def api_check(self, new_server, server, block, old_shares):
             self.bitHopper.pool.servers[server]['shares'] += old_shares
             self.bitHopper.select_best_server()
 
-    def add_block(self,block, work):
+    def add_block(self, block, work):
         self.blocks[block]={}
         self.bitHopper.lp_callback(work)
         self.blocks[block]["_owner"] = None
@@ -85,7 +85,7 @@ def receive(self, body, server):
         self.polled[server].release()
         self.bitHopper.log_dbg('received lp from: ' + server)
         info = self.bitHopper.pool.servers[server]
-        if info['role'] in ['mine_nmc','disable','mine_ixc','mine_i0c']:
+        if info['role'] in ['mine_nmc', 'disable', 'mine_ixc', 'mine_i0c']:
             return
         if body == None:
             self.bitHopper.log_dbg('error in lp from: ' + server)

diff --git a/work.py b/work.py
@@ -50,6 +50,7 @@ def __init__(self, bitHopper):
         self.bitHopper = bitHopper
         self.i = 0
         self.agent = Agent(bitHopper.reactor, persistent=True)
+        self.agent.maxConnections = 4
         #twisted.web.client.Agent(bitHopper.reactor, connectTimeout=5)
 
         self.lp_agent = Agent(bitHopper.reactor, persistent=True)