black format

Author: hanke0

benchmarks/benchmark_funcs.py

@@ -8,7 +8,7 @@ def benchmark_int8_to_datetime():
 
 
 def rand_int():
-    return random.randint(0, 0xffffffff)
+    return random.randint(0, 0xFFFFFFFF)
 
 
 @benchmark_setup(i=rand_int)

benchmarks/benchmark_strhash.py

@@ -13,19 +13,19 @@ def benchmark_strhash_default_method(string):
 
 @benchmark_setup(string=new_str)
 def benchmark_strhash_fnv1a(string):
-    ctools.strhash(string, 'fnv1a')
+    ctools.strhash(string, "fnv1a")
 
 
 @benchmark_setup(string=new_str)
 def benchmark_strhash_fnv1(string):
-    ctools.strhash(string, 'fnv1')
+    ctools.strhash(string, "fnv1")
 
 
 @benchmark_setup(string=new_str)
 def benchmark_strhash_djb2(string):
-    ctools.strhash(string, 'djb2')
+    ctools.strhash(string, "djb2")
 
 
 @benchmark_setup(string=new_str)
 def benchmark_strhash_murmur(string):
-    ctools.strhash(string, 'murmur')
+    ctools.strhash(string, "murmur")

ctools/__init__.py

@@ -22,4 +22,3 @@
 
 test = Tester(__name__)
 del Tester
-

ctools/_tester.py

@@ -21,21 +21,32 @@
 
 def _show_info(test_args):
     import ctools
+
     title = "Testing Information"
     print("\n-" * len(title))
     print(title)
     print("-" * len(title))
     print("Python: ", sys.executable)
-    print('Ctools:', ctools.__version__, "(debug build)" if ctools.build_with_debug() else "")
-    print("Arguments:", " ".join(test_args), '\n')
+    print(
+        "Ctools:",
+        ctools.__version__,
+        "(debug build)" if ctools.build_with_debug() else "",
+    )
+    print("Arguments:", " ".join(test_args), "\n")
 
 
 class Tester(object):
     def __init__(self, module_name):
         self.module_name = module_name
 
-    def __call__(self, extra_argv=None, coverage=False, include_sys_argv=True, tests=None,
-                 verbose=True):
+    def __call__(
+        self,
+        extra_argv=None,
+        coverage=False,
+        include_sys_argv=True,
+        tests=None,
+        verbose=True,
+    ):
         import pytest
 
         module = sys.modules[self.module_name]
