diff options
Diffstat (limited to 'test/fs.py')
| -rw-r--r-- | test/fs.py | 19 |
1 files changed, 18 insertions, 1 deletions
@@ -217,6 +217,23 @@ def discovery(binary, embedded=False): client.write('/exec', b'Msg woken\n') reader.join(5) assert woke and woke[0].endswith(b' woken\n'), woke + # A pane's ctl takes acme's lock: a second open's lock waits until + # the holder unlocks, and nothing else waits on it meanwhile. + with Client(address) as other: + mine = client.open(f'/pane/{first}/ctl', 2) + client.rpc(118, struct.pack('<IQI', mine, 0, 5) + b'lock\n') + theirs = other.open(f'/pane/{first}/ctl', 1) + locked = [] + locker = threading.Thread(target=lambda: locked.append(other.rpc(118, struct.pack('<IQI', theirs, 0, 5) + b'lock\n')), daemon=True) + locker.start() + time.sleep(.2) + assert not locked + client.write(f'/pane/{first}/addr', b'#0') + client.rpc(118, struct.pack('<IQI', mine, 0, 7) + b'unlock\n') + locker.join(5) + assert locked, 'a lock waiting on another open goes once it unlocks' + client.close(mine) + other.close(theirs) assert set(client.list('/pane')) == {'new', str(fixture), str(first), str(second)} client.write(f'/pane/{first}/body', b'first pane', truncate=True) assert client.read(f'/pane/{first}/body') == b'first pane' @@ -287,7 +304,7 @@ def discovery(binary, embedded=False): assert client.read('/src/pardes.zig').startswith(b'const std') assert client.stat('/src/pardes.zig')['mode'] == 0o444 assert b'pub const Pardes' in client.read(f'/pane/{look(client, "/virtual/src/pardes.zig")}/body') - print('9P discovery: listing/stat/find are inert; new, remove, look, exec, name, sel and log behave') + print('9P discovery: listing/stat/find are inert; new, remove, look, exec, name, sel, log and ctl lock behave') def run_file(binary): |