run_isolated.py: install CIPD packages

client/isolateserver.py

 #!/usr/bin/env python
 # Copyright 2013 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """Archives a set of files or directories to an Isolate Server."""
 
 __version__ = '0.4.8'
 
 import base64
@@ skipping 1505 matching lines @@
       # Report to the server that it failed with more details. We'll want to
       # squash them all.
       on_error.report('Failed to hardlink\n%s -> %s' % (path, dest))
 
     if file_mode is not None:
       # Ignores all other bits.
       fs.chmod(dest, file_mode & 0500)
     with self._lock:
       self._linked.append(self._lru[digest])
 
+  def item_path(self, digest):
+    """Returns a path on disk of the cached item.
+
+    Raises:
+      CacheMiss if the item is not present in cache.
+    """

[M-A Ruel, 2016/06/06 23:34:51]

if digest not in self._lru:
  raise CacheMiss(digest)


since lru.LRUDict implements __contains__ and it is largely faster than doing a
disk I/O.

[nodir, 2016/06/07 18:46:35]

Done

+    path = self._path(digest)
+    if not fs.isfile(path):
+      raise CacheMiss(digest)
+    return path
+
   def _load(self):
     """Loads state of the cache from json file."""
     self._lock.assert_locked()
 
     if not os.path.isdir(self.cache_dir):
       fs.makedirs(self.cache_dir)
     else:
       # Make sure the cache is read-only.
       # TODO(maruel): Calculate the cost and optimize the performance
       # accordingly.
@@ skipping 751 matching lines @@
   dispatcher = subcommand.CommandDispatcher(__name__)
   return dispatcher.execute(OptionParserIsolateServer(), args)
 
 
 if __name__ == '__main__':
   subprocess42.inhibit_os_error_reporting()
   fix_encoding.fix_encoding()
   tools.disable_buffering()
   colorama.init()
   sys.exit(main(sys.argv[1:]))