nortti
/
tea_cah
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

Flush log output after each line in case output is buffered

This commit is contained in:
Juhani Krekelä 2021-12-12 17:07:00 +02:00
parent 2c6d35347c
commit 9f5f74c456
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ircbot.py
View File

@ -42,6 +42,7 @@ class LoggerThread(threading.Thread):
if message_data[0] == internal_submessage_types.quit: if message_data[0] == internal_submessage_types.quit:
assert len(message_data) == 1 assert len(message_data) == 1
print('--- Quit') print('--- Quit')
sys.stdout.flush()
self.dead_notify_channel.send((controlmessage_types.quit,)) self.dead_notify_channel.send((controlmessage_types.quit,))
break break
@ -49,23 +50,28 @@ class LoggerThread(threading.Thread):
elif message_data[0] == internal_submessage_types.error: elif message_data[0] == internal_submessage_types.error:
assert len(message_data) == 2 assert len(message_data) == 2
print('--- Error', message_data[1]) print('--- Error', message_data[1])
sys.stdout.flush()
elif message_data[0] == internal_submessage_types.server: elif message_data[0] == internal_submessage_types.server:
assert len(message_data) == 2 assert len(message_data) == 2
assert len(message_data[1]) == 2 assert len(message_data[1]) == 2
print(f'--- Connecting to server {message_data[1][0]}:{message_data[1][1]}') print(f'--- Connecting to server {message_data[1][0]}:{message_data[1][1]}')
sys.stdout.flush()
else: else:
print('--- ???', message_data) print('--- ???', message_data)
sys.stdout.flush()
# Messages about status from the bot code # Messages about status from the bot code
elif message_type == logmessage_types.status: elif message_type == logmessage_types.status:
assert len(message_data) == 2 assert len(message_data) == 2
print('*', end='') print('*', end='')
print(*message_data[0], **message_data[1]) print(*message_data[0], **message_data[1])
sys.stdout.flush()
else: else:
print('???', message_type, message_data) print('???', message_type, message_data)
sys.stdout.flush()
# API(serverthread_object) # API(serverthread_object)
# Create a new API object corresponding to given ServerThread object # Create a new API object corresponding to given ServerThread object