acs.benchmark.util

Class ManagerAdminClient

java.lang.Object

acs.benchmark.util.ManagerAdminClient

public class ManagerAdminClient
extends java.lang.Object

Dummy manager client for custom manager logins as administrator.

TODO: Unify with similar class in ACS/LGPL/CommonSoftware/containerTests/contLogTest (which builds before this, but does not get installed).

Constructor Summary

Constructors

Constructor and Description
ManagerAdminClient(java.lang.String name, java.util.logging.Logger logger)

Method Summary

Modifier and Type	Method and Description
AuthenticationData	authenticate(long execution_id, java.lang.String question)
boolean	awaitContainerLogin(java.lang.String containerName, long timeout, java.util.concurrent.TimeUnit unit) Allows clients to wait for given container login.
void	client_logged_in(ClientInfo info, long timestamp, long execution_id)
void	client_logged_out(int h, long timestamp)
void	component_activated(ComponentInfo info, long timestamp, long execution_id)
void	component_deactivated(int h, long timestamp)
void	components_available(ComponentInfo[] components)
void	components_released(int[] clients, int[] components, long timestamp)
void	components_requested(int[] clients, int[] components, long timestamp)
void	components_unavailable(java.lang.String[] component_names)
void	container_logged_in(ContainerInfo info, long timestamp, long execution_id) Releases all clients that wait for a given container to log in, see awaitContainerLogin(String, long, TimeUnit).
void	container_logged_out(int h, long timestamp)
void	disconnect()
void	message(short type, java.lang.String message)
java.lang.String	name()
boolean	ping()
void	taggedmessage(short type, short messageID, java.lang.String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagerAdminClient

public ManagerAdminClient(java.lang.String name,
                          java.util.logging.Logger logger)

Method Detail

awaitContainerLogin

public boolean awaitContainerLogin(java.lang.String containerName,
                                   long timeout,
                                   java.util.concurrent.TimeUnit unit)
                            throws java.lang.InterruptedException

Allows clients to wait for given container login. This method is thread-safe.

Throws:

java.lang.InterruptedException

See Also:

CountDownLatch#await(long, TimeUnit)}

client_logged_in

public void client_logged_in(ClientInfo info,
                             long timestamp,
                             long execution_id)

client_logged_out

public void client_logged_out(int h,
                              long timestamp)

component_activated

public void component_activated(ComponentInfo info,
                                long timestamp,
                                long execution_id)

component_deactivated

public void component_deactivated(int h,
                                  long timestamp)

components_released

public void components_released(int[] clients,
                                int[] components,
                                long timestamp)

components_requested

public void components_requested(int[] clients,
                                 int[] components,
                                 long timestamp)

container_logged_in

public void container_logged_in(ContainerInfo info,
                                long timestamp,
                                long execution_id)

Releases all clients that wait for a given container to log in, see awaitContainerLogin(String, long, TimeUnit).

See Also:

si.ijs.maci.AdministratorOperations#container_logged_in(si.ijs.maci.ContainerInfo, long, long)

container_logged_out

public void container_logged_out(int h,
                                 long timestamp)

authenticate

public AuthenticationData authenticate(long execution_id,
                                       java.lang.String question)

components_available

public void components_available(ComponentInfo[] components)

components_unavailable

public void components_unavailable(java.lang.String[] component_names)

disconnect

public void disconnect()

taggedmessage

public void taggedmessage(short type,
                          short messageID,
                          java.lang.String message)

message

public void message(short type,
                    java.lang.String message)

name

public java.lang.String name()

ping

public boolean ping()