cmd_send: fold helper routines back into main function
These were split out to make the blocking- and twisted- based implementations share some code, but now that we're down to just Twisted, it's clearer to merge them back in.
This commit is contained in:
parent
35639dafed
commit
b0da2a9ac7
|
@ -13,11 +13,20 @@ APPID = u"lothar.com/wormhole/text-or-file-xfer"
|
||||||
@inlineCallbacks
|
@inlineCallbacks
|
||||||
def send_twisted(args, reactor=reactor):
|
def send_twisted(args, reactor=reactor):
|
||||||
assert isinstance(args.relay_url, type(u""))
|
assert isinstance(args.relay_url, type(u""))
|
||||||
handle_zero(args)
|
if args.zeromode:
|
||||||
|
assert not args.code
|
||||||
|
args.code = u"0-"
|
||||||
|
|
||||||
# TODO: parallelize the roundtrip that allocates the channel with the
|
# TODO: parallelize the roundtrip that allocates the channel with the
|
||||||
# (blocking) local IO (file os.stat, zipfile generation)
|
# (blocking) local IO (file os.stat, zipfile generation)
|
||||||
phase1, fd_to_send = build_phase1_data(args)
|
phase1, fd_to_send = build_phase1_data(args)
|
||||||
other_cmd = build_other_command(args)
|
|
||||||
|
other_cmd = "wormhole receive"
|
||||||
|
if args.verify:
|
||||||
|
other_cmd = "wormhole --verify receive"
|
||||||
|
if args.zeromode:
|
||||||
|
other_cmd += " -0"
|
||||||
|
|
||||||
print(u"On the other computer, please run: %s" % other_cmd,
|
print(u"On the other computer, please run: %s" % other_cmd,
|
||||||
file=args.stdout)
|
file=args.stdout)
|
||||||
|
|
||||||
|
@ -104,11 +113,6 @@ def send_twisted(args, reactor=reactor):
|
||||||
args.stdout, args.hide_progress, args.timing)
|
args.stdout, args.hide_progress, args.timing)
|
||||||
returnValue(0)
|
returnValue(0)
|
||||||
|
|
||||||
def handle_zero(args):
|
|
||||||
if args.zeromode:
|
|
||||||
assert not args.code
|
|
||||||
args.code = u"0-"
|
|
||||||
|
|
||||||
def build_phase1_data(args):
|
def build_phase1_data(args):
|
||||||
phase1 = {}
|
phase1 = {}
|
||||||
|
|
||||||
|
@ -181,14 +185,6 @@ def build_phase1_data(args):
|
||||||
|
|
||||||
raise TypeError("'%s' is neither file nor directory" % args.what)
|
raise TypeError("'%s' is neither file nor directory" % args.what)
|
||||||
|
|
||||||
def build_other_command(args):
|
|
||||||
other_cmd = "wormhole receive"
|
|
||||||
if args.verify:
|
|
||||||
other_cmd = "wormhole --verify receive"
|
|
||||||
if args.zeromode:
|
|
||||||
other_cmd += " -0"
|
|
||||||
return other_cmd
|
|
||||||
|
|
||||||
@inlineCallbacks
|
@inlineCallbacks
|
||||||
def _send_file_twisted(tdata, transit_sender, fd_to_send,
|
def _send_file_twisted(tdata, transit_sender, fd_to_send,
|
||||||
stdout, hide_progress, timing):
|
stdout, hide_progress, timing):
|
||||||
|
|
Loading…
Reference in New Issue
Block a user