|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
ExportIdentifierChunk
containing an
IPExportIdentifier
.Protocol.createExportIdentifier(java.util.Map, org.objectweb.dream.protocol.ExportIdentifier[])
method
to specify the address of the export identifier to create.
Protocol.createExportIdentifier(java.util.Map, org.objectweb.dream.protocol.ExportIdentifier[])
method
to specify the address of the export identifier to create.
LogicalClock.testRecvMessage(Message)
if the message has
already been delivered.
ChannelFactory
interface
designated by the given export identifier.
ChannelFactory
interface designated
by the given export identifier.
Skeleton
interface designated by the
given export identifier.
keyChunk
) that is contained in the message as a
AbstractChunk
which name can be specified as a Fractal component
attribute using the
BufferAttributeControllerKeyChunkAdd
interface.Buffer
interface using a sorted list.SequenceNumberChunk
class.get
or
remove
in the same order as they are added
(First In First Out).chunk
which name can be
specified as a Fractal component attribute using the interface of type
BufferAttributeControllerKeyChunkAdd
.MessageKeyManager
.get
or
remove
in the reverse order as they are added
(Last In First Out).get
or remove
only if they are accepted
by the message matcher
bound to this component.get
or
remove
in the order of the "key" that is calculated for
each message by the MessageComparableKeyManager
component bound to
this component when adding
each message.OutgoingPush
interface for
bus protocol.Protocol
interface for protocol components providing
BusOutgoingPush
interface as result of a binding."out-push"
client interface).ChannelProtocol
can
export.ExportIdentifier
that identify the ChannelIn.ChannelFactory
interfaces.Protocol.createExportIdentifier(java.util.Map, ExportIdentifier[])
to specify the clock type.
Condition
interface.Condition
interface.connectionRetry
attribute.
ConnectionFactory
.ContentHandler
client interface.
WaitingKey
object for the given key.
Push
client interface.
outPushTable
.
LogicalClock.testRecvMessage(Message)
if the message can
be delivered
deserialize
that takes a
byte array as parameter and returns the corresponding message.DeSerializator
interface.DestinationResolver
implementation that use
a ExportIdentifierChunk
to retrieve
destination of messages.ExportIdentifier
if a
ExportIdentifierChunk
contained in the
message.DoubleKeyedPull
interface.DoubleKeyedPull
interface.Push
server interface to
throw a BufferOverflowException
PushException
has been catched while a message was pushed on the normal out push.
ChannelFactory
interface using this protocol.
Skeleton
interface using this protocol graph.
chunkName
is equals to the default name returns
LogicalClockChunk.DEFAULT_NAME
, returns the given string otherwise.
chunkName
is equal to the default name returns
FragmentationChunk.DEFAULT_NAME
, otherwise returns the given string.
chunkName
is equals to the default name returns
SequenceNumberChunk.DEFAULT_NAME
, returns the given string otherwise.
ExportIdentifierChunk
will be added
with the given name in every received messages.
TCPIPProtocol.CONNECTION_RETRY
hint.
true
if the destination chunk must be deleted from
the message.
ExportIdentifier
that identify the ChannelIn.
fragmentationSize
attribute value.
fromChunkName
attribute.
ExportIdentifier
identifying the local access point.
MultiplexChunk
that the protocol will add
to outgoing messages.
TCPIPProtocol.PORT
hint.
UDPProtocol.PORT
hint.
true
if the aggregator must return an empty message
when no message can't be aggregated.
recvBufferSize
attribute value.
true
if the return message has been received.
TCPIPProtocol.SO_LINGER
hint.
TCPIPProtocol.SO_TIMEOUT
hint.
TCPIPProtocol.TCP_NO_DELAY
hint.
PullException
occurring when the activity tries to pull a
message.
PushException
occurring when the activity tries to push a
message.
HandleReturnMessage
interface.ExportIdentifierChunk
send in first message of newly
opened channel session.
pushed
messages into a
buffer
bound to it.pushed
messages into a
buffer
bound to it.pushed
messages into a
buffer
bound to it.pushed
messages into a
buffer
bound to it.true
if the route table is initialized.
outPushRouteTable
route table.
DeSerializator
interface.
Serializator
interface.
Mutex
interface.
MutexReEntrant
interface.
ReadWriteLock
interface.
Semaphore
interface.
KeyedPush
interface.KeyedPush
interface.KeyedPush
interface.KeyedPull
interface.KeyedPull
interface.KeyInteger
objects with an increasing
integer.Key
interface that uses positive
integers.BusExportIdentifier
that other protocol instances must use to
access to this one)
BusProtocol.LOCAL_ADDRESS_HINT_KEY
),
and to export the access point of the local bus session.Protocol.createExportIdentifier(java.util.Map, ExportIdentifier[])
to specify the chunk name.
LogicalClock
interfaces
BufferRemove.removeAll()
.
KeyedBufferRemove.removeAll()
.
KeyedBufferRemove.removeAll()
.
DoubleKeyedBufferRemove.removeAll()
.
BufferRemove.get()
and BufferRemove.remove()
.BufferMatchingImpl.get()
, AbstractBufferImpl.tryGet()
, BufferMatchingImpl.remove()
,
AbstractBufferImpl.tryRemove()
and AbstractBufferImpl.removeAll()
.
OutgoingPush
interface for
message passing protocol.MessagePassingOverChannelImpl
component.ChannelProtocol
.BufferMatchingImpl.messageMatcherItf
and that are ready to
be returned.
snFrom
to snTo
are missing for the given key.
snFrom
to snTo
are missing.
snFrom
to snTo
are missing for the given key.
Mutex
interface: this mutex is
non-reentrant.MutexReEntrant
interface: this mutex is
reentrant.returns
messages removed from a
buffer
bound to it.returns
messages removed from a
buffer
bound to it.returns
messages removed from a
buffer
bound to it.to
.
Push
output
interfaces.
PullPullAggregatorWhileNotNullImpl
aggregator implementation.out-pull
server interface, this component pulls messages on its in-pull
client interface until null
is returned, and then returns an
aggregated message containing every pulled messages.UnlockKey.unlockKey()
.push
input.chunk
.
ObjectInput
object.
ReadWriteLock
interface.WaitingKey
object corresponding to the given key.
WaitingKey
objects corresponding to the
keys that are associated to the given key (that is an "isAll" key).
ExportIdentifier
which identifies the destination of the
given message.
PushException
is
catched, the message is pushed again.Protocol.createExportIdentifier(java.util.Map, org.objectweb.dream.protocol.ExportIdentifier[])
method
to specify the route identifier used to created the
MultiplexExportIdentifier
The value associated with this key must
be a Number
out-push-with-chunk
and out-push-without-chunk
.SAXParser
to give it a
Fractal component behavior.BufferMatchingImpl.removersCount
> 0
or if BufferMatchingImpl.gettersCount
> 0
), iterate over
the received messages
, and test each message by calling
MessageMatcher.acceptMessage(Message)
using
the bound matcher
, until at most enough matching
messages for waiting removers and getters have been found.
Semaphore
interface.Semaphore
interface.serialize
that takes a message
as parameter and returns a byte array representation of the message.Serializator
interface.TCPIPProtocol.CONNECTION_RETRY
hint.
multiplexChunkName
attribute.
nbMaxSession
attribute value.
TCPIPProtocol.PORT
hint.
UDPProtocol.PORT
hint.
pullEmptyMessage
policy.
DatagramPacket
when
receiving message.
TCPIPProtocol.SO_LINGER
hint.
TCPIPProtocol.SO_TIMEOUT
hint.
TCPIPProtocol.TCP_NO_DELAY
hint.
SO_LINGER
parameter of created sockets.
SO_TIMEOUT
parameter of created sockets.
Push
input, one Push
output, and one
Push1
input.PushWithReturn.pushWithReturn(Message)
method (i.e. outgoing
messages).ChannelFactory
interface.
BufferKeyMutexSortedImpl
component to
unlock the key of the calling thread.LogicalClock.testRecvMessage(Message)
if there is other
messages that must be delivered before this one.
WaitingKey
objects.ObjectOutput
object.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |