xan/xenu_nntp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Always flush output before reading line for simplicity

Browse source
This commit is contained in:
XANTRONIX Development 2024-11-30 18:22:31 -05:00
parent b45fe13111
commit fcdfa488dd
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/nntp/tiny/session.py
View file

@ -48,15 +48,16 @@ class Session():
self.perms: Optional[UserPermission] = None self.perms: Optional[UserPermission] = None
self.article_id: Optional[int] = None self.article_id: Optional[int] = None
def readline(self):
return self.buf.readline(self.sock)
def print(self, text: str, end: str="\r\n"): def print(self, text: str, end: str="\r\n"):
return self.output.print(text, end) return self.output.print(text, end)
def flush(self): def flush(self):
return self.output.flush() return self.output.flush()
def readline(self):
self.flush()
return self.buf.readline(self.sock)
def end(self): def end(self):
return self.print('.') return self.print('.')
@ -800,7 +801,6 @@ class Session():
def greet(self): def greet(self):
self.respond(ResponseCode.NNTP_SERVICE_READY_POST_PROHIBITED) self.respond(ResponseCode.NNTP_SERVICE_READY_POST_PROHIBITED)
self.flush()
def handle_command(self): def handle_command(self):
line = self.readline() line = self.readline()
@ -832,7 +832,6 @@ class Session():
try: try:
while self.active: while self.active:
self.handle_command() self.handle_command()
self.flush()
self.sock.close() self.sock.close()
except BrokenPipeError: except BrokenPipeError: