ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-06-19 07:48:11 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

whitespace more conforming to PEP8

Browse Source
This commit is contained in:
Jean-Paul Calderone
2019-08-02 15:05:25 -06:00
parent 3152a35618
commit 21d735ece9
5 changed files with 0 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/allmydata/client.py
View File

@ -888,7 +888,6 @@ class _Client(node.Node, pollmixin.PollMixin):
for ic in self.introducer_clients: for ic in self.introducer_clients:
ic.publish("storage", announcement, self._node_private_key) ic.publish("storage", announcement, self._node_private_key)
def get_client_storage_plugin_web_resources(self): def get_client_storage_plugin_web_resources(self):
""" """
Get all of the client-side ``IResource`` implementations provided by Get all of the client-side ``IResource`` implementations provided by
@ -898,7 +897,6 @@ class _Client(node.Node, pollmixin.PollMixin):
""" """
return self.storage_broker.get_client_storage_plugin_web_resources() return self.storage_broker.get_client_storage_plugin_web_resources()
def _enable_storage_servers(self, announceable_storage_servers): def _enable_storage_servers(self, announceable_storage_servers):
""" """
Register and announce the given storage servers. Register and announce the given storage servers.
@ -906,7 +904,6 @@ class _Client(node.Node, pollmixin.PollMixin):
for announceable in announceable_storage_servers: for announceable in announceable_storage_servers:
yield self._enable_storage_server(announceable) yield self._enable_storage_server(announceable)
def _enable_storage_server(self, announceable_storage_server): def _enable_storage_server(self, announceable_storage_server):
""" """
Register a storage server. Register a storage server.
@ -927,7 +924,6 @@ class _Client(node.Node, pollmixin.PollMixin):
) )
return announceable_storage_server return announceable_storage_server
def init_client(self): def init_client(self):
helper_furl = self.config.get_config("client", "helper.furl", None) helper_furl = self.config.get_config("client", "helper.furl", None)
if helper_furl in ("None", ""): if helper_furl in ("None", ""):

2
src/allmydata/storage_client.py
View File

@ -197,7 +197,6 @@ class StorageFarmBroker(service.MultiService):
storage_server.setServiceParent(self) storage_server.setServiceParent(self)
storage_server.start_connecting(self._trigger_connections) storage_server.start_connecting(self._trigger_connections)
def get_client_storage_plugin_web_resources(self): def get_client_storage_plugin_web_resources(self):
""" """
Get all of the client-side ``IResource`` implementations provided by Get all of the client-side ``IResource`` implementations provided by
@ -214,7 +213,6 @@ class StorageFarmBroker(service.MultiService):
in self.storage_client_config.storage_plugins.items() in self.storage_client_config.storage_plugins.items()
} }
@log_call( @log_call(
action_type=u"storage-client:broker:make-storage-server", action_type=u"storage-client:broker:make-storage-server",
include_args=["server_id"], include_args=["server_id"],

7
src/allmydata/test/common.py
View File

@ -124,7 +124,6 @@ class MemoryIntroducerClient(object):
)) ))
@attr.s @attr.s
class Subscription(object): class Subscription(object):
""" """
@ -136,7 +135,6 @@ class Subscription(object):
kwargs = attr.ib() kwargs = attr.ib()
@attr.s @attr.s
class Announcement(object): class Announcement(object):
""" """
@ -151,7 +149,6 @@ class Announcement(object):
return ed25519.signing_keypair_from_string(self.signing_key_bytes)[0] return ed25519.signing_keypair_from_string(self.signing_key_bytes)[0]
def get_published_announcements(client): def get_published_announcements(client):
""" """
Get a flattened list of all announcements sent using all introducer Get a flattened list of all announcements sent using all introducer
@ -166,7 +163,6 @@ def get_published_announcements(client):
) )
class UseTestPlugins(object): class UseTestPlugins(object):
""" """
A fixture which enables loading Twisted plugins from the Tahoe-LAFS test A fixture which enables loading Twisted plugins from the Tahoe-LAFS test
@ -181,7 +177,6 @@ class UseTestPlugins(object):
testplugins = FilePath(__file__).sibling("plugins") testplugins = FilePath(__file__).sibling("plugins")
twisted.plugins.__path__.insert(0, testplugins.path) twisted.plugins.__path__.insert(0, testplugins.path)
def cleanUp(self): def cleanUp(self):
""" """
Remove the testing package ``plugins`` directory from the Remove the testing package ``plugins`` directory from the
@ -191,12 +186,10 @@ class UseTestPlugins(object):
testplugins = FilePath(__file__).sibling("plugins") testplugins = FilePath(__file__).sibling("plugins")
twisted.plugins.__path__.remove(testplugins.path) twisted.plugins.__path__.remove(testplugins.path)
def getDetails(self): def getDetails(self):
return {} return {}
@attr.s @attr.s
class UseNode(object): class UseNode(object):
""" """

2
src/allmydata/test/storage_plugin.py
View File

@ -61,11 +61,9 @@ class DummyStorage(object):
), ),
) )
def get_storage_client(self, configuration, announcement, get_rref): def get_storage_client(self, configuration, announcement, get_rref):
return DummyStorageClient(get_rref, configuration, announcement) return DummyStorageClient(get_rref, configuration, announcement)
def get_client_resource(self, configuration): def get_client_resource(self, configuration):
""" """
:return: A static data resource that produces the given configuration when :return: A static data resource that produces the given configuration when

3
src/allmydata/test/test_storage_client.py
View File

@ -394,7 +394,6 @@ class FoolscapStorageServers(unittest.TestCase):
) )
class StoragePluginWebPresence(AsyncTestCase): class StoragePluginWebPresence(AsyncTestCase):
""" """
Tests for the web resources ``IFoolscapStorageServer`` plugins may expose. Tests for the web resources ``IFoolscapStorageServer`` plugins may expose.
@ -435,7 +434,6 @@ class StoragePluginWebPresence(AsyncTestCase):
self.addCleanup(self.node.stopService) self.addCleanup(self.node.stopService)
self.port = self.webish.getPortnum() self.port = self.webish.getPortnum()
@inlineCallbacks @inlineCallbacks
def test_plugin_resource_path(self): def test_plugin_resource_path(self):
""" """
@ -449,7 +447,6 @@ class StoragePluginWebPresence(AsyncTestCase):
self.assertThat(result, Equals(dumps({b"web": b"1"}))) self.assertThat(result, Equals(dumps({b"web": b"1"})))
class TestStorageFarmBroker(unittest.TestCase): class TestStorageFarmBroker(unittest.TestCase):
def test_static_servers(self): def test_static_servers(self):