X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fbitcoin%2Fstratum.py;h=b70ac3ea9556b4c428f84d7c3b1ff364b826eb50;hb=2dffea00ee99f2c624a8504afee37532ba3daa5d;hp=464af5245da4a10129796598ec6e7ec35f46f5d0;hpb=ca2e77d2d90638705eaa1e7e1db61fe05669c6d4;p=p2pool.git

diff --git a/p2pool/bitcoin/stratum.py b/p2pool/bitcoin/stratum.py
index 464af52..b70ac3e 100644
--- a/p2pool/bitcoin/stratum.py
+++ b/p2pool/bitcoin/stratum.py
@@ -18,6 +18,8 @@ class StratumRPCMiningProvider(object):
         self.watch_id = self.wb.new_work_event.watch(self._send_work)
     
     def rpc_subscribe(self):
+        reactor.callLater(0, self._send_work)
+        
         return [
             ["mining.notify", "ae6812eb4cd7735a302a8a9dd95cf71f"], # subscription details
             "", # extranonce1
@@ -30,10 +32,7 @@ class StratumRPCMiningProvider(object):
         reactor.callLater(0, self._send_work)
     
     def _send_work(self):
-        if self.username is None: # authorize hasn't been received yet
-            return
-        
-        x, got_response = self.wb.get_work(*self.wb.preprocess_request(self.username))
+        x, got_response = self.wb.get_work(*self.wb.preprocess_request('' if self.username is None else self.username))
         jobid = str(random.randrange(2**128))
         self.other.svc_mining.rpc_set_difficulty(bitcoin_data.target_to_difficulty(x['share_target'])).addErrback(lambda err: None)
         self.other.svc_mining.rpc_notify(