patrick/WoofWare.PawPrint
1
0
Fork 0
mirror of https://github.com/Smaug123/WoofWare.PawPrint synced 2025-10-17 19:38:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reentrant locking (#51)

Browse Source
This commit is contained in:
Patrick Stevens
2025-06-15 21:28:56 +01:00
committed by GitHub
parent 8b49b190ea
commit 3b1f916743
3 changed files with 23 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
WoofWare.PawPrint/ExternImplementations/System.Threading.Monitor.fs
View File

@@ -64,10 +64,14 @@ module System_Threading_Monitor =
failwith "TODO: throw ArgumentNullException"
| EvalStackValue.ManagedPointer (ManagedPointerSource.Heap addr) ->
match IlMachineState.getSyncBlock addr state with
| None -> state |> IlMachineState.setSyncBlock addr (Some currentThread)
| Some _ ->
failwith
"TODO: somehow need to block on the monitor; also what happens if this thread already has the lock?"
| SyncBlock.Free ->
state |> IlMachineState.setSyncBlock addr (SyncBlock.Locked (currentThread, 1))
| SyncBlock.Locked (thread, counter) ->
if thread = currentThread then
state
|> IlMachineState.setSyncBlock addr (SyncBlock.Locked (thread, counter + 1))
else
failwith "TODO: somehow need to block on the monitor"
| EvalStackValue.ManagedPointer (ManagedPointerSource.LocalVariable _) ->
failwith "TODO: local variable holds object to lock"
| lockObj -> failwith $"TODO: lock object in Monitor.ReliableEnter was {lockObj}"
@@ -75,11 +79,11 @@ module System_Threading_Monitor =
// Set result to True
let state =
match outVar with
| Null -> failwith "logic error"
| LocalVariable (sourceThread, methodFrame, whichVar) ->
| ManagedPointerSource.Null -> failwith "logic error"
| ManagedPointerSource.LocalVariable (sourceThread, methodFrame, whichVar) ->
state
|> IlMachineState.setLocalVariable sourceThread methodFrame whichVar (CliType.OfBool true)
| Heap addr -> failwith "todo: managed heap"
| ManagedPointerSource.Heap addr -> failwith "todo: managed heap"
(state, WhatWeDid.Executed) |> ExecutionResult.Stepped
@@ -95,8 +99,14 @@ module System_Threading_Monitor =
failwith "TODO: throw ArgumentNullException"
| EvalStackValue.ManagedPointer (ManagedPointerSource.Heap addr) ->
match IlMachineState.getSyncBlock addr state with
| Some t when t = thread -> state |> IlMachineState.setSyncBlock addr None
| _ -> failwith "TODO: throw SynchronizationLockException"
| SyncBlock.Free -> failwith "TODO: throw SynchronizationLockException"
| SyncBlock.Locked (holdingThread, count) ->
if thread <> holdingThread then
failwith "TODO: throw SynchronizationLockException"
else if count = 1 then
IlMachineState.setSyncBlock addr SyncBlock.Free state
else
IlMachineState.setSyncBlock addr (SyncBlock.Locked (holdingThread, count - 1)) state
| EvalStackValue.ManagedPointer (ManagedPointerSource.LocalVariable _) ->
failwith "TODO: local variable holds object to lock"
| lockObj -> failwith $"TODO: lock object in Monitor.ReliableEnter was {lockObj}"

2
WoofWare.PawPrint/IlMachineState.fs
View File

@@ -857,7 +857,7 @@ module IlMachineState =
{
Fields = Map.ofList fields
Type = TypeInfoCrate.make typeInfo
SyncBlock = None
SyncBlock = SyncBlock.Free
}
let alloc, heap = state.ManagedHeap |> ManagedHeap.AllocateNonArray o

4
WoofWare.PawPrint/ManagedHeap.fs
View File

@@ -2,7 +2,9 @@ namespace WoofWare.PawPrint
open System.Collections.Immutable
type SyncBlock = ThreadId option
type SyncBlock =
| Free
| Locked of lockingThread : ThreadId * reentrancyCount : int
type AllocatedNonArrayObject =
{