ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2024-12-20 05:28:04 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

trailing-whitespace eradication, no functional changes

Browse Source
This commit is contained in:
Brian Warner 2007-11-01 15:29:03 -07:00
parent 433802f5ca
commit 3425cd9202
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/allmydata/scripts/tahoe_put-web2ish.py
View File

@ -21,7 +21,7 @@ def _put(serverurl, vdrive_fname, local_fname, verbosity):
port = int(mo.group(3)) port = int(mo.group(3))
d = defer.Deferred() d = defer.Deferred()
url = "/vdrive/global/" url = "/vdrive/global/"
if vdrive_fname: if vdrive_fname:
url += urllib.quote(vdrive_fname) url += urllib.quote(vdrive_fname)
@ -31,7 +31,7 @@ def _put(serverurl, vdrive_fname, local_fname, verbosity):
else: else:
infileobj = open(local_fname, "rb") infileobj = open(local_fname, "rb")
instream = stream.FileStream(infileobj) instream = stream.FileStream(infileobj)
d2 = protocol.ClientCreator(reactor, HTTPClientProtocol).connectTCP(host, port) d2 = protocol.ClientCreator(reactor, HTTPClientProtocol).connectTCP(host, port)
def got_resp(resp): def got_resp(resp):
@ -63,7 +63,7 @@ def _put(serverurl, vdrive_fname, local_fname, verbosity):
outbuf.append("200 (OK); ") outbuf.append("200 (OK); ")
elif resp.code == 201: elif resp.code == 201:
outbuf.append("201 (Created); ") outbuf.append("201 (Created); ")
if verbosity == 2: if verbosity == 2:
if resp.code == 200: if resp.code == 200:
outbuf.append("modified existing mapping of name %s to point to " % (vdrive_fname,)) outbuf.append("modified existing mapping of name %s to point to " % (vdrive_fname,))
@ -71,14 +71,14 @@ def _put(serverurl, vdrive_fname, local_fname, verbosity):
outbuf.append("created new mapping of name %s to point to " % (vdrive_fname,)) outbuf.append("created new mapping of name %s to point to " % (vdrive_fname,))
outbuf.append("URI: %s" % (uri,)) outbuf.append("URI: %s" % (uri,))
sys.stdout.write(''.join(outbuf)) sys.stdout.write(''.join(outbuf))
sys.stdout.write("\n") sys.stdout.write("\n")
d.callback(resp.code) d.callback(resp.code)
stream.readStream(resp.stream, gather_uri).addCallback(output_result) stream.readStream(resp.stream, gather_uri).addCallback(output_result)
def send_req(proto): def send_req(proto):
proto.submitRequest(ClientRequest('PUT', url, {}, instream)).addCallback(got_resp) proto.submitRequest(ClientRequest('PUT', url, {}, instream)).addCallback(got_resp)
@ -101,7 +101,7 @@ def put(server, vdrive_fname, local_fname, verbosity):
exitcode[0] = result exitcode[0] = result
reactor.stop() reactor.stop()
return result return result
d.addCallbacks(exit, exit) d.addCallbacks(exit, exit)
reactor.run() reactor.run()
return exitcode[0] return exitcode[0]