Package | Description |
---|---|
casa.agentCom |
The package (agentCom = "Agent
Communications") handles connections between agents. The class Channel
is an abstraction of a communication channel.
|
Modifier and Type | Field and Description |
---|---|
private ConcurrentLinkedQueue<Pair<SocketChannel,TCPChannel>> |
SocketServerTCPIP.registerQueue
Used by
SocketServerTCPIP.registerChannel(SocketChannel, TCPChannel) and SocketServerTCPIP.run()
to safely do new registrations without generating an interrupt on the socket listener thread. |
Modifier and Type | Method and Description |
---|---|
private TCPChannel |
SocketServerTCPIP.addConnection(URLDescriptor url,
SelectionKey key,
InfiniteReadWriteByteBuffer initBuffer)
Creates a new
TCPChannel object, and links it to url. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
SocketServerTCPIP.registerChannel(SocketChannel channel,
TCPChannel tcpChannel)
External threads may call this method to register the channel.
|