This basically changes the internal message handler of the given
entity to become the current object (this communication handler)
which allows it to receive all message events rightaway and to
forward them fast via the messages handler interface specific methods.
Called each time inside the host's CommunicationServerThread addNewEntity()
as last statement, AFTER the new entity is inserted into the Communication
ServerThread's structures, BEFORE starting the entity through Entity.up()
This gives the handler the oportunity to maybe change the default message
handler of this entity and to perform maybe other tasks.
This basically changes the internal message handler of the given
entity to become the current object (this communication handler)
which allows it to receive all message events rightaway and to
forward them fast via the messages handler interface specific methods.
This variable does not count inside the entity, the hashCode returns
a value that doesn't depend on this, two EntityID objects are equal
even if this value is different.
Returns the maximum nodes number that can be handled by this graph
This also means that there can be NO node with an id greater than this
value, stored inside this graph.
Defines the default value for the incomming queue length parameter
in the case of a call to the simple version of login()
You may set this to some other value than the default.
This defines the time to wait for a full queue to free up before
declaring the queue full on inserting a object into it
Should be reasonable small (0-100).
A class that implements the necesary connecting and messaging functions
for connecting and communicating inside a JVM medium implementation
using object serialization.
This defines the default login timeout parameter
in the case of a call to the simple version of login()
You may set this to some other value than the default.
Note: Always remember that this is executed inside the run()
of the TCPIPReadThread so don't kill this guy via Entity.down() maybe !!!
You may kill him only as LAST statement, before return.
NOT IMPLEMENTED YET !!!
Note: Always remember that this is executed inside the run()
of the TCPIPReadThread so don't kill this guy via Entity.down() maybe !!!
You may kill him only as LAST statement, before return.
Defines the default value for the incomming queue length parameter
in the case of a call to the simple version of login()
You may set this to some other value than the default.
This thread is created for each new accepted socket inside the
ConnectionThread and should apply the given protocol on the socket
in a somehow blocking mode, that is this thread is dedicated only
to a given session after which it exits.
The method bellow is adapted from the jdk102 DataInputStream source
and reads from a InputStream a whole line, that has been terminated by a \n, \r,
\r\n or EOF.
Removes a node from the graph by removing all the connections that
contain that node integer number. Devlp note: The respective slot is not deleted ! why should it be ?
Defines the default sleep delay for the read thread
in the case of a call to the simple version of login()
You may set this to some other value than the default.
This defines the default timeout inside the simple version of send(),
in waiting for a free slot
in the outgoing message queue, before throwing FullException.
A thread that runs as server on a specified port and accepts incomming
TCP/IP connect requests.It then puts the incomming socket into a queue
which should be parsed by one or more specific protocol threads that
treat the requests.
This is like some sort of constructor for the communication handler
and gets called right after instantiating the handler.
REF="jvm/server/DistributedCommunicationHandler.html#setBasicVars(jvm.server.CommunicationServerThread, jclass.SimpleProperties)">setBasicVars(CommunicationServerThread, SimpleProperties) -
Method in class jvm.server.DistributedCommunicationHandler
This stream basically deals with the automatic class loading issues
that require that on both sides of a connection there should be a
description of the transfered object class available.
This stream basically deals with the automatic class loading issues
that require that on both sides of a connection there should be a
description of the transfered object class available.
A thread that reads Messages from a SimpleQueue and writes them
to a stream through a SmartObjectOutputStream AFTER timestamping them
using a internal settable timer.
A hashtable with ServerID keys and Long Values containing the timestamp
diferences (=(local time)-(remote time)) of the current server to all
the connected remote servers.
This defines the default amount of the the client waits inside
removeFromGroup(), before returning false, if there is any ongoing
remove from group activity.
Defines the default sleep delay for the read thread
in the case of a call to the simple version of login()
You may set this to some other value than the default.