self._message_prefix = message_prefix
self._max_payload_length = max_payload_length
self.dataReceived2 = datachunker.DataChunker(self.dataReceiver())
- self.paused_var = variable.Variable(False)
self.traffic_happened = traffic_happened
- def connectionMade(self):
- self.transport.registerProducer(self, True)
-
- def pauseProducing(self):
- self.paused_var.set(True)
-
- def resumeProducing(self):
- self.paused_var.set(False)
-
- def stopProducing(self):
- pass
-
def dataReceived(self, data):
self.traffic_happened.happened('p2p/in', len(data))
self.dataReceived2(data)
data = self._message_prefix + struct.pack('<12sI', command, len(payload)) + hashlib.sha256(hashlib.sha256(payload).digest()).digest()[:4] + payload
self.traffic_happened.happened('p2p/out', len(data))
self.transport.write(data)
- return self.paused_var.get_when_satisfies(lambda paused: not paused)
def __getattr__(self, attr):
prefix = 'send_'