def update(self):
data = self.receive()
- if data is None:
+ if not data:
# close_session
self.session.stop()
return False
try:
return self.session.connection().recv(1024)
except socket.error:
- return None
+ return ''
def parse(self):
raw_buffer = self.message.find('\n')
processor.shared = shared
processor.start()
# Create various transports we need
- transports = TcpServer(shared, processor, "ecdsa.org", 50002),
+ transports = TcpServer(shared, processor, "176.31.24.241", 50001),
for server in transports:
server.start()
while not shared.stopped():