Holumbus-MapReduce-0.1.1: a distributed MapReduce framework

Portabilityportable
Stabilityexperimental
MaintainerStefan Schmidt (stefanschmidt@web.de)

Holumbus.Distribution.Messages

Contents

Description

Version : 0.1

Synopsis

Datatypes

Messages to and from the Master

Messages to and from the Worker

request an response handling

performPortAction

Arguments

:: (Show a, Binary a, Show b, Binary b, RspMsg b) 
=> Port a

request port

-> Stream b

response Stream

-> Int

timeout for the response in mikroseconds (1000000 = 1 sec) (0 = wait for ever)

-> a

request message

-> (b -> IO (Maybe c))

response handler

-> IO c 

Sends a request to the server (stream) and handles the response and all error cases. Very helpful when simulating a request response scheme with the mailboxes.