|
|
|
@ -359,7 +359,8 @@ class Peer(PrintError): |
|
|
|
|
|
|
|
|
|
|
|
def close_and_cleanup(self): |
|
|
|
def close_and_cleanup(self): |
|
|
|
try: |
|
|
|
try: |
|
|
|
self.writer.close() |
|
|
|
if self.transport: |
|
|
|
|
|
|
|
self.transport.writer.close() |
|
|
|
except: |
|
|
|
except: |
|
|
|
pass |
|
|
|
pass |
|
|
|
for chan in self.channels.values(): |
|
|
|
for chan in self.channels.values(): |
|
|
|
|