chaind

Base package for chain queue serviceBase package for chain queue service
Log | Files | Refs | LICENSE

commit e54f03a8f66d9ed0da057cd3d785db4cb86d8a79
parent 18d10dc8b79050ecb547fc3beffac2348add6b87
Author: lash <dev@holbrook.no>
Date:   Tue, 26 Apr 2022 21:28:31 +0000

Add chainqueue settings

Diffstat:
Mchaind/settings.py | 14++++++++++++++
1 file changed, 14 insertions(+), 0 deletions(-)

diff --git a/chaind/settings.py b/chaind/settings.py @@ -79,12 +79,26 @@ class ChaindSettings(ChainsyncerSettings): self.process_sync_interface(config) self.process_sync_range(config) + + def process_socket(self, config): + socket_path = config.get('SESSION_SOCKET_PATH') + if socket_path == None: + socket_path = os.path.join(self.o['SESSION_RUNTIME_DIR'], 'chaind.sock') + self.o['SESSION_SOCKET_PATH'] = socket_path + + + def process_dispatch(self, config): + self.o['SESSION_DISPATCH_DELAY'] = 0.01 + def process(self, config): self.process_common(config) self.process_session(config) + self.process_socket(config) if self.include_sync: self.process_sync(config) + if self.include_queue: + self.process_dispatch(config) def __str__(self):