ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-27 06:20:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Pacify mypy.

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2023-03-09 13:45:50 -05:00
parent 56b6dd86c3
commit 5d7d387593
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/allmydata/client.py
View File

@ -60,7 +60,7 @@ from allmydata.interfaces import (
) )
from allmydata.nodemaker import NodeMaker from allmydata.nodemaker import NodeMaker
from allmydata.blacklist import Blacklist from allmydata.blacklist import Blacklist
from allmydata.node import _Config
KiB=1024 KiB=1024
MiB=1024*KiB MiB=1024*KiB

6
src/allmydata/storage_client.py
View File

@ -34,7 +34,7 @@ from __future__ import annotations
from six import ensure_text from six import ensure_text
from typing import Union from typing import Union, Any
from os import urandom from os import urandom
import re import re
import time import time
@ -219,9 +219,9 @@ class StorageFarmBroker(service.MultiService):
# own Reconnector, and will give us a RemoteReference when we ask # own Reconnector, and will give us a RemoteReference when we ask
# them for it. # them for it.
self.servers = BytesKeyDict() self.servers = BytesKeyDict()
self._static_server_ids = set() # ignore announcements for these self._static_server_ids : set[bytes] = set() # ignore announcements for these
self.introducer_client = None self.introducer_client = None
self._threshold_listeners = [] # tuples of (threshold, Deferred) self._threshold_listeners : list[tuple[float,defer.Deferred[Any]]]= [] # tuples of (threshold, Deferred)
self._connected_high_water_mark = 0 self._connected_high_water_mark = 0
@log_call(action_type=u"storage-client:broker:set-static-servers") @log_call(action_type=u"storage-client:broker:set-static-servers")