machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Await mysql queries in order to avoid deadlock

Browse Source
This commit is contained in:
nymkappa 2022-08-22 22:31:21 +02:00
parent 7fe9029a4e
commit b3735328b7
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/src/tasks/lightning/network-sync.service.ts
View File

@ -83,7 +83,7 @@ class NetworkSyncService {
logger.info(`${progress} nodes updated. ${deletedSockets} sockets deleted`); logger.info(`${progress} nodes updated. ${deletedSockets} sockets deleted`);
// If a channel if not present in the graph, mark it as inactive // If a channel if not present in the graph, mark it as inactive
nodesApi.$setNodesInactive(graphNodesPubkeys); await nodesApi.$setNodesInactive(graphNodesPubkeys);
if (config.MAXMIND.ENABLED) { if (config.MAXMIND.ENABLED) {
$lookupNodeLocation(); $lookupNodeLocation();
@ -121,7 +121,7 @@ class NetworkSyncService {
logger.info(`${progress} channels updated`); logger.info(`${progress} channels updated`);
// If a channel if not present in the graph, mark it as inactive // If a channel if not present in the graph, mark it as inactive
channelsApi.$setChannelsInactive(graphChannelsIds); await channelsApi.$setChannelsInactive(graphChannelsIds);
} catch (e) { } catch (e) {
logger.err(`Cannot update channel list. Reason: ${(e instanceof Error ? e.message : e)}`); logger.err(`Cannot update channel list. Reason: ${(e instanceof Error ? e.message : e)}`);
} }