2014-03-10 21:36:47 +00:00
|
|
|
from __future__ import absolute_import
|
2015-05-30 00:03:28 +00:00
|
|
|
import os
|
|
|
|
import datetime
|
|
|
|
import re
|
|
|
|
import time
|
2011-06-30 01:27:27 +00:00
|
|
|
import json
|
2011-03-07 00:46:02 +00:00
|
|
|
|
2015-05-30 00:03:28 +00:00
|
|
|
|
2011-03-07 00:46:02 +00:00
|
|
|
def timestamp():
|
2011-03-08 23:18:08 +00:00
|
|
|
"""
|
|
|
|
Returns a serializable UTC timestamp.
|
|
|
|
"""
|
|
|
|
return time.time()
|
2011-03-07 00:46:02 +00:00
|
|
|
|
2010-02-16 04:09:07 +00:00
|
|
|
|
2015-03-03 20:49:47 +00:00
|
|
|
def format_timestamp(s):
|
2015-03-03 02:22:44 +00:00
|
|
|
s = time.localtime(s)
|
|
|
|
d = datetime.datetime.fromtimestamp(time.mktime(s))
|
|
|
|
return d.strftime("%Y-%m-%d %H:%M:%S")
|
2011-02-03 00:30:47 +00:00
|
|
|
|
2015-03-04 17:02:01 +00:00
|
|
|
|
2015-03-03 02:22:44 +00:00
|
|
|
def format_timestamp_with_milli(s):
|
|
|
|
d = datetime.datetime.fromtimestamp(s)
|
2015-03-04 17:02:01 +00:00
|
|
|
return d.strftime("%Y-%m-%d %H:%M:%S.%f")[:-3]
|
|
|
|
|
|
|
|
|
2010-02-16 04:09:07 +00:00
|
|
|
def isBin(s):
|
|
|
|
"""
|
|
|
|
Does this string have any non-ASCII characters?
|
|
|
|
"""
|
|
|
|
for i in s:
|
|
|
|
i = ord(i)
|
|
|
|
if i < 9:
|
|
|
|
return True
|
|
|
|
elif i > 13 and i < 32:
|
|
|
|
return True
|
|
|
|
elif i > 126:
|
|
|
|
return True
|
|
|
|
return False
|
|
|
|
|
|
|
|
|
2011-06-27 03:59:17 +00:00
|
|
|
def isXML(s):
|
|
|
|
for i in s:
|
|
|
|
if i in "\n \t":
|
|
|
|
continue
|
|
|
|
elif i == "<":
|
|
|
|
return True
|
|
|
|
else:
|
|
|
|
return False
|
|
|
|
|
|
|
|
|
2011-06-30 01:27:27 +00:00
|
|
|
def pretty_json(s):
|
|
|
|
try:
|
|
|
|
p = json.loads(s)
|
|
|
|
except ValueError:
|
|
|
|
return None
|
|
|
|
return json.dumps(p, sort_keys=True, indent=4).split("\n")
|
|
|
|
|
|
|
|
|
2015-02-26 21:14:20 +00:00
|
|
|
def pretty_duration(secs):
|
|
|
|
formatters = [
|
2015-03-04 17:02:01 +00:00
|
|
|
(100, "{:.0f}s"),
|
|
|
|
(10, "{:2.1f}s"),
|
|
|
|
(1, "{:1.2f}s"),
|
2015-02-26 21:14:20 +00:00
|
|
|
]
|
|
|
|
|
|
|
|
for limit, formatter in formatters:
|
|
|
|
if secs >= limit:
|
|
|
|
return formatter.format(secs)
|
2015-05-30 00:03:28 +00:00
|
|
|
# less than 1 sec
|
|
|
|
return "{:.0f}ms".format(secs * 1000)
|
2010-02-16 04:09:07 +00:00
|
|
|
|
2015-04-30 00:18:01 +00:00
|
|
|
|
2010-02-16 04:09:07 +00:00
|
|
|
class Data:
|
|
|
|
def __init__(self, name):
|
|
|
|
m = __import__(name)
|
|
|
|
dirname, _ = os.path.split(m.__file__)
|
|
|
|
self.dirname = os.path.abspath(dirname)
|
|
|
|
|
|
|
|
def path(self, path):
|
|
|
|
"""
|
|
|
|
Returns a path to the package data housed at 'path' under this
|
|
|
|
module.Path can be a path to a file, or to a directory.
|
|
|
|
|
|
|
|
This function will raise ValueError if the path does not exist.
|
|
|
|
"""
|
|
|
|
fullpath = os.path.join(self.dirname, path)
|
|
|
|
if not os.path.exists(fullpath):
|
2015-05-30 00:03:28 +00:00
|
|
|
raise ValueError("dataPath: %s does not exist." % fullpath)
|
2010-02-16 04:09:07 +00:00
|
|
|
return fullpath
|
2011-08-02 04:14:33 +00:00
|
|
|
pkg_data = Data(__name__)
|
2010-02-16 04:09:07 +00:00
|
|
|
|
|
|
|
|
2011-03-15 00:05:33 +00:00
|
|
|
class LRUCache:
|
|
|
|
"""
|
2015-03-22 08:00:41 +00:00
|
|
|
A simple LRU cache for generated values.
|
2011-03-15 00:05:33 +00:00
|
|
|
"""
|
2015-05-30 00:03:28 +00:00
|
|
|
|
2011-03-15 00:05:33 +00:00
|
|
|
def __init__(self, size=100):
|
|
|
|
self.size = size
|
2015-03-22 08:00:41 +00:00
|
|
|
self.cache = {}
|
2015-05-30 00:03:28 +00:00
|
|
|
self.cacheList = []
|
2015-03-22 08:00:41 +00:00
|
|
|
|
|
|
|
def get(self, gen, *args):
|
|
|
|
"""
|
|
|
|
gen: A (presumably expensive) generator function. The identity of
|
|
|
|
gen is NOT taken into account by the cache.
|
|
|
|
*args: A list of immutable arguments, used to establish identiy by
|
|
|
|
*the cache, and passed to gen to generate values.
|
|
|
|
"""
|
2015-05-30 00:03:28 +00:00
|
|
|
if args in self.cache:
|
2015-03-22 08:00:41 +00:00
|
|
|
self.cacheList.remove(args)
|
|
|
|
self.cacheList.insert(0, args)
|
|
|
|
return self.cache[args]
|
|
|
|
else:
|
|
|
|
ret = gen(*args)
|
|
|
|
self.cacheList.insert(0, args)
|
|
|
|
self.cache[args] = ret
|
|
|
|
if len(self.cacheList) > self.size:
|
|
|
|
d = self.cacheList.pop()
|
|
|
|
self.cache.pop(d)
|
|
|
|
return ret
|
2011-03-15 00:05:33 +00:00
|
|
|
|
2011-08-03 10:38:23 +00:00
|
|
|
|
2012-02-08 05:25:00 +00:00
|
|
|
def clean_hanging_newline(t):
|
|
|
|
"""
|
|
|
|
Many editors will silently add a newline to the final line of a
|
|
|
|
document (I'm looking at you, Vim). This function fixes this common
|
|
|
|
problem at the risk of removing a hanging newline in the rare cases
|
|
|
|
where the user actually intends it.
|
|
|
|
"""
|
2012-08-25 00:21:45 +00:00
|
|
|
if t and t[-1] == "\n":
|
2012-02-08 05:25:00 +00:00
|
|
|
return t[:-1]
|
|
|
|
return t
|
|
|
|
|
|
|
|
|
2011-09-09 03:27:31 +00:00
|
|
|
def parse_size(s):
|
|
|
|
"""
|
|
|
|
Parses a size specification. Valid specifications are:
|
2012-01-20 23:43:00 +00:00
|
|
|
|
2011-09-09 03:27:31 +00:00
|
|
|
123: bytes
|
|
|
|
123k: kilobytes
|
|
|
|
123m: megabytes
|
|
|
|
123g: gigabytes
|
|
|
|
"""
|
|
|
|
if not s:
|
|
|
|
return None
|
|
|
|
mult = None
|
|
|
|
if s[-1].lower() == "k":
|
|
|
|
mult = 1024**1
|
|
|
|
elif s[-1].lower() == "m":
|
|
|
|
mult = 1024**2
|
|
|
|
elif s[-1].lower() == "g":
|
|
|
|
mult = 1024**3
|
|
|
|
|
|
|
|
if mult:
|
|
|
|
s = s[:-1]
|
|
|
|
else:
|
|
|
|
mult = 1
|
|
|
|
try:
|
|
|
|
return int(s) * mult
|
|
|
|
except ValueError:
|
2015-05-30 00:03:28 +00:00
|
|
|
raise ValueError("Invalid size specification: %s" % s)
|
2012-05-26 01:10:31 +00:00
|
|
|
|
|
|
|
|
|
|
|
def safe_subn(pattern, repl, target, *args, **kwargs):
|
|
|
|
"""
|
|
|
|
There are Unicode conversion problems with re.subn. We try to smooth
|
|
|
|
that over by casting the pattern and replacement to strings. We really
|
|
|
|
need a better solution that is aware of the actual content ecoding.
|
|
|
|
"""
|
|
|
|
return re.subn(str(pattern), str(repl), target, *args, **kwargs)
|