Skip to content

Instantly share code, notes, and snippets.

@liath

liath/YAS3FS-PR-133-test.py

Created March 26, 2018 22:57
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save liath/49fece9fc6dca640a4d9ecedb7b3c4a7 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save liath/49fece9fc6dca640a4d9ecedb7b3c4a7 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. liath created this gist Mar 26, 2018.
    51 changes: 51 additions & 0 deletions YAS3FS-PR-133-test.py
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,51 @@
    from shutil import rmtree
    from tempfile import mkdtemp
    from threading import Thread
    from time import sleep
    from unittest import TestCase
    from yas3fs import FSCache


    class testPR133(TestCase):
    """Per https://github.com/danilop/yas3fs/pull/133 \
    Fix deadlock when a path is re-locked while the cache is locked globally"""

    def setUp(self):
    self.tempdir = mkdtemp(prefix='yas3fs-pr133-test-')
    self.cache = FSCache(self.tempdir)

    def tearDown(self):
    rmtree(self.tempdir)

    def test_deadlock(self):
    def getGlobalLock():
    with self.cache.lock:
    print('locked global')
    while(True):
    sleep(10)

    def getPathLock():
    with self.cache.get_lock('pr133'):
    print('locked local')
    self.cache.entries['pr133'] = {}
    self.cache.entries['pr133']['lock'] = self.cache.new_locks['pr133']
    del self.cache.new_locks['pr133']
    sleep(2)
    print('attempting to relock local')
    with self.cache.get_lock('pr133'):
    print('relocked local')

    # lock a path
    llock = Thread(target=getPathLock)
    llock.start()
    sleep(1)

    # lock the world
    glock = Thread(target=getGlobalLock)
    glock.setDaemon(True)
    glock.start()

    # wait a bit
    llock.join(timeout=3)
    # see if we've encountered a stalemate
    self.assertFalse(llock.isAlive(), 'Attempt to relock path failed')