2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 01:22:00 +00:00

node rsync -s switch

This commit is contained in:
tkucherera 2023-09-27 17:52:15 -04:00
parent bd0b16992d
commit eee8bbb498
2 changed files with 13 additions and 2 deletions

View File

@ -48,6 +48,8 @@ def run():
'prompting if over the threshold')
argparser.add_option('-l', '--loginname', type='str',
help='Username to use when connecting, defaults to current user.')
argparser.add_option('-s', '--substitutename',
help='Use a different name other than the nodename for rsync')
argparser.add_option('-f', '-c', '--count', type='int', default=168,
help='Number of nodes to concurrently rsync')
# among other things, FD_SETSIZE limits. Besides, spawning too many
@ -63,8 +65,14 @@ def run():
c = client.Command()
cmdstr = ' '.join(args[:-1])
cmdstr = 'rsync -av --info=progress2 ' + cmdstr
if options.loginname:
cmdstr += ' {}@'.format(options.loginname) + '{node}:' + targpath
if options.loginname and options.substitutename:
cmdstr += ' {}@'.format(options.loginname) + '{node}' + '{}:'.format(options.substitutename) + targpath
elif options.loginname and not options.substitutename:
cmdstr += ' {}@'.format(options.loginname) + '{node}:' + targpath
elif options.substitutename and not options.loginname:
subname = options.substitutename
if '{' not in subname:
cmdstr += ' {node}' + '{}:'.format(options.substitutename) + targpath
else:
cmdstr += ' {node}:' + targpath

View File

@ -16,6 +16,9 @@ noderange. This will present progress as percentage for all nodes.
Specify how many rsync executions to do concurrently. If noderange
exceeds the count, then excess nodes will wait until one of the
active count completes.
* `-s`, `--substitutename`:
'Use a different name other than the nodename for rsync'
* `-m MAXNODES`, `--maxnodes=MAXNODES`:
Specify a maximum number of nodes to run rsync to, prompting if over the