Asyncoro

This module provides basic support for asynchronous communication and computation of secret-shared values.

Documentation

createConnections :: Int -> [Party] -> IO [Party]

Open connections with other parties, if any.

send :: Int -> ByteString -> Party -> SIO ()

Send payload labeled with pc to the peer.

Message format consists of three parts:

1. pc (8 bytes signed int)
2. payload_size (4 bytes unsigned int)
3. payload (byte string of length payload_size).

receive :: Int -> Party -> SIO (MVar ByteString)

Receive payload labeled with given pc from the peer.

class Gather a where

Transform SecureTypes into FiniteField by reading the future MVar share that contains a FiniteField (blocking).

Associated Types

type Result a :: *

Methods

gather :: a -> SIO (Result a)

Instances

Gather SecureTypes

Defined in Asyncoro

Associated Types

type Result SecureTypes

Methods

gather :: SecureTypes -> SIO (Result SecureTypes)

Gather a => Gather [a]

Defined in Asyncoro

Associated Types

type Result [a]

Methods

gather :: [a] -> SIO (Result [a])

(Gather a, Gather b) => Gather (a, b)

Defined in Asyncoro

Associated Types

type Result (a, b)

Methods

gather :: (a, b) -> SIO (Result (a, b))

(Gather a, Gather b, Gather c) => Gather (a, b, c)

Defined in Asyncoro

Associated Types

type Result (a, b, c)

Methods

gather :: (a, b, c) -> SIO (Result (a, b, c))

async :: SIO a -> SIO (MVar a)

forkIO the action monad asynchronously and return future MVar. Provide the given state monad with its own program counter space.

asyncList :: Int -> SIO [a] -> SIO [MVar a]

asyncListList :: Int -> Int -> SIO [[a]] -> SIO [[MVar a]]

await :: MVar a -> SIO a

Read the value from the future MVar (blocking).

incPC :: SIO Int

increment program counter in state.

decreaseBarrier :: Barrier -> IO ()