this was supposed to be in the last commit. oops.
This commit is contained in:
parent
520a6ecd08
commit
d0be88ef3b
1 changed files with 2 additions and 0 deletions
|
@ -27,6 +27,7 @@ class Server(object):
|
||||||
self.channel_types = []
|
self.channel_types = []
|
||||||
self.last_read = None
|
self.last_read = None
|
||||||
self.attempted_join = {}
|
self.attempted_join = {}
|
||||||
|
self.ping_sent = False
|
||||||
if ipv4:
|
if ipv4:
|
||||||
self.socket = socket.socket(socket.AF_INET,
|
self.socket = socket.socket(socket.AF_INET,
|
||||||
socket.SOCK_STREAM)
|
socket.SOCK_STREAM)
|
||||||
|
@ -152,6 +153,7 @@ class Server(object):
|
||||||
if not decoded_lines:
|
if not decoded_lines:
|
||||||
self.disconnect()
|
self.disconnect()
|
||||||
self.last_read = time.time()
|
self.last_read = time.time()
|
||||||
|
self.ping_sent = False
|
||||||
return decoded_lines
|
return decoded_lines
|
||||||
def send(self, data):
|
def send(self, data):
|
||||||
encoded = data.split("\n")[0].strip("\r").encode("utf8")
|
encoded = data.split("\n")[0].strip("\r").encode("utf8")
|
||||||
|
|
Loading…
Reference in a new issue