Roll version of gsutil to 4.15.

third_party/gsutil/gslib/progress_callback.py

 # -*- coding: utf-8 -*-
 # Copyright 2014 Google Inc. All Rights Reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
@@ skipping 102 matching lines @@
     url_string = '...%s' % url_string[
         -(MAX_PROGRESS_INDICATOR_COLUMNS - start_len - end_len - ellipsis_len):]
   base_announce_text = '%s%s:' % (justified_op_string, url_string)
   format_str = '{0:%ds}' % MAX_PROGRESS_INDICATOR_COLUMNS
   return format_str.format(base_announce_text.encode(UTF8))
 
 
 class FileProgressCallbackHandler(object):
   """Outputs progress info for large operations like file copy or hash."""
 
-  def __init__(self, announce_text, logger):
+  def __init__(self, announce_text, logger, start_byte=0,
+               override_total_size=None):
     """Initializes the callback handler.
 
     Args:
       announce_text: String describing the operation.
       logger: For outputting log messages.
+      start_byte: The beginning of the file component, if one is being used.
+      override_total_size: The size of the file component, if one is being used.
     """
     self._announce_text = announce_text
     self._logger = logger
+    self._start_byte = start_byte
+    self._override_total_size = override_total_size
     # Ensures final newline is written once even if we get multiple callbacks.
     self._last_byte_written = False
 
   # Function signature is in boto callback format, which cannot be changed.
   def call(self,  # pylint: disable=invalid-name
-           total_bytes_processed,
+           last_byte_processed,
            total_size):
     """Prints an overwriting line to stderr describing the operation progress.
 
     Args:
-      total_bytes_processed: Number of bytes processed so far.
+      last_byte_processed: The last byte processed in the file. For file
+                           components, this number should be in the range
+                           [start_byte:start_byte + override_total_size].
       total_size: Total size of the ongoing operation.
     """
     if not self._logger.isEnabledFor(logging.INFO) or self._last_byte_written:
       return
 
-    # Handle streaming case specially where we don't know the total size:
+    if self._override_total_size:
+      total_size = self._override_total_size
+
     if total_size:
       total_size_string = '/%s' % MakeHumanReadable(total_size)
     else:
       total_size_string = ''
     # Use sys.stderr.write instead of self.logger.info so progress messages
     # output on a single continuously overwriting line.
     # TODO: Make this work with logging.Logger.
     sys.stderr.write('%s%s%s    \r' % (
         self._announce_text,
-        MakeHumanReadable(total_bytes_processed),
+        MakeHumanReadable(last_byte_processed - self._start_byte),
         total_size_string))
-    if total_size and total_bytes_processed == total_size:
+    if total_size and last_byte_processed - self._start_byte == total_size:
       self._last_byte_written = True
       sys.stderr.write('\n')