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

Compare commits

base: xan:49c58c94da93d6a253b4f4a1df197bc0a99ce916
Branches Tags
xan:main
..
compare: xan:9ebe7933cbdd7ccd8a26df9a7c7441be4e1f0dab
Branches Tags
xan:main

2 commits
49c58c94da ... 9ebe7933cb

Author SHA1 Message Date
XANTRONIX Industrial
9ebe7933cb Don't start thread in case of SSL error 2025-04-09 09:50:03 -04:00
XANTRONIX Industrial
84c07efd0a Remove unused import 2025-04-09 09:33:12 -04:00
2 changed files with 4 additions and 7 deletions
Show stats Expand all files Collapse all files

2
lib/xenu_nntp/newsgroup.py
View file

@ -1,5 +1,3 @@
import datetime
from xenu_nntp.db import DatabaseTable from xenu_nntp.db import DatabaseTable
class Newsgroup(DatabaseTable): class Newsgroup(DatabaseTable):

9
lib/xenu_nntp/server.py
View file

@ -1,5 +1,4 @@
import re import re
import enum
import threading import threading
import socket import socket
import selectors import selectors
@ -38,7 +37,7 @@ class Server():
try: try:
sock, addr = listener.accept() sock, addr = listener.accept()
except ssl.SSLError as e: except ssl.SSLError:
return return
def spawn(): def spawn():
@ -46,12 +45,12 @@ class Server():
try: try:
session.handle() session.handle()
thread = threading.Thread(target=spawn)
thread.start()
except (ssl.SSLEOFError, ssl.SSLError): except (ssl.SSLEOFError, ssl.SSLError):
pass pass
thread = threading.Thread(target=spawn)
thread.start()
def run(self): def run(self):
hosts = re.split(r'\s*,\s*', self.config.get('listen', 'host')) hosts = re.split(r'\s*,\s*', self.config.get('listen', 'host'))
port = int(self.config.get('listen', 'port')) port = int(self.config.get('listen', 'port'))