mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-06-05 01:00:52 +00:00
IFilesystemNode: add get_storage_index(), it makes tests easier
This commit is contained in:
parent
5c0bfd7681
commit
c80e352951
@ -243,6 +243,9 @@ class NewDirectoryNode:
|
|||||||
def get_verifier(self):
|
def get_verifier(self):
|
||||||
return self._uri.get_verifier().to_string()
|
return self._uri.get_verifier().to_string()
|
||||||
|
|
||||||
|
def get_storage_index(self):
|
||||||
|
return self._uri._filenode_uri.storage_index
|
||||||
|
|
||||||
def check(self, verify=False, repair=False):
|
def check(self, verify=False, repair=False):
|
||||||
"""Perform a file check. See IChecker.check for details."""
|
"""Perform a file check. See IChecker.check for details."""
|
||||||
return self._node.check(verify, repair)
|
return self._node.check(verify, repair)
|
||||||
|
@ -44,6 +44,9 @@ class FileNode:
|
|||||||
def get_verifier(self):
|
def get_verifier(self):
|
||||||
return self.u.get_verifier()
|
return self.u.get_verifier()
|
||||||
|
|
||||||
|
def get_storage_index(self):
|
||||||
|
return self.u.storage_index
|
||||||
|
|
||||||
def check(self, verify=False, repair=False):
|
def check(self, verify=False, repair=False):
|
||||||
assert repair is False # not implemented yet
|
assert repair is False # not implemented yet
|
||||||
storage_index = self.u.storage_index
|
storage_index = self.u.storage_index
|
||||||
@ -113,6 +116,9 @@ class LiteralFileNode:
|
|||||||
def get_verifier(self):
|
def get_verifier(self):
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
def get_storage_index(self):
|
||||||
|
return None
|
||||||
|
|
||||||
def check(self, verify=False, repair=False):
|
def check(self, verify=False, repair=False):
|
||||||
# neither verify= nor repair= affect LIT files
|
# neither verify= nor repair= affect LIT files
|
||||||
r = Results(None)
|
r = Results(None)
|
||||||
|
@ -414,6 +414,11 @@ class IFilesystemNode(Interface):
|
|||||||
it holds a share for the file or directory.
|
it holds a share for the file or directory.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
def get_storage_index():
|
||||||
|
"""Return a string with the (binary) storage index in use on this
|
||||||
|
download. This may be None if there is no storage index (i.e. LIT
|
||||||
|
files)."""
|
||||||
|
|
||||||
def check(verify=False, repair=False):
|
def check(verify=False, repair=False):
|
||||||
"""Perform a file check. See IChecker.check for details.
|
"""Perform a file check. See IChecker.check for details.
|
||||||
|
|
||||||
|
@ -242,6 +242,8 @@ class Dirnode(unittest.TestCase, testutil.ShouldFailMixin, testutil.StallMixin):
|
|||||||
u_v = n.get_verifier()
|
u_v = n.get_verifier()
|
||||||
self.failUnless(u_v.startswith("URI:DIR2-Verifier:"), u_v)
|
self.failUnless(u_v.startswith("URI:DIR2-Verifier:"), u_v)
|
||||||
self.expected_manifest.append(u_v)
|
self.expected_manifest.append(u_v)
|
||||||
|
expected_si = n._uri._filenode_uri.storage_index
|
||||||
|
self.failUnlessEqual(n.get_storage_index(), expected_si)
|
||||||
|
|
||||||
d = n.list()
|
d = n.list()
|
||||||
d.addCallback(lambda res: self.failUnlessEqual(res, {}))
|
d.addCallback(lambda res: self.failUnlessEqual(res, {}))
|
||||||
|
@ -27,6 +27,7 @@ class Node(unittest.TestCase):
|
|||||||
self.failUnlessEqual(fn1.is_mutable(), False)
|
self.failUnlessEqual(fn1.is_mutable(), False)
|
||||||
self.failUnlessEqual(fn1.get_readonly_uri(), u.to_string())
|
self.failUnlessEqual(fn1.get_readonly_uri(), u.to_string())
|
||||||
self.failUnlessEqual(fn1.get_size(), 1000)
|
self.failUnlessEqual(fn1.get_size(), 1000)
|
||||||
|
self.failUnlessEqual(fn1.get_storage_index(), u.storage_index)
|
||||||
d = {}
|
d = {}
|
||||||
d[fn1] = 1 # exercise __hash__
|
d[fn1] = 1 # exercise __hash__
|
||||||
v = fn1.get_verifier()
|
v = fn1.get_verifier()
|
||||||
@ -47,6 +48,7 @@ class Node(unittest.TestCase):
|
|||||||
self.failUnlessEqual(fn1.is_mutable(), False)
|
self.failUnlessEqual(fn1.is_mutable(), False)
|
||||||
self.failUnlessEqual(fn1.get_readonly_uri(), u.to_string())
|
self.failUnlessEqual(fn1.get_readonly_uri(), u.to_string())
|
||||||
self.failUnlessEqual(fn1.get_size(), len(DATA))
|
self.failUnlessEqual(fn1.get_size(), len(DATA))
|
||||||
|
self.failUnlessEqual(fn1.get_storage_index(), None)
|
||||||
d = {}
|
d = {}
|
||||||
d[fn1] = 1 # exercise __hash__
|
d[fn1] = 1 # exercise __hash__
|
||||||
|
|
||||||
|
@ -266,6 +266,7 @@ class Filenode(unittest.TestCase, testutil.ShouldFailMixin):
|
|||||||
d = self.client.create_mutable_file()
|
d = self.client.create_mutable_file()
|
||||||
def _created(n):
|
def _created(n):
|
||||||
self.failUnless(isinstance(n, FastMutableFileNode))
|
self.failUnless(isinstance(n, FastMutableFileNode))
|
||||||
|
self.failUnlessEqual(n.get_storage_index(), n._storage_index)
|
||||||
peer0 = self.client._peerids[0]
|
peer0 = self.client._peerids[0]
|
||||||
shnums = self.client._storage._peers[peer0].keys()
|
shnums = self.client._storage._peers[peer0].keys()
|
||||||
self.failUnlessEqual(len(shnums), 1)
|
self.failUnlessEqual(len(shnums), 1)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user