|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.dream.protocol.bus.logicalClock.ProtocolImpl.Session
protected class ProtocolImpl.Session
Field Summary | |
---|---|
protected boolean |
initialized
|
protected LogicalClock |
logicalClock
|
protected BusOutgoingPush |
lowerBusOutgoingPush
|
protected IncomingPush |
upperIncomingPush
|
protected List<Message> |
waitingToDeliver
|
Constructor Summary | |
---|---|
protected |
ProtocolImpl.Session(IncomingPush upperIncomingPush)
|
Method Summary | |
---|---|
int |
getBusSize()
Returns the size of the bus. |
int |
getLocalAddress()
Returns the address of this protocol instance in the bus. |
void |
incomingClosed(Object outgoingPush,
Exception exception)
Notifies the session, this interface belong, that the lower session accessible through the given interface has been unexpectedly closed. |
void |
incomingPush(Message message)
Gives an incoming message to a protocol. |
protected void |
initialize(LogicalClock logicalClock,
BusOutgoingPush lowerBusOutgoingPush)
|
void |
outgoingClose(IncomingPush incomingPush)
Closes the communication channel. |
void |
outgoingPush(Message message,
int to)
Gives an outgoing message to a protocol. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected IncomingPush upperIncomingPush
protected boolean initialized
protected BusOutgoingPush lowerBusOutgoingPush
protected LogicalClock logicalClock
protected List<Message> waitingToDeliver
Constructor Detail |
---|
protected ProtocolImpl.Session(IncomingPush upperIncomingPush)
Method Detail |
---|
protected void initialize(LogicalClock logicalClock, BusOutgoingPush lowerBusOutgoingPush)
public void outgoingPush(Message message, int to) throws PushException
BusOutgoingPush
outgoingPush
in interface BusOutgoingPush
message
- the message to give to the component.to
- the address in the bus of the receiver of the message.
PushException
- if an exception occurs.BusOutgoingPush.outgoingPush(Message, int)
public void outgoingClose(IncomingPush incomingPush) throws IOException
BusOutgoingPush
IncomingPush.incomingClosed(java.lang.Object, java.lang.Exception)
method, since this latter
is only used to inform a upper session that a lower session has been closed
unexpectedly.
outgoingClose
in interface BusOutgoingPush
incomingPush
- the interface on which incoming messages of the closed
communication channel were received.
IOException
- the closing process failed.BusOutgoingPush.outgoingClose(IncomingPush)
public int getLocalAddress()
BusOutgoingPush
getLocalAddress
in interface BusOutgoingPush
BusOutgoingPush.getLocalAddress()
public int getBusSize()
BusOutgoingPush
getBusSize
in interface BusOutgoingPush
BusOutgoingPush.getBusSize()
public void incomingPush(Message message) throws PushException
IncomingPush
incomingPush
in interface IncomingPush
message
- the message to give to the component.
PushException
- if an exception occurs.IncomingPush.incomingPush(Message)
public void incomingClosed(Object outgoingPush, Exception exception)
IncomingPush
incomingClosed
in interface IncomingPush
outgoingPush
- the interface provided by the closed session.exception
- the exception that forced the session to close. May be
null
.IncomingPush.incomingClosed(Object, Exception)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |