diff options
Diffstat (limited to 'scripts/lib')
-rw-r--r-- | scripts/lib/devtool/deploy.py | 87 |
1 files changed, 78 insertions, 9 deletions
diff --git a/scripts/lib/devtool/deploy.py b/scripts/lib/devtool/deploy.py index d54f6ba2e1..66644ccb6a 100644 --- a/scripts/lib/devtool/deploy.py +++ b/scripts/lib/devtool/deploy.py | |||
@@ -28,7 +28,7 @@ logger = logging.getLogger('devtool') | |||
28 | 28 | ||
29 | deploylist_path = '/.devtool' | 29 | deploylist_path = '/.devtool' |
30 | 30 | ||
31 | def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=False): | 31 | def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=False, nopreserve=False, nocheckspace=False): |
32 | """ | 32 | """ |
33 | Prepare a shell script for running on the target to | 33 | Prepare a shell script for running on the target to |
34 | deploy/undeploy files. We have to be careful what we put in this | 34 | deploy/undeploy files. We have to be careful what we put in this |
@@ -48,6 +48,7 @@ def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=Fals | |||
48 | if not deploy: | 48 | if not deploy: |
49 | lines.append('echo "Previously deployed files for $1:"') | 49 | lines.append('echo "Previously deployed files for $1:"') |
50 | lines.append('manifest="%s/$1.list"' % deploylist_path) | 50 | lines.append('manifest="%s/$1.list"' % deploylist_path) |
51 | lines.append('preservedir="%s/$1.preserve"' % deploylist_path) | ||
51 | lines.append('if [ -f $manifest ] ; then') | 52 | lines.append('if [ -f $manifest ] ; then') |
52 | # Read manifest in reverse and delete files / remove empty dirs | 53 | # Read manifest in reverse and delete files / remove empty dirs |
53 | lines.append(' sed \'1!G;h;$!d\' $manifest | while read file') | 54 | lines.append(' sed \'1!G;h;$!d\' $manifest | while read file') |
@@ -58,7 +59,10 @@ def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=Fals | |||
58 | lines.append(' fi') | 59 | lines.append(' fi') |
59 | else: | 60 | else: |
60 | lines.append(' if [ -d $file ] ; then') | 61 | lines.append(' if [ -d $file ] ; then') |
61 | lines.append(' rmdir $file > /dev/null 2>&1 || true') | 62 | # Avoid deleting a preserved directory in case it has special perms |
63 | lines.append(' if [ ! -d $preservedir/$file ] ; then') | ||
64 | lines.append(' rmdir $file > /dev/null 2>&1 || true') | ||
65 | lines.append(' fi') | ||
62 | lines.append(' else') | 66 | lines.append(' else') |
63 | lines.append(' rm $file') | 67 | lines.append(' rm $file') |
64 | lines.append(' fi') | 68 | lines.append(' fi') |
@@ -71,6 +75,39 @@ def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=Fals | |||
71 | lines.append('fi') | 75 | lines.append('fi') |
72 | 76 | ||
73 | if deploy: | 77 | if deploy: |
78 | if not nocheckspace: | ||
79 | # Check for available space | ||
80 | # FIXME This doesn't take into account files spread across multiple | ||
81 | # partitions, but doing that is non-trivial | ||
82 | # Find the part of the destination path that exists | ||
83 | lines.append('checkpath="$2"') | ||
84 | lines.append('while [ "$checkpath" != "/" ] && [ ! -e $checkpath ]') | ||
85 | lines.append('do') | ||
86 | lines.append(' checkpath=`dirname "$checkpath"`') | ||
87 | lines.append('done') | ||
88 | lines.append('freespace=`df -P $checkpath | sed "1d" | awk \'{ print $4 }\'`') | ||
89 | # First line of the file is the total space | ||
90 | lines.append('total=`head -n1 $3`') | ||
91 | lines.append('if [ $total -gt $freespace ] ; then') | ||
92 | lines.append(' echo "ERROR: insufficient space on target (available ${freespace}, needed ${total})"') | ||
93 | lines.append(' exit 1') | ||
94 | lines.append('fi') | ||
95 | if not nopreserve: | ||
96 | # Preserve any files that exist. Note that this will add to the | ||
97 | # preserved list with successive deployments if the list of files | ||
98 | # deployed changes, but because we've deleted any previously | ||
99 | # deployed files at this point it will never preserve anything | ||
100 | # that was deployed, only files that existed prior to any deploying | ||
101 | # (which makes the most sense) | ||
102 | lines.append('cat $3 | sed "1d" | while read file fsize') | ||
103 | lines.append('do') | ||
104 | lines.append(' if [ -e $file ] ; then') | ||
105 | lines.append(' dest="$preservedir/$file"') | ||
106 | lines.append(' mkdir -p `dirname $dest`') | ||
107 | lines.append(' mv $file $dest') | ||
108 | lines.append(' fi') | ||
109 | lines.append('done') | ||
110 | lines.append('rm $3') | ||
74 | lines.append('mkdir -p `dirname $manifest`') | 111 | lines.append('mkdir -p `dirname $manifest`') |
75 | lines.append('mkdir -p $2') | 112 | lines.append('mkdir -p $2') |
76 | if verbose: | 113 | if verbose: |
@@ -78,6 +115,14 @@ def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=Fals | |||
78 | else: | 115 | else: |
79 | lines.append(' tar xv -C $2 -f - > $manifest') | 116 | lines.append(' tar xv -C $2 -f - > $manifest') |
80 | lines.append('sed -i "s!^./!$2!" $manifest') | 117 | lines.append('sed -i "s!^./!$2!" $manifest') |
118 | elif not dryrun: | ||
119 | # Put any preserved files back | ||
120 | lines.append('if [ -d $preservedir ] ; then') | ||
121 | lines.append(' cd $preservedir') | ||
122 | lines.append(' find . -type f -exec mv {} /{} \;') | ||
123 | lines.append(' cd /') | ||
124 | lines.append(' rm -rf $preservedir') | ||
125 | lines.append('fi') | ||
81 | 126 | ||
82 | if undeployall: | 127 | if undeployall: |
83 | if not dryrun: | 128 | if not dryrun: |
@@ -94,6 +139,7 @@ def _prepare_remote_script(deploy, verbose=False, dryrun=False, undeployall=Fals | |||
94 | def deploy(args, config, basepath, workspace): | 139 | def deploy(args, config, basepath, workspace): |
95 | """Entry point for the devtool 'deploy' subcommand""" | 140 | """Entry point for the devtool 'deploy' subcommand""" |
96 | import re | 141 | import re |
142 | import math | ||
97 | import oe.recipeutils | 143 | import oe.recipeutils |
98 | 144 | ||
99 | check_workspace_recipe(workspace, args.recipename, checksrc=False) | 145 | check_workspace_recipe(workspace, args.recipename, checksrc=False) |
@@ -119,11 +165,23 @@ def deploy(args, config, basepath, workspace): | |||
119 | 'recipe? If so, the install step has not installed ' | 165 | 'recipe? If so, the install step has not installed ' |
120 | 'any files.' % args.recipename) | 166 | 'any files.' % args.recipename) |
121 | 167 | ||
168 | filelist = [] | ||
169 | ftotalsize = 0 | ||
170 | for root, _, files in os.walk(recipe_outdir): | ||
171 | for fn in files: | ||
172 | # Get the size in kiB (since we'll be comparing it to the output of du -k) | ||
173 | # MUST use lstat() here not stat() or getfilesize() since we don't want to | ||
174 | # dereference symlinks | ||
175 | fsize = int(math.ceil(float(os.lstat(os.path.join(root, fn)).st_size)/1024)) | ||
176 | ftotalsize += fsize | ||
177 | # The path as it would appear on the target | ||
178 | fpath = os.path.join(destdir, os.path.relpath(root, recipe_outdir), fn) | ||
179 | filelist.append((fpath, fsize)) | ||
180 | |||
122 | if args.dry_run: | 181 | if args.dry_run: |
123 | print('Files to be deployed for %s on target %s:' % (args.recipename, args.target)) | 182 | print('Files to be deployed for %s on target %s:' % (args.recipename, args.target)) |
124 | for root, _, files in os.walk(recipe_outdir): | 183 | for item, _ in filelist: |
125 | for fn in files: | 184 | print(' %s' % item) |
126 | print(' %s' % os.path.join(destdir, os.path.relpath(root, recipe_outdir), fn)) | ||
127 | return 0 | 185 | return 0 |
128 | 186 | ||
129 | 187 | ||
@@ -140,11 +198,20 @@ def deploy(args, config, basepath, workspace): | |||
140 | tmpdir = tempfile.mkdtemp(prefix='devtool') | 198 | tmpdir = tempfile.mkdtemp(prefix='devtool') |
141 | try: | 199 | try: |
142 | tmpscript = '/tmp/devtool_deploy.sh' | 200 | tmpscript = '/tmp/devtool_deploy.sh' |
143 | shellscript = _prepare_remote_script(deploy=True, verbose=args.show_status) | 201 | tmpfilelist = os.path.join(os.path.dirname(tmpscript), 'devtool_deploy.list') |
202 | shellscript = _prepare_remote_script(deploy=True, | ||
203 | verbose=args.show_status, | ||
204 | nopreserve=args.no_preserve, | ||
205 | nocheckspace=args.no_check_space) | ||
144 | # Write out the script to a file | 206 | # Write out the script to a file |
145 | with open(os.path.join(tmpdir, os.path.basename(tmpscript)), 'w') as f: | 207 | with open(os.path.join(tmpdir, os.path.basename(tmpscript)), 'w') as f: |
146 | f.write(shellscript) | 208 | f.write(shellscript) |
147 | # Copy it to the target | 209 | # Write out the file list |
210 | with open(os.path.join(tmpdir, os.path.basename(tmpfilelist)), 'w') as f: | ||
211 | f.write('%d\n' % ftotalsize) | ||
212 | for fpath, fsize in filelist: | ||
213 | f.write('%s %d\n' % (fpath, fsize)) | ||
214 | # Copy them to the target | ||
148 | ret = subprocess.call("scp %s %s/* %s:%s" % (extraoptions, tmpdir, args.target, os.path.dirname(tmpscript)), shell=True) | 215 | ret = subprocess.call("scp %s %s/* %s:%s" % (extraoptions, tmpdir, args.target, os.path.dirname(tmpscript)), shell=True) |
149 | if ret != 0: | 216 | if ret != 0: |
150 | raise DevtoolError('Failed to copy script to %s - rerun with -s to ' | 217 | raise DevtoolError('Failed to copy script to %s - rerun with -s to ' |
@@ -153,7 +220,7 @@ def deploy(args, config, basepath, workspace): | |||
153 | shutil.rmtree(tmpdir) | 220 | shutil.rmtree(tmpdir) |
154 | 221 | ||
155 | # Now run the script | 222 | # Now run the script |
156 | ret = exec_fakeroot(rd, 'tar cf - . | ssh %s %s \'sh %s %s %s\'' % (extraoptions, args.target, tmpscript, args.recipename, destdir), cwd=recipe_outdir, shell=True) | 223 | ret = exec_fakeroot(rd, 'tar cf - . | ssh %s %s \'sh %s %s %s %s\'' % (extraoptions, args.target, tmpscript, args.recipename, destdir, tmpfilelist), cwd=recipe_outdir, shell=True) |
157 | if ret != 0: | 224 | if ret != 0: |
158 | raise DevtoolError('Deploy failed - rerun with -s to get a complete ' | 225 | raise DevtoolError('Deploy failed - rerun with -s to get a complete ' |
159 | 'error message') | 226 | 'error message') |
@@ -213,13 +280,15 @@ def register_commands(subparsers, context): | |||
213 | """Register devtool subcommands from the deploy plugin""" | 280 | """Register devtool subcommands from the deploy plugin""" |
214 | parser_deploy = subparsers.add_parser('deploy-target', | 281 | parser_deploy = subparsers.add_parser('deploy-target', |
215 | help='Deploy recipe output files to live target machine', | 282 | help='Deploy recipe output files to live target machine', |
216 | description='Deploys a recipe\'s build output (i.e. the output of the do_install task) to a live target machine over ssh. Note: this only deploys the recipe itself and not any runtime dependencies, so it is assumed that those have been installed on the target beforehand.', | 283 | description='Deploys a recipe\'s build output (i.e. the output of the do_install task) to a live target machine over ssh. By default, any existing files will be preserved instead of being overwritten and will be restored if you run devtool undeploy-target. Note: this only deploys the recipe itself and not any runtime dependencies, so it is assumed that those have been installed on the target beforehand.', |
217 | group='testbuild') | 284 | group='testbuild') |
218 | parser_deploy.add_argument('recipename', help='Recipe to deploy') | 285 | parser_deploy.add_argument('recipename', help='Recipe to deploy') |
219 | parser_deploy.add_argument('target', help='Live target machine running an ssh server: user@hostname[:destdir]') | 286 | parser_deploy.add_argument('target', help='Live target machine running an ssh server: user@hostname[:destdir]') |
220 | parser_deploy.add_argument('-c', '--no-host-check', help='Disable ssh host key checking', action='store_true') | 287 | parser_deploy.add_argument('-c', '--no-host-check', help='Disable ssh host key checking', action='store_true') |
221 | parser_deploy.add_argument('-s', '--show-status', help='Show progress/status output', action='store_true') | 288 | parser_deploy.add_argument('-s', '--show-status', help='Show progress/status output', action='store_true') |
222 | parser_deploy.add_argument('-n', '--dry-run', help='List files to be deployed only', action='store_true') | 289 | parser_deploy.add_argument('-n', '--dry-run', help='List files to be deployed only', action='store_true') |
290 | parser_deploy.add_argument('-p', '--no-preserve', help='Do not preserve existing files', action='store_true') | ||
291 | parser_deploy.add_argument('--no-check-space', help='Do not check for available space before deploying', action='store_true') | ||
223 | parser_deploy.set_defaults(func=deploy) | 292 | parser_deploy.set_defaults(func=deploy) |
224 | 293 | ||
225 | parser_undeploy = subparsers.add_parser('undeploy-target', | 294 | parser_undeploy = subparsers.add_parser('undeploy-target', |