|
Holumbus.Distribution.DStreamPort | Portability | portable | Stability | experimental | Maintainer | Stefan Schmidt (stefanschmidt@web.de) |
|
|
|
|
|
Description |
Version : 0.1
This module offers distributed streams and ports.
Because a DChan allows external read access, the idea came up to
split a DChan into two parts: a stream and a port. A stream only allows
you to read data from it. The read-access is limited to the local process which
created the stream. To send data to a stream, you need a port. This can be used
on forgein nodes to send data to your local stream.
|
|
Synopsis |
|
|
|
|
datatypes
|
|
|
|
|
Instances | |
|
|
|
Message Datatype.
We are sending additional information, to do debugging
| Constructors | StreamPortMessage | | spm_Data :: !a | the data
| spm_Generic :: !(Maybe ByteString) | some generic data -- could be another port
|
|
| Instances | |
|
|
creating and closing a stream
|
|
|
Creates a new local stream.
|
|
|
Closes a stream.
|
|
operations on a stream
|
|
|
Tests, if a stream has no more data to read.
|
|
|
Reads the data packet of the next message from a stream.
If stream is empty, this function will block until a new message arrives.
|
|
|
Reads the next message from a stream (data packet + message header).
If stream is empty, this function will block until a new message arrives.
|
|
|
Reads the data packet of the next message from a stream.
If stream is empty, this function will immediately return with Nothing.
|
|
|
Reads the next message from a stream (data packet + message header).
If stream is empty, this function will immediately return with Nothing.
|
|
|
Reads the data packet of the next message from a stream.
If stream is empty, this function will wait for new messages until the
time is up and if no message has arrived, return with Nothing.
|
|
|
Reads the next message from a stream (data packet + message header).
If stream is empty, this function will wait for new messages until the
time is up and if no message has arrived, return with Nothing.
|
|
|
Encapsulates a stream.
A new stream is created, then some user-action is done an after that the
stream is closed.
|
|
creating a port
|
|
|
Creates a new Port, which is bound to a stream.
|
|
|
Creates a new port from a streamname and its socketId.
The first parameter is the name of the resource and the second one
the name of the node.
|
|
operations on a port
|
|
|
Send data to the stream of the port.
The data is send via network, if the stream is located on an external
processor
|
|
|
Like send, but here we can give some generic data (e.g. a port for reply
messages).
|
|
|
Like sendWithGeneric, but the generic data is optional
|
|
Produced by Haddock version 2.6.1 |