Test.DejaFu.Conc.Internal.Memory

Operations over CRefs and MVars. This module is NOT considered to form part of the public interface of this library.

Relaxed memory operations over CRefs are implemented with an explicit write buffer: one per thread for TSO, and one per thread/variable combination for PSO. Unsynchronised writes append to this buffer, and periodically separate threads commit from these buffers to the "actual" CRef.

This model comes from /Dynamic Partial Order Reduction for Relaxed Memory Models/, N. Zhang, M. Kusano, and C. Wang (2015).

Manipulating CRefs

newtype WriteBuffer r

In non-sequentially-consistent memory models, non-synchronised writes get buffered.

The CRefId parameter is only used under PSO. Under TSO each thread has a single buffer.

Constructors

WriteBuffer

Fields

• buffer :: Map (ThreadId, Maybe CRefId) (Seq (BufferedWrite r))

data BufferedWrite r where

A buffered write is a reference to the variable, and the value to write. Universally quantified over the value type so that the only thing which can be done with it is to write it to the reference.

Constructors

BufferedWrite :: ThreadId -> CRef r a -> a -> BufferedWrite r

emptyBuffer :: WriteBuffer r

An empty write buffer.

bufferWrite :: MonadRef r n => WriteBuffer r -> (ThreadId, Maybe CRefId) -> CRef r a -> a -> n (WriteBuffer r)

Add a new write to the end of a buffer.

commitWrite :: MonadRef r n => WriteBuffer r -> (ThreadId, Maybe CRefId) -> n (WriteBuffer r)

Commit the write at the head of a buffer.

readCRef :: MonadRef r n => CRef r a -> ThreadId -> n a

Read from a CRef, returning a newer thread-local non-committed write if there is one.

readForTicket :: MonadRef r n => CRef r a -> ThreadId -> n (Ticket a)

Read from a CRef, returning a Ticket representing the current view of the thread.

casCRef :: MonadRef r n => CRef r a -> ThreadId -> Ticket a -> a -> n (Bool, Ticket a)

Perform a compare-and-swap on a CRef if the ticket is still valid. This is strict in the "new" value argument.

readCRefPrim :: MonadRef r n => CRef r a -> ThreadId -> n (a, Integer)

Read the local state of a CRef.

writeImmediate :: MonadRef r n => CRef r a -> a -> n ()

Write and commit to a CRef immediately, clearing the update map and incrementing the write count.

writeBarrier :: MonadRef r n => WriteBuffer r -> n ()

Flush all writes in the buffer.

addCommitThreads :: WriteBuffer r -> Threads n r -> Threads n r

Add phantom threads to the thread list to commit pending writes.

delCommitThreads :: Threads n r -> Threads n r

Remove phantom threads.

Manipulating MVars

putIntoMVar :: MonadRef r n => MVar r a -> a -> Action n r -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Put into a MVar, blocking if full.

tryPutIntoMVar :: MonadRef r n => MVar r a -> a -> (Bool -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Try to put into a MVar, not blocking if full.

readFromMVar :: MonadRef r n => MVar r a -> (a -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Read from a MVar, blocking if empty.

tryReadFromMVar :: MonadRef r n => MVar r a -> (Maybe a -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Try to read from a MVar, not blocking if empty.

takeFromMVar :: MonadRef r n => MVar r a -> (a -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Take from a MVar, blocking if empty.

tryTakeFromMVar :: MonadRef r n => MVar r a -> (Maybe a -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Try to take from a MVar, not blocking if empty.

mutMVar :: MonadRef r n => Bool -> MVar r a -> a -> (Bool -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Mutate a MVar, in either a blocking or nonblocking way.

seeMVar :: MonadRef r n => Bool -> Bool -> MVar r a -> (Maybe a -> Action n r) -> ThreadId -> Threads n r -> n (Bool, Threads n r, [ThreadId])

Read a MVar, in either a blocking or nonblocking way.