mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-06-15 13:58:22 +00:00
remove stray trailing whitespace
This commit is contained in:
@ -54,7 +54,7 @@ def test_osx_pkg(pkgfile):
|
|||||||
|
|
||||||
# cat Payload | gunzip -dc | cpio -i
|
# cat Payload | gunzip -dc | cpio -i
|
||||||
cat_process = subprocess.Popen(['cat', 'Payload'], stdout=subprocess.PIPE)
|
cat_process = subprocess.Popen(['cat', 'Payload'], stdout=subprocess.PIPE)
|
||||||
gunzip_process = subprocess.Popen(['gunzip', '-dc'],
|
gunzip_process = subprocess.Popen(['gunzip', '-dc'],
|
||||||
stdin=cat_process.stdout,
|
stdin=cat_process.stdout,
|
||||||
stdout=subprocess.PIPE)
|
stdout=subprocess.PIPE)
|
||||||
cpio_process = subprocess.Popen(['cpio', '-i'],
|
cpio_process = subprocess.Popen(['cpio', '-i'],
|
||||||
|
@ -95,7 +95,7 @@ def check_location(options, where):
|
|||||||
stdout.write(" corrupt shares:\n")
|
stdout.write(" corrupt shares:\n")
|
||||||
for (serverid, storage_index, sharenum) in corrupt:
|
for (serverid, storage_index, sharenum) in corrupt:
|
||||||
stdout.write(" %s\n" % _quote_serverid_index_share(serverid, storage_index, sharenum))
|
stdout.write(" %s\n" % _quote_serverid_index_share(serverid, storage_index, sharenum))
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
def check(options):
|
def check(options):
|
||||||
@ -106,7 +106,7 @@ def check(options):
|
|||||||
return 0
|
return 0
|
||||||
for location in options.locations:
|
for location in options.locations:
|
||||||
errno = check_location(options, location)
|
errno = check_location(options, location)
|
||||||
if errno != 0:
|
if errno != 0:
|
||||||
return errno
|
return errno
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
@ -320,7 +320,7 @@ class DeepCheckStreamer(LineOnlyReceiver):
|
|||||||
if not self.options["raw"]:
|
if not self.options["raw"]:
|
||||||
output.done()
|
output.done()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|
||||||
def run(self, options):
|
def run(self, options):
|
||||||
if len(options.locations) == 0:
|
if len(options.locations) == 0:
|
||||||
@ -331,7 +331,7 @@ class DeepCheckStreamer(LineOnlyReceiver):
|
|||||||
for location in options.locations:
|
for location in options.locations:
|
||||||
errno = self.deepcheck_location(options, location)
|
errno = self.deepcheck_location(options, location)
|
||||||
if errno != 0:
|
if errno != 0:
|
||||||
return errno
|
return errno
|
||||||
return self.rc
|
return self.rc
|
||||||
|
|
||||||
def deepcheck(options):
|
def deepcheck(options):
|
||||||
|
@ -3367,11 +3367,11 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
|||||||
c0 = self.g.clients[0]
|
c0 = self.g.clients[0]
|
||||||
d = c0.create_dirnode()
|
d = c0.create_dirnode()
|
||||||
def _stash_uri(n):
|
def _stash_uri(n):
|
||||||
self.uriList.append(n.get_uri())
|
self.uriList.append(n.get_uri())
|
||||||
d.addCallback(_stash_uri)
|
d.addCallback(_stash_uri)
|
||||||
d = c0.create_dirnode()
|
d = c0.create_dirnode()
|
||||||
d.addCallback(_stash_uri)
|
d.addCallback(_stash_uri)
|
||||||
|
|
||||||
d.addCallback(lambda ign: self.do_cli("check", self.uriList[0], self.uriList[1]))
|
d.addCallback(lambda ign: self.do_cli("check", self.uriList[0], self.uriList[1]))
|
||||||
def _check((rc, out, err)):
|
def _check((rc, out, err)):
|
||||||
self.failUnlessReallyEqual(rc, 0)
|
self.failUnlessReallyEqual(rc, 0)
|
||||||
@ -3380,7 +3380,7 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
|||||||
self.failUnlessIn("Healthy", out[:len(out)/2])
|
self.failUnlessIn("Healthy", out[:len(out)/2])
|
||||||
self.failUnlessIn("Healthy", out[len(out)/2:])
|
self.failUnlessIn("Healthy", out[len(out)/2:])
|
||||||
d.addCallback(_check)
|
d.addCallback(_check)
|
||||||
|
|
||||||
d.addCallback(lambda ign: self.do_cli("check", self.uriList[0], "nonexistent:"))
|
d.addCallback(lambda ign: self.do_cli("check", self.uriList[0], "nonexistent:"))
|
||||||
def _check2((rc, out, err)):
|
def _check2((rc, out, err)):
|
||||||
self.failUnlessReallyEqual(rc, 1)
|
self.failUnlessReallyEqual(rc, 1)
|
||||||
@ -3388,7 +3388,7 @@ class Check(GridTestMixin, CLITestMixin, unittest.TestCase):
|
|||||||
self.failUnlessIn("error:", err)
|
self.failUnlessIn("error:", err)
|
||||||
self.failUnlessIn("nonexistent", err)
|
self.failUnlessIn("nonexistent", err)
|
||||||
d.addCallback(_check2)
|
d.addCallback(_check2)
|
||||||
|
|
||||||
return d
|
return d
|
||||||
|
|
||||||
|
|
||||||
|
@ -126,7 +126,7 @@ def get_local_ip_for(target):
|
|||||||
# avoid this DNS lookup. This also makes node startup fractionally
|
# avoid this DNS lookup. This also makes node startup fractionally
|
||||||
# faster.
|
# faster.
|
||||||
return None
|
return None
|
||||||
|
|
||||||
try:
|
try:
|
||||||
udpprot = DatagramProtocol()
|
udpprot = DatagramProtocol()
|
||||||
port = reactor.listenUDP(0, udpprot)
|
port = reactor.listenUDP(0, udpprot)
|
||||||
|
Reference in New Issue
Block a user