aljaz/Interlace
1
1
Fork 0
mirror of https://github.com/codingo/Interlace.git synced 2025-12-17 23:04:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixed blocker bug

Browse Source
This commit is contained in:
Joshua Ogunyinka
2019-08-20 13:14:39 +01:00
parent 3673de2fcc
commit 764739f2cb
3 changed files with 17 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Interlace/lib/core/input.py
View File

@@ -112,9 +112,11 @@ class InputHelper(object):
if task_name == new_task_name:
return task_block
# otherwise pre-process all the commands in this new `new_task_name` block
for task in InputHelper._pre_process_commands(command_list, new_task_name, False):
tasks = InputHelper._pre_process_commands(command_list, new_task_name, False)
for task in tasks:
task_block.append(task)
sibling = task
if len(tasks) > 0:
sibling = tasks[-1]
continue
else:
# if a blocker is encountered, all commands following the blocker must wait until the last
@@ -126,10 +128,10 @@ class InputHelper(object):
# if we're in the global scope and there was a previous _blocker_ encountered, we wait for the last
# child of the block
if is_global_task and global_task:
task.wait_for(global_task.get_lock())
task.wait_for(task_block)
# all but the first command in a block scope wait for its predecessor
elif sibling and not is_global_task:
task.wait_for(sibling.get_lock())
task.wait_for([sibling])
task_block.append(task)
sibling = task
return task_block

13
Interlace/lib/threader.py
View File

@@ -9,7 +9,7 @@ class Task(object):
def __init__(self, command):
self.task = command
self.self_lock = None
self.sibling_lock = None
self.sibling_locks = []
def __cmp__(self, other):
return self.name() == other.name()
@@ -20,21 +20,22 @@ class Task(object):
def clone(self):
new_task = Task(self.task)
new_task.self_lock = self.self_lock
new_task.sibling_lock = self.sibling_lock
new_task.sibling_locks = self.sibling_locks
return new_task
def replace(self, old, new):
self.task = self.task.replace(old, new)
def run(self, t=False):
if self.sibling_lock:
self.sibling_lock.wait()
for lock in self.sibling_locks:
lock.wait()
self._run_task(t)
if self.self_lock:
self.self_lock.set()
def wait_for(self, _lock):
self.sibling_lock = _lock
def wait_for(self, siblings):
for sibling in siblings:
self.sibling_locks.append(sibling.get_lock())
def name(self):
return self.task

4
foo.test
View File

@@ -13,4 +13,8 @@ echo _target_/b/
echo _target_/re/
_block:file_
_blocker_
ping 127.0.0.1 -n 10 > nul
ping 127.0.0.1 -n 10 > nul && echo "sleepy"
ping 127.0.0.1 -n 5 > nul && echo "test1"
_blocker_
echo "Done"