Commit ce41dc0c authored by Yiannis Tsiouris's avatar Yiannis Tsiouris

Re-format exports

parent 892445d0
......@@ -8,7 +8,8 @@ module Credit( credit
, zero
, one
, is_zero
, is_one) where
, is_one
) where
-- An *atomic credit* is represented as a non-negative integer k;
-- it stands for the credit 1/{2^k}.
......
--
-- orbit-int master (controlling orbit computation)
--
module Master () where
module Master where
import Control.Distributed.Process (Process, ProcessId, match,
receiveWait)
......
--
-- orbit-int sequential implementation
--
module Sequential(Generator
, orbit) where
module Sequential( Generator
, orbit
) where
import Data.Dequeue (BankersDequeue, fromList, popFront, pushBack)
import Data.Hashable (hash)
......
......@@ -20,7 +20,8 @@ module Table( Freq
, avg_nonempty_freq
, freq_to_stat
, freq_from_stat
, fill_deg) where
, fill_deg
) where
import Data.Array (Array, elems, listArray, (!), (//))
import Types (Freq, Stats, VTable, Vertex)
......
--
-- orbit-int types
--
module Types ( Ct(..)
, Generator
, Freq
, HostInfo(..)
, MaybeHosts(..)
, ParConf
, SeqConf
, Stats
, Vertex
, VTable) where
module Types( Ct(..)
, Generator
, Freq
, HostInfo(..)
, MaybeHosts(..)
, ParConf
, SeqConf
, Stats
, Vertex
, VTable) where
import Control.Distributed.Process (NodeId, ProcessId)
import Data.Array (Array)
......@@ -31,7 +31,7 @@ type ParConf = ([Generator], ProcessId, [ProcessId], Int, Int, Bool)
data Ct = Ct {
verts_recvd :: Int -- #vertices received by this server so far
, credit_retd :: Int -- #times server has returned credit to master
, min_atomic_credit :: Int -- minimal atomic credit received so far
, min_atomic_credit :: Int -- minimal atomic credit received so far
, last_event :: Int -- time stamp [ms] of most recent event
, init_idle :: Int -- idle time [ms] between init recv first vertex
, tail_idle :: Int -- idle time [ms] between send last vertex and dump
......
--
-- orbit-int worker
--
module Worker ( defaultCt
, now
, worker_stats
, verts_recvd_from_stat
, credit_retd_from_stat
, min_atomic_credit_from_stat
, init_idle_from_stat
, tail_idle_from_stat
, max_idle_from_stat
) where
module Worker( defaultCt
, now
, worker_stats
, verts_recvd_from_stat
, credit_retd_from_stat
, min_atomic_credit_from_stat
, init_idle_from_stat
, tail_idle_from_stat
, max_idle_from_stat
) where
import Control.Distributed.Process (NodeId)
import Table (freq_to_stat)
import Types (Ct (..), Freq, Stats)
defaultCt = Ct {
verts_recvd = 0
, credit_retd = 0
, min_atomic_credit = 0
, last_event = now
, init_idle = -1
, tail_idle = -1
, max_idle = -1
}
defaultCt :: Ct
defaultCt = Ct { verts_recvd = 0
, credit_retd = 0
, min_atomic_credit = 0
, last_event = now
, init_idle = -1
, tail_idle = -1
, max_idle = -1
}
-- current wall clock time (in milliseconds since start of RTS)
-- FIXME get current wall clock time
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment