54 lines
1.8 KiB
Haskell
54 lines
1.8 KiB
Haskell
package Bus(mkBus) where
|
|
|
|
import Types
|
|
import BusTypes
|
|
import TagEngine
|
|
import Vector
|
|
import Util
|
|
import Arbiter
|
|
|
|
clientRequest :: Arbiter.ArbiterClient_IFC -> Action
|
|
clientRequest ifc = ifc.request
|
|
|
|
busRequestToAddr :: BusRequest -> Addr
|
|
busRequestToAddr req = case req of
|
|
BusReadRequest (ReadRequest addr _) -> addr
|
|
WriteReadRequest (WriteRequest addr _) -> addr
|
|
|
|
mkBus :: (Addr -> Integer)
|
|
-> Vector numClients (BusClient inFlightTransactions)
|
|
-> Vector numServers (BusServer inFlightTransactions numClients)
|
|
-> Module Empty
|
|
mkBus addrToServerTranslation clientVec serverVec = do
|
|
tagEngineByClientVec :: Vector numClients (TagEngine inFlightTransactions)
|
|
tagEngineByClientVec <- replicateM mkTagEngine
|
|
|
|
arbiterByServer :: Vector numServers (Arbiter_IFC numClients)
|
|
arbiterByServer <- replicateM (mkArbiter False)
|
|
|
|
addRules |>
|
|
rules
|
|
"placeholder rule": when True ==> do
|
|
let selectedServerArbiter = (select arbiterByServer 0)
|
|
mapM_ clientRequest selectedServerArbiter.clients
|
|
|
|
"connect request client 0": when True ==> do
|
|
let
|
|
clientIdx :: Integer = 0
|
|
selectedClient ::(BusClient inFlightTransactions)
|
|
selectedClient = (select clientVec clientIdx)
|
|
selectedTagEngine = (select tagEngineByClientVec clientIdx)
|
|
|
|
tag <- selectedTagEngine.requestTag
|
|
|
|
busRequest :: BusRequest
|
|
busRequest <- selectedClient.dequeueRequest tag
|
|
|
|
let
|
|
addr = busRequestToAddr busRequest
|
|
targetServerIdx = addrToServerTranslation addr
|
|
targetServer = (select serverVec 0)
|
|
action {}
|
|
|
|
return $ interface Empty { }
|