| Index: third_party/gsutil/gslib/util.py
|
| diff --git a/third_party/gsutil/gslib/util.py b/third_party/gsutil/gslib/util.py
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..75daba8abf47c0592fd6a8f51151120113aa3a78
|
| --- /dev/null
|
| +++ b/third_party/gsutil/gslib/util.py
|
| @@ -0,0 +1,155 @@
|
| +# Copyright 2010 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
|
| +# distributed under the License is distributed on an "AS IS" BASIS,
|
| +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
| +# See the License for the specific language governing permissions and
|
| +# limitations under the License.
|
| +
|
| +"""Static data and helper functions."""
|
| +
|
| +import math
|
| +import re
|
| +import sys
|
| +import time
|
| +
|
| +import boto
|
| +from third_party.retry_decorator.decorators import retry
|
| +
|
| +# We don't use the oauth2 authentication plugin directly; importing it here
|
| +# ensures that it's loaded and available by default. Note: we made this static
|
| +# state instead of Command instance state because the top-level gsutil code
|
| +# needs to check it.
|
| +HAVE_OAUTH2 = False
|
| +try:
|
| + from oauth2_plugin import oauth2_helper
|
| + HAVE_OAUTH2 = True
|
| +except ImportError:
|
| + pass
|
| +
|
| +TWO_MB = 2 * 1024 * 1024
|
| +
|
| +NO_MAX = sys.maxint
|
| +
|
| +# Binary exponentiation strings.
|
| +_EXP_STRINGS = [
|
| + (0, 'B', 'bit'),
|
| + (10, 'KB', 'kbit'),
|
| + (20, 'MB', 'Mbit'),
|
| + (30, 'GB', 'Gbit'),
|
| + (40, 'TB', 'Tbit'),
|
| + (50, 'PB', 'Pbit'),
|
| +]
|
| +
|
| +# Detect platform types.
|
| +IS_WINDOWS = 'win32' in str(sys.platform).lower()
|
| +IS_LINUX = 'linux' in str(sys.platform).lower()
|
| +IS_OSX = 'darwin' in str(sys.platform).lower()
|
| +
|
| +Retry = retry
|
| +
|
| +# Enum class for specifying listing style.
|
| +class ListingStyle(object):
|
| + SHORT = 'SHORT'
|
| + LONG = 'LONG'
|
| + LONG_LONG = 'LONG_LONG'
|
| +
|
| +
|
| +def HasConfiguredCredentials():
|
| + """Determines if boto credential/config file exists."""
|
| + config = boto.config
|
| + has_goog_creds = (config.has_option('Credentials', 'gs_access_key_id') and
|
| + config.has_option('Credentials', 'gs_secret_access_key'))
|
| + has_amzn_creds = (config.has_option('Credentials', 'aws_access_key_id') and
|
| + config.has_option('Credentials', 'aws_secret_access_key'))
|
| + has_oauth_creds = (HAVE_OAUTH2 and
|
| + config.has_option('Credentials', 'gs_oauth2_refresh_token'))
|
| + has_auth_plugins = config.has_option('Plugin', 'plugin_directory')
|
| + return (has_goog_creds or has_amzn_creds or has_oauth_creds
|
| + or has_auth_plugins)
|
| +
|
| +
|
| +def _RoundToNearestExponent(num):
|
| + i = 0
|
| + while i+1 < len(_EXP_STRINGS) and num >= (2 ** _EXP_STRINGS[i+1][0]):
|
| + i += 1
|
| + return i, round(float(num) / 2 ** _EXP_STRINGS[i][0], 2)
|
| +
|
| +def MakeHumanReadable(num):
|
| + """Generates human readable string for a number of bytes.
|
| +
|
| + Args:
|
| + num: The number, in bytes.
|
| +
|
| + Returns:
|
| + A string form of the number using size abbreviations (KB, MB, etc.).
|
| + """
|
| + i, rounded_val = _RoundToNearestExponent(num)
|
| + return '%s %s' % (rounded_val, _EXP_STRINGS[i][1])
|
| +
|
| +def MakeBitsHumanReadable(num):
|
| + """Generates human readable string for a number of bits.
|
| +
|
| + Args:
|
| + num: The number, in bits.
|
| +
|
| + Returns:
|
| + A string form of the number using bit size abbreviations (kbit, Mbit, etc.)
|
| + """
|
| + i, rounded_val = _RoundToNearestExponent(num)
|
| + return '%s %s' % (rounded_val, _EXP_STRINGS[i][2])
|
| +
|
| +def Percentile(values, percent, key=lambda x:x):
|
| + """Find the percentile of a list of values.
|
| +
|
| + Taken from: http://code.activestate.com/recipes/511478/
|
| +
|
| + Args:
|
| + values: a list of numeric values. Note that the values MUST BE already
|
| + sorted.
|
| + percent: a float value from 0.0 to 1.0.
|
| + key: optional key function to compute value from each element of the list
|
| + of values.
|
| +
|
| + Returns:
|
| + The percentile of the values.
|
| + """
|
| + if not values:
|
| + return None
|
| + k = (len(values) - 1) * percent
|
| + f = math.floor(k)
|
| + c = math.ceil(k)
|
| + if f == c:
|
| + return key(values[int(k)])
|
| + d0 = key(values[int(f)]) * (c-k)
|
| + d1 = key(values[int(c)]) * (k-f)
|
| + return d0 + d1
|
| +
|
| +def ExtractErrorDetail(e):
|
| + """Extract <Details> text from XML content.
|
| +
|
| + Args:
|
| + e: The GSResponseError that includes XML to be parsed.
|
| +
|
| + Returns:
|
| + (exception_name, d), where d is <Details> text or None if not found.
|
| + """
|
| + exc_name_parts = re.split("[\.']", str(type(e)))
|
| + if len(exc_name_parts) < 2:
|
| + # Shouldn't happen, but have fallback in case.
|
| + exc_name = str(type(e))
|
| + else:
|
| + exc_name = exc_name_parts[-2]
|
| + if not hasattr(e, 'body'):
|
| + return (exc_name, None)
|
| + detail_start = e.body.find('<Details>')
|
| + detail_end = e.body.find('</Details>')
|
| + if detail_start != -1 and detail_end != -1:
|
| + return (exc_name, e.body[detail_start+9:detail_end])
|
| + return (exc_name, None)
|
|
|