@@ -55,11 +66,11 @@ def __call__(self, extra_argv=None, coverage=False, include_sys_argv=True, tests
             test_args.extend(sys.argv[1:])
 
         test_args += ["--pyargs"] + list(tests)
-        test_args += ["--deselect", os.path.join(here, 'tests', '_bases.py')]
+        test_args += ["--deselect", os.path.join(here, "tests", "_bases.py")]
 
         if verbose:
             for i in test_args:
-                if i.startswith('-v'):
+                if i.startswith("-v"):
                     break
             else:
                 test_args.append("-vvv")
@@ -74,11 +85,13 @@ def __call__(self, extra_argv=None, coverage=False, include_sys_argv=True, tests
         return code
 
 
-_memory_report = namedtuple('MemoryReport', "exc_code,cycles,max_rss,last_rss,max_incr,cum_incr,escaped")
+_memory_report = namedtuple(
+    "MemoryReport", "exc_code,cycles,max_rss,last_rss,max_incr,cum_incr,escaped"
+)
 
 
 def memory_leak_test(
-    test, max_rss=None, max_incr=None, cycles=None, multi=10, log_prefix="", log=True,
+    test, max_rss=None, max_incr=None, cycles=None, multi=10, log_prefix="", log=True
 ):
     import time
     import psutil
@@ -90,7 +103,7 @@ def memory_leak_test(
 
     pid = os.getpid()
     process = psutil.Process(pid)
-    print_('PID =', pid)
+    print_("PID =", pid)
 
     cycle_count = 1
     last_rss = None
@@ -124,15 +137,17 @@ def memory_leak_test(
                         incr_limit = multi * cum_incr
 
             print_(log_prefix, end=" ")
-            print_(f"loop={cycle_count}, escaped={spend}, rss={rss_bytes:,}, increase={incr:,}")
+            print_(
+                f"loop={cycle_count}, escaped={spend}, rss={rss_bytes:,}, increase={incr:,}"
+            )
 
             if rss_limit and rss_bytes > rss_limit:
                 print_(f"rss {rss_bytes:,} touch roof {rss_limit:,}")
                 exc_code = 1
                 break
 
             if incr_limit and cum_incr > incr_limit:
-                print_(f'rss increase {cum_incr:,} touch roof {incr_limit:,}')
+                print_(f"rss increase {cum_incr:,} touch roof {incr_limit:,}")
                 exc_code = 1
                 break
 
@@ -145,8 +160,14 @@ def memory_leak_test(
                 break
 
     except KeyboardInterrupt:
-        print_(_memory_report(exc_code, cycle_count, max_rss, last_rss, max_incr, cum_incr, escaped))
+        print_(
+            _memory_report(
+                exc_code, cycle_count, max_rss, last_rss, max_incr, cum_incr, escaped
+            )
+        )
         raise
-    report = _memory_report(exc_code, cycle_count, max_rss, last_rss, max_incr, cum_incr, escaped)
+    report = _memory_report(
+        exc_code, cycle_count, max_rss, last_rss, max_incr, cum_incr, escaped
+    )
     print_(report)
     return report

ctools/tests/_bases.py

@@ -21,7 +21,6 @@ def not_raise(exc=Exception):
 
 
 class TestCase(unittest.TestCase):
-
     def assertRefEqual(self, a, b, msg=None):
         self.assertEqual(sys.getrefcount(a), sys.getrefcount(b), msg=msg)
 
@@ -52,7 +51,6 @@ def map_set_random(mp):
 
 
 class DefaultMap(dict):
-
     def setnx(self, k, ca):
         if k not in self:
             v = ca()
@@ -287,7 +285,7 @@ def test_normal_update(self):
         self.assertRefEqual(dkey, ckey)
         self.assertRefEqual(dval, cval)
         self.assertEqual(len(cache), len(mp))
-        self.assertIn('a', cache)
+        self.assertIn("a", cache)
 
     def test_normal_setdefault(self):
         cache = self.create_map()
@@ -340,7 +338,7 @@ def test_normal_clear(self):
         dkey, dval = map_set_random(mp)
         cache.clear()
         mp.clear()
-        self.assertEqual(len(cache), 0, msg='cache map is not empty after clear')
+        self.assertEqual(len(cache), 0, msg="cache map is not empty after clear")
         self.assertRefEqual(ckey, dkey)
         self.assertRefEqual(cval, dval)
 
@@ -365,5 +363,5 @@ def test_error_set(self):
         self.assertRefEqual(cval, dval)
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     unittest.main()

ctools/tests/test_cachemap.py

@@ -7,7 +7,6 @@
 
 
 class TestCacheMapEntry(BaseTestEntry):
-
     def create_entry(self):
         return ctools.CacheMapEntry(uuid.uuid1())
 
@@ -20,19 +19,18 @@ def set_random(mp):
 
 
 class TestCacheMap(BaseTestMapLike):
-
     def create_map(self):
         return ctools.CacheMap(257)
 
     def test_get_set(self):
         d = ctools.CacheMap(2)
-        d['a'] = 1
-        d['c'] = 2
-        d['e'] = 3
+        d["a"] = 1
+        d["c"] = 2
+        d["e"] = 3
         self.assertEqual(len(d), 2)
 
         for i in range(10):
-            self.assertEqual(d['c'], 2)
+            self.assertEqual(d["c"], 2)
 
     def test_len(self):
         for m in range(254, 1024):
@@ -47,5 +45,5 @@ def test_len(self):
 
 del BaseTestEntry, BaseTestMapLike
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     unittest.main()

ctools/tests/test_function.py

@@ -7,7 +7,6 @@
 
 
 class TestFunction(unittest.TestCase):
-
     def test_int8_to_datetime(self):
         start = datetime(2000, 1, 1)
         for i in range(1024):
@@ -21,17 +20,11 @@ def test_int8_to_datetime(self):
     def test_jump_consistent_hash(self):
         count = 1024
         bucket = 100
-        m = {
-            i: ctools.jump_consistent_hash(i, bucket)
-            for i in range(count)
-        }
+        m = {i: ctools.jump_consistent_hash(i, bucket) for i in range(count)}
         for i in range(count):
             b = ctools.jump_consistent_hash(i, bucket)
             self.assertEqual(m[i], b)
-        n = {
-            i: ctools.jump_consistent_hash(i, bucket + 1)
-            for i in range(count)
-        }
+        n = {i: ctools.jump_consistent_hash(i, bucket + 1) for i in range(count)}
         equal_count = 0
         for i in range(count):
             if m[i] == n[i]:
@@ -54,10 +47,10 @@ def test_strhash(self):
             self.assertEqual(b, ctools.strhash(us, meth))
 
         self.assertEqual(ctools.strhash(s), ctools.strhash(s, "fnv1a"))
-        self.assertEqual(ctools.strhash(us), ctools.strhash(us, 'fnv1a'))
+        self.assertEqual(ctools.strhash(us), ctools.strhash(us, "fnv1a"))
 
         self.assertNotEqual(ctools.strhash(s), ctools.strhash(s, "fnv1"))
         self.assertNotEqual(ctools.strhash(s), ctools.strhash(s, "fnv1"))
 
         with self.assertRaises(TypeError):
-            ctools.strhash(s, method='fnv1a')
+            ctools.strhash(s, method="fnv1a")

ctools/tests/test_ttlcache.py

@@ -8,7 +8,6 @@
 
 
 class TestTTLCacheEntry(BaseTestEntry):
-
     def create_entry(self):
         return ctools.TTLCacheEntry(uuid.uuid1(), 1024)
 
@@ -21,7 +20,6 @@ def set_random(mp):
 
 
 class TestTTLCache(BaseTestMapLike):
-
     def create_map(self):
         return ctools.TTLCache(1024)
 
@@ -48,5 +46,5 @@ def test_expire(self):
 
 del BaseTestEntry, BaseTestMapLike
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     unittest.main()

setup.py

@@ -26,16 +26,12 @@ def source(*args):
     return [os.path.join("src", *args)]
 
 
-if os.getenv('CTOOLS_DEBUG', '').upper() == "ON":
-    print('---------------CTOOLS DEBUG ON------------------')
-    extra_extension_args = dict(
-        undef_macros=["NDEBUG"]
-    )
+if os.getenv("CTOOLS_DEBUG", "").upper() == "ON":
+    print("---------------CTOOLS DEBUG ON------------------")
+    extra_extension_args = dict(undef_macros=["NDEBUG"])
 else:
-    print('---------------CTOOLS DEBUG OFF------------------')
-    extra_extension_args = dict(
-        define_macros=[('NDEBUG', '1')]
-    )
+    print("---------------CTOOLS DEBUG OFF------------------")
+    extra_extension_args = dict(define_macros=[("NDEBUG", "1")])
 
 
 def find_version():
@@ -44,7 +40,7 @@ def find_version():
         value = f.read()
         exec(value, d, d)
 
-    return d['__version__']
+    return d["__version__"]
 
 
 extensions = [
@@ -53,7 +49,7 @@ def find_version():
     Extension("_ctools_ttlcache", source("ctools_ttlcache.c"), **extra_extension_args),
 ]
 
-with io.open('README.rst', 'rt', encoding='utf8') as f:
+with io.open("README.rst", "rt", encoding="utf8") as f:
     readme = f.read()
 
 setup(
@@ -68,14 +64,14 @@ def find_version():
         "Documentation": "https://github.com/ko-han/python-ctools/wiki",
         "Source Code": "https://github.com/ko-han/python-ctools",
     },
-    license='Apache License 2.0',
+    license="Apache License 2.0",
     long_description=readme,
-    long_description_content_type='text/x-rst',
+    long_description_content_type="text/x-rst",
     python_requires=">=3",
     include_package_data=True,
     zip_safe=False,
     ext_modules=extensions,
-    packages=find_packages(include=['ctools', 'ctools.*']),
+    packages=find_packages(include=["ctools", "ctools.*"]),
     classifiers=[
         "Programming Language :: C",
         "Programming Language :: Python :: 3 :: Only",

src/ctools_ttlcache.c

@@ -596,7 +596,10 @@ static PyMethodDef TTLCache_methods[] = {
   { "clear", (PyCFunction)TTLCache_clear, METH_NOARGS, NULL },
   { "setnx", (PyCFunction)TTLCache_setnx, METH_VARARGS | METH_KEYWORDS, NULL },
   { "_storage", (PyCFunction)TTLCache__storage, METH_NOARGS, NULL },
-  { "get_default_ttl", (PyCFunction)TTLCache_get_default_ttl, METH_NOARGS, NULL },
+  { "get_default_ttl",
+    (PyCFunction)TTLCache_get_default_ttl,
+    METH_NOARGS,
+    NULL },
   { NULL, NULL, 0, NULL } /* Sentinel */
 };
 

tools/genapidoc.py

@@ -4,12 +4,12 @@
 
 project_root = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 
-with open(os.path.join(project_root, 'ctools', "__init__.pyi")) as f:
+with open(os.path.join(project_root, "ctools", "__init__.pyi")) as f:
     s = f.read()
 
 doc = re.split("##----*start----*##", s, 1, re.MULTILINE)[1].lstrip()
 
-api_list = [i for i in re.split('#- api', doc) if i]
+api_list = [i for i in re.split("#- api", doc) if i]
 
 des_regex = re.compile("#- description:(?P<des>.*)")
 
@@ -19,15 +19,15 @@
     match = des_regex.search(api)
     if not match:
         lines.append("```python\n{}\n```".format(api.strip()))
-        lines.append('\n')
+        lines.append("\n")
     else:
-        description = match.group('des').strip()
+        description = match.group("des").strip()
         if description:
             lines.append("* {}\n".format(description))
         api = des_regex.sub("", api).strip()
         lines.append("```python\n{}\n```".format(api))
         lines.append("\n\n\n")
 
 
-with open(os.path.join(project_root, 'doc', 'api.md'), 'wt') as f:
+with open(os.path.join(project_root, "doc", "api.md"), "wt") as f:
     f.writelines(lines)