robstewart57

mtype = { PING , PONG , INFO } ;

typedef Node {
  chan inChan = [50] of {mtype } ;
  bool receivedInfo;
};
Node nodes[2];

active proctype Master()  {
  

robstewart57

mtype = { FISH , RESCHEDULE , SCHEDULE , SCHEDULEREQ , SCHEDULEAUTH , ACK , NOWORK , SENDFAILED , PING } ; // message payload types
mtype = { ONNODE , INTRANSITION }; // spark.status types

typedef Node {
  chan inChan = [50] of {mtype, chan } ;
  bool hasSpark;
  bool waitingFish;
  bool waitingSchedAuth;
  bool dead;
};

robstewart57

{-# LANGUAGE DeriveDataTypeable #-}

import Control.Concurrent (threadDelay)
import Control.Exception (Exception,throw)
import Control.Monad (void)
import Control.Concurrent.Async (Async,race,wait,withAsync)
import Data.Typeable (Typeable)

data ThreadTimeoutException = ThreadTimeoutException
     deriving (Show, Typeable)

robstewart57

Prelude> data D = D Int
Prelude> let f (D i) = "ok"
Prelude> f undefined
"*** Exception: Prelude.undefined
Prelude> newtype D = D Int
Prelude> let f (D i) = "ok"
Prelude> f undefined
"ok"