-- Hoogle documentation, generated by Haddock -- See Hoogle, http://www.haskell.org/hoogle/ -- | Compositional lazy dataflow networks for exact real number computation -- -- AERN-Net provides datatypes and abstractions for defining and -- executing networks of communicating processes. These networks have a -- fixed topology, which can be infinite via recursion. The communication -- on each channel is driven by some query-response protocol. Basic -- protocols for communicating approximations of real numbers and -- functions are provided together with protocol combinators eg for -- communicating value pairs or lists and communicating with additional -- query parameters or with optimised repetitions. -- -- An class-based abstraction is provided to make it possible to execute -- networks on various distributed backends without modification. At the -- moment there is only one backend, which is not distributed. It is -- envisaged that truly distributed backends will be added soon, eg based -- on plain TCP, MPI or REST/SOAP Web services. -- -- A mathematical foundation of these networks is described in the draft -- paper -- http://www-users.aston.ac.uk/~konecnym/papers/ernets08-draft.html. -- -- Simple examples of usage can be found in modules DemoMax and -- DemoSqrt in folder tests. @package AERN-Net @version 0.2.0 -- | This module defines the concept of a protocol for channel -- communication. -- -- The protocol concept is formalised using the 2-parameter class -- QAProtocol and the existential types ChannelType, -- AnswerAnyProt, QueryAnyProt indexed by instances of -- QAProtocol. module Control.ERNet.Foundations.Protocol -- | any danger of over 2^29 queries? type QueryId = Int -- | A class grouping types of queries and answers. -- -- Each instance has to define dynamic type checking of answers agains -- queries. class (Ord q, HTML q, HTML a, Show q, Show a, Typeable q, Typeable a) => QAProtocol q a | a -> q, q -> a qaMatch :: (QAProtocol q a) => q -> a -> Maybe String qaaSetMinGran :: (QAProtocol q a) => Granularity -> a -> a -- | This type is used to identify protocols eg for the creation of new -- channels or for dynamic type checking. It consists of an example query -- and an example answer. data ChannelType ChannelType :: q -> a -> ChannelType -- | Union of queries from all protocols. data QueryAnyProt QueryAnyProt :: q -> QueryAnyProt -- | Union of answers from all protocols. data AnswerAnyProt AnswerAnyProt :: a -> AnswerAnyProt data QAUnitQ QAUnitQ :: QAUnitQ data QAUnitA QAUnitA :: QAUnitA data QABoolQ QABoolQ :: QABoolQ instance Typeable QABoolQ instance Typeable QAUnitA instance Typeable QAUnitQ instance Eq QABoolQ instance Ord QABoolQ instance Show QABoolQ instance Eq QAUnitA instance Ord QAUnitA instance Show QAUnitA instance Eq QAUnitQ instance Ord QAUnitQ instance Show QAUnitQ instance HTML QABoolQ instance HTML Bool instance QAProtocol QABoolQ Bool instance HTML QAUnitA instance HTML QAUnitQ instance QAProtocol QAUnitQ QAUnitA instance HTML AnswerAnyProt instance Show AnswerAnyProt instance HTML QueryAnyProt instance Show QueryAnyProt instance Show ChannelType instance Eq ChannelType -- | Kahn process networks with channels adapted for arbitrary precision -- real higher-order data communication. Executed using a number of -- parallel threads. Each process started in a dedicated thread and each -- process typically starts further internal threads. Each channel is a -- transactional variable (TVar) known to both end processes and allows -- them to communicate according to its instance of the QAProtocol -- class. module Control.ERNet.Foundations.Process -- | All data that define a process, including its behaviour. Each -- executing process is instantiated from one of these descriptions. data ERProcess sInAnyProt sOutAnyProt ERProcess :: ERProcessName -> ERProcessDeploy sInAnyProt sOutAnyProt -> [ChannelType] -> [ChannelType] -> ERProcess sInAnyProt sOutAnyProt -- | undeployed process name erprocName :: ERProcess sInAnyProt sOutAnyProt -> ERProcessName -- | On deployment, a process either expands itself using the provided -- callback function and does not use the sockets at all -- -- OR it uses the sockets and never calls the expansion callback. erprocDeploy :: ERProcess sInAnyProt sOutAnyProt -> ERProcessDeploy sInAnyProt sOutAnyProt erprocInputTypes :: ERProcess sInAnyProt sOutAnyProt -> [ChannelType] erprocOutputTypes :: ERProcess sInAnyProt sOutAnyProt -> [ChannelType] type ERProcessName = String type ERProcessDeploy sInAnyProt sOutAnyProt = ERProcessName -> [sInAnyProt] -> [sOutAnyProt] -> (ERProcessExpandCallback sInAnyProt sOutAnyProt) -> IO () type ERProcessExpandCallback sInAnyProt sOutAnyProt = String -> [(ChannelType, Int)] -> [(ChannelType, Int)] -> [(ERProcess sInAnyProt sOutAnyProt, ([Int], [Int]))] -> IO () subnetProcess :: ERProcessName -> [(ChannelType, Int)] -> [(ChannelType, Int)] -> [(ERProcess sInAnyProt sOutAnyProt, ([Int], [Int]))] -> ERProcess sInAnyProt sOutAnyProt -- | This module defines some basic concrete protocols, namely protocols -- for transferring a unit and a boolean. -- -- Some protocol combinators are provided to form new protocols from old -- protocols. Eg one can form a product of two protocols to get a -- protocol for query-answer dialogues about a pair of values. Similarly, -- one can construct protocols for a sum of two types, a maybe type and a -- list type. -- -- Any protocol can be also extended to include effort indices in queries -- or to allow incremental computation with non-blocking queries on -- progress, multiple dialogue thread tracking and the communication of a -- failure. -- -- TODO: add protocols for -- -- module Control.ERNet.Foundations.Protocol.StandardCombinators data QAMaybeQ q QAMaybeQ :: q -> QAMaybeQ q QAMaybeQIsNothing :: q -> QAMaybeQ q data QAMaybeA a QAMaybeA :: (Maybe a) -> QAMaybeA a QAMaybeAIsNothing :: Bool -> QAMaybeA a chTMaybe :: ChannelType -> ChannelType makeAnswerMaybe :: (QAProtocol q a) => (q -> Maybe a) -> (QAMaybeQ q) -> (QAMaybeA a) data QAIxQ q QAIxQ :: EffortIndex -> q -> QAIxQ q data QAIxA a QAIxA :: a -> QAIxA a chTIx :: ChannelType -> ChannelType data QAChangesQ q QAChangesQIfNew :: QueryId -> q -> QAChangesQ q QAChangesQWhenNew :: QueryId -> q -> QAChangesQ q QAChangesQ :: q -> QAChangesQ q data QAChangesA a QAChangesANew :: a -> QAChangesA a QAChangesASame :: QAChangesA a QAChangesAGivenUp :: QAChangesA a chTChanges :: ChannelType -> ChannelType firstJust :: [Maybe err] -> Maybe err data QAListQ q QAListQAllHomog :: q -> QAListQ q QAListQSingle :: Int -> q -> QAListQ q QAListQPrefix :: [q] -> QAListQ q QAListQLength :: QAListQ q data QAListA a QAListA :: [a] -> QAListA a QAListASingle :: a -> QAListA a QAListALength :: Int -> QAListA a chTList :: ChannelType -> ChannelType makeAnswerList :: (QAProtocol q a) => ([a]) -> (QAListQ q) -> (QAListA a) data QAProdQ q1 q2 QAProdQFirst :: q1 -> QAProdQ q1 q2 QAProdQSecond :: q2 -> QAProdQ q1 q2 QAProdQBoth :: q1 -> q2 -> QAProdQ q1 q2 data QAProdA a1 a2 QAProdAFirst :: a1 -> QAProdA a1 a2 QAProdASecond :: a2 -> QAProdA a1 a2 QAProdABoth :: a1 -> a2 -> QAProdA a1 a2 chTProd :: ChannelType -> ChannelType -> ChannelType makeAnswerProd :: (QAProtocol q1 a1, QAProtocol q2 a2) => (q1 -> a1) -> (q2 -> a2) -> (QAProdQ q1 q2) -> (QAProdA a1 a2) instance Typeable2 QAProdA instance Typeable2 QAProdQ instance Typeable1 QAListA instance Typeable1 QAListQ instance Typeable1 QAChangesA instance Typeable1 QAChangesQ instance Typeable1 QAIxA instance Typeable1 QAIxQ instance Typeable1 QAMaybeA instance Typeable1 QAMaybeQ instance (Eq a1, Eq a2) => Eq (QAProdA a1 a2) instance (Ord a1, Ord a2) => Ord (QAProdA a1 a2) instance (Show a1, Show a2) => Show (QAProdA a1 a2) instance (Eq q1, Eq q2) => Eq (QAProdQ q1 q2) instance (Ord q1, Ord q2) => Ord (QAProdQ q1 q2) instance (Show q1, Show q2) => Show (QAProdQ q1 q2) instance (Eq a) => Eq (QAListA a) instance (Ord a) => Ord (QAListA a) instance (Show a) => Show (QAListA a) instance (Eq q) => Eq (QAListQ q) instance (Ord q) => Ord (QAListQ q) instance (Show q) => Show (QAListQ q) instance (Eq a) => Eq (QAChangesA a) instance (Ord a) => Ord (QAChangesA a) instance (Show a) => Show (QAChangesA a) instance (Eq q) => Eq (QAChangesQ q) instance (Ord q) => Ord (QAChangesQ q) instance (Show q) => Show (QAChangesQ q) instance (Eq a) => Eq (QAIxA a) instance (Ord a) => Ord (QAIxA a) instance (Show a) => Show (QAIxA a) instance (Eq q) => Eq (QAIxQ q) instance (Ord q) => Ord (QAIxQ q) instance (Show q) => Show (QAIxQ q) instance (Eq a) => Eq (QAMaybeA a) instance (Ord a) => Ord (QAMaybeA a) instance (Show a) => Show (QAMaybeA a) instance (Eq q) => Eq (QAMaybeQ q) instance (Ord q) => Ord (QAMaybeQ q) instance (Show q) => Show (QAMaybeQ q) instance (HTML a1, HTML a2) => HTML (QAProdA a1 a2) instance (HTML q1, HTML q2) => HTML (QAProdQ q1 q2) instance (QAProtocol q1 a1, QAProtocol q2 a2, Show q1, Show a1, Show q2, Show a2) => QAProtocol (QAProdQ q1 q2) (QAProdA a1 a2) instance (HTML a) => HTML (QAListA a) instance (HTML q) => HTML (QAListQ q) instance (QAProtocol q a, Show q, Show a) => QAProtocol (QAListQ q) (QAListA a) instance (HTML a) => HTML (QAChangesA a) instance (HTML q) => HTML (QAChangesQ q) instance (QAProtocol q a, Show q, Show a) => QAProtocol (QAChangesQ q) (QAChangesA a) instance (HTML a) => HTML (QAIxA a) instance (HTML q) => HTML (QAIxQ q) instance (QAProtocol q a) => QAProtocol (QAIxQ q) (QAIxA a) instance (HTML a) => HTML (QAMaybeA a) instance (HTML q) => HTML (QAMaybeQ q) instance (QAProtocol q a, Show q, Show a) => QAProtocol (QAMaybeQ q) (QAMaybeA a) -- | Communication events with various data useful for logging and -- debugging. module Control.ERNet.Foundations.Event -- | Data to be logged with every query and answer event. data ERNetEvent ERNetEvQryMade :: UTCTime -> QueryId -> String -> QueryId -> String -> q -> ERNetEvent ernetevTime :: ERNetEvent -> UTCTime ernetevQryId :: ERNetEvent -> QueryId ernetevFromId :: ERNetEvent -> String ernetevFromQryId :: ERNetEvent -> QueryId ernetevToId :: ERNetEvent -> String ernetevQry :: ERNetEvent -> q ERNetEvQryReceived :: UTCTime -> QueryId -> String -> q -> ERNetEvent ernetevTime :: ERNetEvent -> UTCTime ernetevQryId :: ERNetEvent -> QueryId ernetevToId :: ERNetEvent -> String ernetevQry :: ERNetEvent -> q ERNetEvAnsMade :: UTCTime -> QueryId -> String -> a -> ERNetEvent ernetevTime :: ERNetEvent -> UTCTime ernetevQryId :: ERNetEvent -> QueryId -- | query target, the one who answered ernetevToId :: ERNetEvent -> String ernetevAns :: ERNetEvent -> a ERNetEvAnsReceived :: UTCTime -> QueryId -> String -> QueryId -> String -> a -> q -> ERNetEvent ernetevTime :: ERNetEvent -> UTCTime ernetevQryId :: ERNetEvent -> QueryId -- | query originator, receiver of answer ernetevFromId :: ERNetEvent -> String ernetevFromQryId :: ERNetEvent -> QueryId -- | query target, the one who answered ernetevToId :: ERNetEvent -> String ernetevAns :: ERNetEvent -> a ernetevQry :: ERNetEvent -> q instance Show ERNetEvent -- | Functions that produce a javascipt representation of the message -- dependence graph contained in a set of network events. module Control.ERNet.Foundations.Event.JavaScript constructJS :: [ERNetEvent] -> String -- | Abstraction of an event logger in the IO monad. -- -- To be imported qualified, usually with the prefix LG. module Control.ERNet.Foundations.Event.Logger class Logger lg new :: (Logger lg) => IO lg addEvent :: (Logger lg) => lg -> ERNetEvent -> IO () emptyAndDo :: (Logger lg) => lg -> (ERNetEvent -> IO a) -> IO () emptyAndGetEvents :: (Logger lg) => lg -> IO ([ERNetEvent]) -- | Abstraction of data flow channels and its sockets with associated -- query-answer protocol for gradual data communication. -- -- To be imported qualified, usually with the prefix CH. module Control.ERNet.Foundations.Channel -- | A channel type, as it is presented to the processes, consists of an -- input socket and an output socket types. -- -- Each socket type has a unique protocol associated with it. Whenever -- the protocol can be determined at compile time, we use the sIn and -- sOut types, otherwise we use the sInAnyProt and sOutAnyProt types. -- Elements of sInAnyProt and sOutAnyProt can be dynamically cast to -- elements of sIn and sOut once the protocol can be deduced by the -- Haskell type checker. class Channel sIn sOut sInAnyProt sOutAnyProt | sIn -> sOut sInAnyProt sOutAnyProt, sOut -> sIn sInAnyProt sOutAnyProt, sInAnyProt -> sOutAnyProt sIn sOut, sOutAnyProt -> sInAnyProt sIn sOut castIn :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => String -> sInAnyProt -> sIn q a castOut :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => String -> sOutAnyProt -> sOut q a castInIO :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => String -> sInAnyProt -> IO (sIn q a) castOutIO :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => String -> sOutAnyProt -> IO (sOut q a) makeQuery :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a, Show q, Show a) => sOut q2 a2 -> QueryId -> sIn q a -> q -> IO QueryId makeQueryAnyProt :: (Channel sIn sOut sInAnyProt sOutAnyProt) => String -> sOutAnyProt -> QueryId -> sInAnyProt -> QueryAnyProt -> IO QueryId waitForQuery :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a, Show q, Show a) => sOut q a -> IO (QueryId, q) waitForQueryMulti :: (Channel sIn sOut sInAnyProt sOutAnyProt) => [sOutAnyProt] -> IO (Int, (QueryId, QueryAnyProt)) answerQuery :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => Bool -> (sOut q a) -> (QueryId, a) -> IO () answerQueryAnyProt :: (Channel sIn sOut sInAnyProt sOutAnyProt) => String -> Bool -> sOutAnyProt -> (QueryId, AnswerAnyProt) -> IO () waitForAnswer :: (Channel sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a, Show q, Show a) => sOut q2 a2 -> QueryId -> sIn q a -> QueryId -> IO a waitForAnswerMulti :: (Channel sIn sOut sInAnyProt sOutAnyProt) => sOutAnyProt -> QueryId -> [(sInAnyProt, QueryId)] -> IO (Int, AnswerAnyProt) class (Channel sIn sOut sInAnyProt sOutAnyProt, Logger lg) => ChannelForScheduler lg sIn sOut sInAnyProt sOutAnyProt | sIn -> lg new :: (ChannelForScheduler lg sIn sOut sInAnyProt sOutAnyProt) => lg -> String -> Int -> ChannelType -> IO (sInAnyProt, sOutAnyProt) -- | Abstraction of a distributed manager for networked ER processes. Its -- functions comprise: -- -- -- -- To be imported qualified, usually with the prefix MAN. module Control.ERNet.Foundations.Manager class (ChannelForScheduler lg sIn sOut sInAnyProt sOutAnyProt) => Manager man lg sIn sOut sInAnyProt sOutAnyProt | man -> lg sIn sOut sInAnyProt sOutAnyProt new :: (Manager man lg sIn sOut sInAnyProt sOutAnyProt) => ManagerName -> IO (man, ManagerID) connectNeighbour :: (Manager man lg sIn sOut sInAnyProt sOutAnyProt) => man -> ManagerID -> IO Bool runProcess :: (Manager man lg sIn sOut sInAnyProt sOutAnyProt) => man -> ERProcess sInAnyProt sOutAnyProt -> IO lg -- | A name given to a ditributed node by a programmer. type ManagerName = String -- | A globally unique name as a URL. -- -- eg ernet:localhost:4176/miks-ivp-solver-master -- ernet-local:/ivp-solver-master ernet-mpi:/ivp-solver-master -- -- The port 4176 was unassigned when checked on -- http:www.iana.orgassignmentsport-numbers on 2nd November -- 2008. type ManagerID = String -- | Run a process together with some queries on one of its output sockets. runDialogue :: (Manager man lg sIn sOut sInAnyProt sOutAnyProt, QAProtocol q a) => man -> ERProcess sInAnyProt sOutAnyProt -> Int -> ChannelType -> ((q -> IO a) -> IO ()) -> Bool -> IO lg -- | A simple logger implementation using an STM channel. module Control.ERNet.Deployment.Local.Logger data LoggerLocal instance Logger LoggerLocal -- | A simple channel implementation using STM protected variables. module Control.ERNet.Deployment.Local.Channel data ChannelLocal q a -- | Union of channel types over instances of the ChannelComm.QERrotocol -- class. -- -- (existential type) data ChannelLocalAnyProt instance Typeable2 ChannelLocal instance Show (ChannelLocal q a) instance Ord (ChannelLocal q a) instance Eq (ChannelLocal q a) instance ChannelForScheduler LoggerLocal ChannelLocal ChannelLocal ChannelLocalAnyProt ChannelLocalAnyProt instance Channel ChannelLocal ChannelLocal ChannelLocalAnyProt ChannelLocalAnyProt -- | A simple implementation of -- Control.ERNet.Foundations.Manager.Manager, deploying all -- processes locally. module Control.ERNet.Deployment.Local.Manager data ManagerLocal instance Manager ManagerLocal LoggerLocal ChannelLocal ChannelLocal ChannelLocalAnyProt ChannelLocalAnyProt -- | Basic protocols for transferring approximations of real functions. module Control.ERNet.Blocks.RnToRm.Protocols data QAFn1Q box QAFn1QAll :: QAFn1Q box QAFn1QDom :: box -> QAFn1Q box QAFn1QPt :: box -> QAFn1Q box data QAFn1A ranra fa QAFn1A :: fa -> QAFn1A ranra fa QAFn1APt :: [ranra] -> QAFn1A ranra fa chTFn1 :: (ERFnApprox box varid domra ranra fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable box, Show box, Typeable domra, Typeable ranra, Typeable fa, HTML fa) => fa -> ChannelType -- | Construct an answer about a function, assuming they will not ask about -- a subdomain. makeAnswerFn1NoIx :: (ERFnApprox box varid domra ranra fa) => fa -> (QAFn1Q box) -> (QAFn1A ranra fa) -- | Construct an answer about a function, given as a Haskell real -> -- real function. makeAnswerFn1ByBoxesNoIx :: (ERFnDomApprox box varid domra ranra fa) => (box -> [ranra]) -> (QAFn1Q box) -> (QAFn1A ranra fa) data QAFn2Q fa QAFn2QPt :: fa -> QAFn2Q fa data QAFn2A fa QAFn2APt :: fa -> QAFn2A fa chTFn2 :: (ERFnApprox box varid domra ranra fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable box, Show box, Typeable domra, Typeable ranra, Typeable fa, HTML fa) => fa -> ChannelType instance Typeable1 QAFn2A instance Typeable1 QAFn2Q instance Typeable2 QAFn1A instance Typeable1 QAFn1Q instance (Show fa) => Show (QAFn2A fa) instance (Show fa) => Show (QAFn2Q fa) instance (Show ranra, Show fa) => Show (QAFn1A ranra fa) instance (Show box) => Show (QAFn1Q box) instance (HTML fa) => HTML (QAFn2A fa) instance (HTML fa) => HTML (QAFn2Q fa) instance (ERFnApprox box varid domra ranra fa) => Ord (QAFn2Q fa) instance (ERFnApprox box varid domra ranra fa) => Eq (QAFn2A fa) instance (ERFnApprox box varid domra ranra fa) => Eq (QAFn2Q fa) instance (ERFnApprox box varid domra ranra fa, Typeable fa, HTML fa) => QAProtocol (QAFn2Q fa) (QAFn2A fa) instance (Show ranra, HTML fa) => HTML (QAFn1A ranra fa) instance (Show box) => HTML (QAFn1Q box) instance (ERFnApprox box varid domra ranra fa) => Eq (QAFn1A ranra fa) instance (DomainBox box varid domra, ERApprox domra) => Ord (QAFn1Q box) instance (DomainBox box varid domra, ERApprox domra) => Eq (QAFn1Q box) instance (ERFnApprox box varid domra ranra fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable box, Show box, Typeable domra, Typeable ranra, Typeable fa, HTML fa) => QAProtocol (QAFn1Q box) (QAFn1A ranra fa) -- | Basic protocols for transferring approximations of a single real -- number. module Control.ERNet.Blocks.Real.Protocols data QARealQ QARealQ :: QARealQ data QARealA ra QARealA :: ra -> QARealA ra chTReal :: (ERApproxElementary ira, Typeable ira) => ira -> ChannelType -- | Construct an answer to a query for a real number using the default -- real number protocol with an effort index. makeAnswerR :: (ERApproxElementary ra) => (EffortIndex -> ra) -> (QAIxQ (QARealQ)) -> (QAIxA (QARealA ra)) -- | Construct an answer to a query for a real number using the default -- real number protocol without any effort index. makeAnswerRNoIx :: (ERApproxElementary ra) => (ra) -> (QARealQ) -> (QARealA ra) -- | Construct an answer to a query for a list a real numbers using the -- list protocol with an effort index. makeAnswerRs :: (ERApproxElementary ra) => (EffortIndex -> [ra]) -> (QAIxQ (QAListQ QARealQ)) -> (QAIxA (QAListA (QARealA ra))) -- | Construct an answer to a query for a list a real numbers using the -- list protocol without any effort index. makeAnswerRsNoIx :: (ERApproxElementary ra) => ([ra]) -> (QAListQ QARealQ) -> (QAListA (QARealA ra)) -- | Make a query and wait for answer on a real number input socket with -- the standard (index -> approx) protocol. querySyncR :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERApproxElementary ira, Typeable ira) => sOut q2 a2 -> QueryId -> (sIn (QAIxQ QARealQ) (QAIxA (QARealA ira))) -> EffortIndex -> IO (ira) instance Typeable1 QARealA instance Typeable QARealQ instance (Eq ra) => Eq (QARealA ra) instance (Ord ra) => Ord (QARealA ra) instance (Show ra) => Show (QARealA ra) instance Eq QARealQ instance Ord QARealQ instance Show QARealQ instance (Show ra) => HTML (QARealA ra) instance HTML QARealQ instance (ERApproxElementary ira, Typeable ira) => QAProtocol QARealQ (QARealA ira) -- | A collection of processes whose main purpose is to synchronise other -- processes and have little semantical value. module Control.ERNet.Blocks.Control.Basic -- | This process joins information from two channels (step, -- val) in such a way that it acts as a splitter of -- responsibilities for its multi-threaded failure-enabled result channel -- as follows: -- -- -- -- While the process is waiting for a response from the step channel, any -- queries are put on hold until the response comes. -- -- joinStepValProcess :: (QAProtocol q a, Show q, Show a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> ChannelType -> a -> ERProcess sInAnyProt sOutAnyProt -- | This process provides multiple copies of one single-threaded channel. -- -- merges splits a channel into two channels - primary channel and -- secondary channel. The primary channel is a clean forward of the -- original channel. The secondary channel can use a slightly different -- protocol than the primary channel. -- -- Any query on the secondary channel will be blocked until a matching -- query is received and processed on the primary channel. (The user must -- supply a function that decides whether or not the queries are -- matching.) -- -- Whenever a query is being answered on the primary channel, all queries -- pending on the secondary channel that are matching this one will be -- replied at the same time using the an answer derived from the answer -- on the primary channel. splitSyncProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> ChannelType -> Int -> a -> ERProcess sInAnyProt sOutAnyProt -- | This process provides two channels (primary, secondary) split off from -- one source channel. The primary channel is a clean forward of the -- source channel. The secondary channel can use a slightly different -- protocol than the primary channel. -- -- Any query on the secondary channel will be blocked until a matching -- query is received and processed on the primary channel. (The user must -- supply a function that decides whether or not the queries are -- matching.) -- -- Whenever a query is being answered on the primary channel, all queries -- pending on the secondary channel that are matching this one will be -- replied at the same time using the an answer derived from the answer -- on the primary channel. biasedSplitSyncProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> ChannelType -> ChannelType -> (q2 -> q1 -> Bool) -> (q2 -> a1 -> a2) -> ERProcess sInAnyProt sOutAnyProt -- | This process acts as a switch for a group of channels, -- forwarding information from one of two groups of source channels. The -- special switch channel indicates whether to use one or the -- other. switchMultiProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> [ChannelType] -> ERProcess sInAnyProt sOutAnyProt -- | This process acts as a simple pass-through + it decreases the effort -- index of each query except for a query with effort index zero it asks -- a special value provider. It can cope with several queries in -- parallel. improverIxSimpleProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> ChannelType -> a -> ERProcess sInAnyProt sOutAnyProt -- | This process acts as a simple pass-through + it remembers its last -- answer and provides it on another channel. It initialises its memory -- from a special value provider. improverNoIxSimpleProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> ChannelType -> a -> ERProcess sInAnyProt sOutAnyProt -- | Definitions of a few universaly useful simple network processes and -- process templates. module Control.ERNet.Blocks.Basic -- | A generic stateless process with no inputs. constantProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> (q -> a) -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A generic process with no inputs that answers using a ChTChanges -- protocol. constantChangedProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> (q -> a) -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A generic stateful process with no inputs. constantStatefulProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> (s -> (QueryId, q) -> (a, Maybe s)) -> s -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A simple process that passes on a translated version of each query to -- another process and translates the answers before passing them back. passThroughProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> (q1 -> q2) -> (q1 -> a2 -> a1) -> ChannelType -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A simple process that either responds with no further queries or -- passes on a translated version of the query to another process, and -- then passing back a translated version of the answer received. maybePassThroughProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> (q1 -> Bool) -> (q1 -> a1) -> (q1 -> q2) -> (q1 -> a2 -> a1) -> ChannelType -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A process that passes on a translated version of each query to another -- process. When the other other answers, it analyses the answer and -- decides whether to send another query or answer its original query. -- -- Several simpler processes are defined as specialisations of this one. passThroughStatefulProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> (s -> (QueryId, q1) -> (Either q2 a1, Maybe s)) -> (s -> (QueryId, q1) -> a2 -> (Either q2 a1, Maybe s)) -> s -> ChannelType -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A process that passes on a translated version of each query to one or -- both of another 2 channels. When the other channel(s) answer, it -- analyses the answer(s) and decides whether to send other queries or -- answer its original query. passThroughBinaryStatefulProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> (s -> (QueryId, q) -> (Either (Maybe q1, Maybe q2) a, Maybe s)) -> (s -> (QueryId, q) -> (Maybe a1, Maybe a2) -> (Either (Maybe q1, Maybe q2) a, Maybe s)) -> s -> (ChannelType, ChannelType) -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A simple process that passes on a translated version of each query to -- another process and translates the answers before passing them back. passThroughBinaryProcess :: (QAProtocol q1 a1, QAProtocol q2 a2, QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> (q -> (q1, q2)) -> (q -> (a1, a2) -> a) -> (ChannelType, ChannelType) -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A process passing on information without modification, except for -- improving the convergence rate in successive queries. -- -- Each query may refer to a previous query. When it does, the query will -- not be answered until either: -- -- -- -- Currently supports only single-threaded querying. rateProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => ERProcessName -> (a -> a -> Bool) -> Int -> ChannelType -> ERProcess sInAnyProt sOutAnyProt -- | A trivial passthrough process that only: -- -- precProcess :: (QAProtocol q a, Channel sIn sOut sInAnyProt sOutAnyProt) => Bool -> ERProcessName -> ChannelType -> a -> ERProcess sInAnyProt sOutAnyProt module Control.ERNet.Blocks.Real.Basic -- | A process passing on information about a real number, trying to -- improve the convergence rate in successive queries. -- -- Each query may refer to a previous query. When it does, the query will -- not be answered until either: -- -- rateRProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERApproxElementary ra, Typeable ra) => ERProcessName -> Rational -> Int -> ra -> ERProcess sInAnyProt sOutAnyProt -- | A process passing on information about a list of real numbers, trying -- to improve the convergence rate in successive queries. -- -- Each query may refer to a previous query. When it does, the query will -- not be answered until either: -- -- rateRsProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERApproxElementary ra, Typeable ra) => ERProcessName -> Rational -> Int -> ra -> ERProcess sInAnyProt sOutAnyProt -- | A few processes universally useful when representing (1st-order) real -- functions as single data entities via ERFnDomApprox. module Control.ERNet.Blocks.RnToRm.Basic -- | A pass-through process for first order real functions with effort -- index that is almost equal to the identity. -- -- It restricts the function's graph at certain given intervals to the -- given boxes. boundingProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => Bool -> ERProcessName -> ChannelType -> fa -> EffortIndex -> [(domra, ranra)] -> ERProcess sInAnyProt sOutAnyProt -- | A simple integrator process for first-order linear domain functions -- with effort index using the default integration of the -- ERFnDomApprox instance. integrateFAProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> ChannelType -> fa -> ERProcess sInAnyProt sOutAnyProt -- | An intersecting and improvement measuring stateful integrator process -- using default intersecting & measuring integration of the -- ERFnDomApprox instance. integrateIsectMeasureFAProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> fa -> ERProcess sInAnyProt sOutAnyProt -- | Apply a function transformer ((R^m->R^n) -> (R^m->R^n)) to a -- function (R^m->R^n). applyFieldProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> fa -> ERProcess sInAnyProt sOutAnyProt -- | A process joining two functions for adjacent domains to one function -- on the joint domain. -- -- Each query is split accordingly to two queries on the two halves of -- the bisected domain, respectively. joinFADomProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> fa -> ERProcess sInAnyProt sOutAnyProt -- | A process splitting a function into two based on a bisection of the -- domain. -- -- A query for either half of the function results in a query for the -- whole. The whole function is then cached to answer an analogous query -- for the second half. Only one such result is cached (always the last -- one). splitFADomProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> fa -> ERProcess sInAnyProt sOutAnyProt -- | A process passing on information about a real function, trying to -- improve the convergence rate in successive queries. -- -- Each query may refer to a previous query. When it does, the query will -- not be answered until either: -- -- rateFnProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> Rational -> Int -> fa -> ERProcess sInAnyProt sOutAnyProt -- | A process passing on information about the values of a real function -- at its domain endpoints. -- -- Protocols are wrapped in ChannelComm.ChTChanges in order to be able to -- communicate failure. getEndpointValsProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> fa -> ERProcess sInAnyProt sOutAnyProt -- | A process passing on information about the values of a real function -- over a fixed domain. -- -- Protocols are wrapped in ChannelComm.ChTChanges in order to be able to -- communicate failure. maxOverDomProcess :: (Channel sIn sOut sInAnyProt sOutAnyProt, ERFnDomApprox box varid domra ranra fa, Typeable box, Typeable fa, Show box, HTML fa, ERApproxElementary domra, ERApproxElementary ranra, Typeable domra, Typeable ranra) => ERProcessName -> box -> fa -> ERProcess sInAnyProt sOutAnyProt