1 from __future__ import division
7 from twisted.internet import defer
10 from p2pool.bitcoin import getwork
11 from p2pool.util import jsonrpc, variable
13 class _Page(jsonrpc.Server):
14 def __init__(self, parent, long_poll):
15 jsonrpc.Server.__init__(self)
17 self.long_poll = long_poll
19 def rpc_getwork(self, request, data=None):
20 return self.parent._getwork(request, data, long_poll=self.long_poll)
22 def render_GET(self, request):
23 request.content = StringIO.StringIO(json.dumps(dict(id=0, method='getwork')))
24 return self.render_POST(request)
26 class WorkerBridge(object):
28 self.new_work_event = variable.Event()
30 def preprocess_request(self, request):
31 return request, # *args to self.compute
33 def get_work(self, request):
34 raise NotImplementedError()
36 def got_response(self, block_header):
37 print self.got_response, "called with", block_header
39 class WorkerInterface(object):
40 def __init__(self, worker_bridge):
41 self.worker_bridge = worker_bridge
43 self.worker_views = {}
45 self.work_cache = {} # request_process_func(request) -> blockattempt
46 self.work_cache_times = self.worker_bridge.new_work_event.times
48 def attach_to(self, res):
49 res.putChild('', _Page(self, long_poll=False))
50 res.putChild('long-polling', _Page(self, long_poll=True))
52 @defer.inlineCallbacks
53 def _getwork(self, request, data, long_poll):
54 request.setHeader('X-Long-Polling', '/long-polling')
55 request.setHeader('X-Roll-NTime', 'expire=10')
56 request.setHeader('X-Is-P2Pool', 'true')
59 defer.returnValue(self.worker_bridge.got_response(getwork.decode_data(data), request))
62 id = random.randrange(1000, 10000)
63 print 'POLL %i START is_long_poll=%r user_agent=%r user=%r' % (id, long_poll, request.getHeader('User-Agent'), request.getUser())
66 request_id = request.getClientIP(), request.getHeader('Authorization')
67 if self.worker_views.get(request_id, self.worker_bridge.new_work_event.times) != self.worker_bridge.new_work_event.times:
69 print 'POLL %i PUSH' % (id,)
72 print 'POLL %i WAITING' % (id,)
73 yield self.worker_bridge.new_work_event.get_deferred()
74 self.worker_views[request_id] = self.worker_bridge.new_work_event.times
76 key = self.worker_bridge.preprocess_request(request)
78 if self.work_cache_times != self.worker_bridge.new_work_event.times:
80 self.work_cache_times = self.worker_bridge.new_work_event.times
82 if key in self.work_cache:
83 res, orig_timestamp = self.work_cache.pop(key)
85 res = self.worker_bridge.get_work(*key)
86 orig_timestamp = res.timestamp
88 if res.timestamp + 12 < orig_timestamp + 600:
89 self.work_cache[key] = res.update(timestamp=res.timestamp + 12), orig_timestamp
92 print 'POLL %i END identifier=%i' % (id, self.worker_bridge.new_work_event.times)
94 defer.returnValue(res.getwork(identifier=str(self.worker_bridge.new_work_event.times), submitold=True))