Bitmessage/PyBitmessage-2024-12-26
Archived
2
0
Fork 0
Code Issues 168 Pull Requests 52 Actions Packages Projects Releases 5 Wiki Activity

what if that true

Browse Source
This commit is contained in:
shportix 2023-11-02 17:36:24 +02:00
parent 27061ab98c
commit 1c918839a8
No known key found for this signature in database
GPG Key ID: 2594F3870220CC1E
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/bitmessagemain.py
View File

@ -22,6 +22,7 @@ app_dir = pathmagic.setup()
import depends import depends
depends.check_dependencies() depends.check_dependencies()
import helper_sql
import getopt import getopt
import multiprocessing import multiprocessing
# Used to capture a Ctrl-C keypress so that Bitmessage can shutdown gracefully. # Used to capture a Ctrl-C keypress so that Bitmessage can shutdown gracefully.
@ -173,18 +174,17 @@ class Main(object):
defaults.networkDefaultPayloadLengthExtraBytes / 100) defaults.networkDefaultPayloadLengthExtraBytes / 100)
# Start the SQL thread # Start the SQL thread
logging.info("SQL started")
sqlLookup = sqlThread() sqlLookup = sqlThread()
# DON'T close the main program even if there are threads left. # DON'T close the main program even if there are threads left.
# The closeEvent should command this thread to exit gracefully. # The closeEvent should command this thread to exit gracefully.
sqlLookup.daemon = False sqlLookup.daemon = False
sqlLookup.start() sqlLookup.start()
helper_sql.sql_available = True
Inventory() # init Inventory() # init
if state.enableObjProc: # Not needed if objproc is disabled if state.enableObjProc: # Not needed if objproc is disabled
shared.reloadMyAddressHashes() shared.reloadMyAddressHashes()
logging.info("Testing logger")
shared.reloadBroadcastSendersForWhichImWatching() shared.reloadBroadcastSendersForWhichImWatching()
# Start the address generation thread # Start the address generation thread

2
src/helper_sql.py
View File

@ -28,7 +28,7 @@ sqlReturnQueue = queue.Queue()
sql_lock = threading.Lock() sql_lock = threading.Lock()
""" lock to prevent queueing a new request until the previous response """ lock to prevent queueing a new request until the previous response
is available """ is available """
sql_available = True sql_available = False
"""set to True by `.threads.sqlThread` immediately upon start""" """set to True by `.threads.sqlThread` immediately upon start"""
sql_ready = threading.Event() sql_ready = threading.Event()
"""set by `.threads.sqlThread` when ready for processing (after """set by `.threads.sqlThread` when ready for processing (after