org.iids.aos.kernel.ac
Class ACSender

java.lang.Object
  org.iids.aos.kernel.ac.ACSender

public class ACSender
extends java.lang.Object

Sends agent containers to remote AOS kernels. Thread-safe.

Author:

Patrick Verkaik, Arno Bakker

Field Summary

protected AgentContainerTransfer	act Class containing all basic info
protected AuditLogger	auditLogger To log receipts of AC transfers, optionally
protected static org.apache.commons.logging.Log	log
protected java.util.Hashtable<Role,java.util.ArrayList<java.net.Socket>>	role2sockets Maps roles to a list of sockets opened on behalf of a role, used to awaken blocked ACTP shipping threads as part of role deletion
protected javax.net.ssl.SSLSocketFactory	secureSocketFactory If secure, the factory for client sockets

Constructor Summary

ACSender(AgentContainerTransfer act, javax.net.ssl.SSLContext ctx)
Constructor.

Method Summary

boolean	closeACTP(Role r, java.net.Socket socket)
void	closeSockets(Role r)
void	shipAgentContainer(Role r, Endpoint dest, TransactionID tid, int acid, java.lang.String[] userSecSuites) Implements AOSapi.shipAgentContainer()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static final org.apache.commons.logging.Log log

act

protected final AgentContainerTransfer act

Class containing all basic info

secureSocketFactory

protected final javax.net.ssl.SSLSocketFactory secureSocketFactory

If secure, the factory for client sockets

auditLogger

protected AuditLogger auditLogger

To log receipts of AC transfers, optionally

role2sockets

protected java.util.Hashtable<Role,java.util.ArrayList<java.net.Socket>> role2sockets

Maps roles to a list of sockets opened on behalf of a role, used to awaken blocked ACTP shipping threads as part of role deletion

Constructor Detail

ACSender

public ACSender(AgentContainerTransfer act,
                javax.net.ssl.SSLContext ctx)

Constructor.

Method Detail

shipAgentContainer

public void shipAgentContainer(Role r,
                               Endpoint dest,
                               TransactionID tid,
                               int acid,
                               java.lang.String[] userSecSuites)
                        throws KernelException

Implements AOSapi.shipAgentContainer()

Throws:

KernelException

closeACTP

public boolean closeACTP(Role r,
                         java.net.Socket socket)
                  throws java.io.IOException

Throws:

java.io.IOException

closeSockets

public void closeSockets(Role r)