Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

remove unused multiprocessin.Manager

Browse source
This commit is contained in:
Victor Shyba 2021-05-15 02:10:44 -03:00 committed by Victor Shyba
parent 09339c9cfb
commit 09f6637fe0
1 changed files with 4 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
lbry/wallet/server/db/writer.py
View file

@ -5,7 +5,6 @@ from typing import Union, Tuple, Set, List
from itertools import chain from itertools import chain
from decimal import Decimal from decimal import Decimal
from collections import namedtuple from collections import namedtuple
from multiprocessing import Manager
from binascii import unhexlify, hexlify from binascii import unhexlify, hexlify
from lbry.wallet.server.leveldb import LevelDB from lbry.wallet.server.leveldb import LevelDB
from lbry.wallet.server.util import class_logger from lbry.wallet.server.util import class_logger
@ -220,7 +219,6 @@ class SQLDB:
self.db = None self.db = None
self.logger = class_logger(__name__, self.__class__.__name__) self.logger = class_logger(__name__, self.__class__.__name__)
self.ledger = Ledger if main.coin.NET == 'mainnet' else RegTestLedger self.ledger = Ledger if main.coin.NET == 'mainnet' else RegTestLedger
self.state_manager = None
self.blocked_streams = None self.blocked_streams = None
self.blocked_channels = None self.blocked_channels = None
self.blocking_channel_hashes = { self.blocking_channel_hashes = {
@ -251,11 +249,10 @@ class SQLDB:
self.execute(self.PRAGMAS) self.execute(self.PRAGMAS)
self.execute(self.CREATE_TABLES_QUERY) self.execute(self.CREATE_TABLES_QUERY)
register_canonical_functions(self.db) register_canonical_functions(self.db)
self.state_manager = Manager() self.blocked_streams = {}
self.blocked_streams = self.state_manager.dict() self.blocked_channels = {}
self.blocked_channels = self.state_manager.dict() self.filtered_streams = {}
self.filtered_streams = self.state_manager.dict() self.filtered_channels = {}
self.filtered_channels = self.state_manager.dict()
self.update_blocked_and_filtered_claims() self.update_blocked_and_filtered_claims()
for algorithm in self.trending: for algorithm in self.trending:
algorithm.install(self.db) algorithm.install(self.db)
@ -263,8 +260,6 @@ class SQLDB:
def close(self): def close(self):
if self.db is not None: if self.db is not None:
self.db.close() self.db.close()
if self.state_manager is not None:
self.state_manager.shutdown()
def update_blocked_and_filtered_claims(self): def update_blocked_and_filtered_claims(self):
self.update_claims_from_channel_hashes( self.update_claims_from_channel_hashes(