Package | Description |
---|---|
net.grinder.common.processidentity |
Interface representing process identity and status.
|
net.grinder.communication |
The Grinder communication subsystem.
|
net.grinder.console.communication |
Console communication.
|
net.grinder.messages.console |
Messages that can be sent to the console.
|
net.grinder.synchronisation.messages |
Messages used by distributed implementations of the synchronisation classes.
|
Modifier and Type | Class and Description |
---|---|
class |
ProcessAddress<T extends ProcessIdentity>
Base
Address implementation for a process. |
Modifier and Type | Method and Description |
---|---|
boolean |
ProcessAddress.includes(Address address)
Whether this address includes the given address.
|
Modifier and Type | Method and Description |
---|---|
protected Address |
FanOutStreamSender.getAddress(ResourcePool.Resource resource)
We don't support addressing individual streams.
|
protected Address |
FanOutServerSender.getAddress(ResourcePool.Resource resource)
Return the address of a socket.
|
Modifier and Type | Method and Description |
---|---|
static ClientReceiver |
ClientReceiver.connect(Connector connector,
Address address)
Factory method that makes a TCP connection and returns a corresponding
Receiver . |
static ClientSender |
ClientSender.connect(Connector connector,
Address address)
Factory method that makes a TCP connection and returns a corresponding
Sender . |
boolean |
Address.includes(Address address)
Whether this address includes the given address.
|
void |
FanOutServerSender.send(Address address,
Message message)
Send a message to a particular address.
|
void |
AddressAwareMessage.setAddress(Address address)
Set the origin address.
|
Modifier and Type | Method and Description |
---|---|
void |
DistributionControl.clearFileCaches(Address address)
Signal agents matching the given address to clear their file caches.
|
void |
DistributionControlImplementation.clearFileCaches(Address address)
Signal agents matching the given address to clear their file caches.
|
void |
DistributionControl.sendFile(Address address,
FileContents fileContents)
Send a file to the agents matching the given address.
|
void |
DistributionControlImplementation.sendFile(Address address,
FileContents fileContents)
Send a file to the agents matching the given address.
|
void |
ConsoleCommunication.sendToAddressedAgents(Address address,
Message message)
Send the given message to the given agent processes (which may pass it on
to its workers).
|
void |
ConsoleCommunicationImplementation.sendToAddressedAgents(Address address,
Message message)
Send the given message to the given agent processes (which may pass it on
to its workers).
|
void |
DistributionControl.setHighWaterMark(Address address,
CacheHighWaterMark highWaterMark)
Inform agent processes of a checkpoint of the cache state.
|
void |
DistributionControlImplementation.setHighWaterMark(Address address,
CacheHighWaterMark highWaterMark)
Inform agent processes of a checkpoint of the cache state.
|
Modifier and Type | Class and Description |
---|---|
class |
AgentAddress
Agent process address.
|
class |
WorkerAddress
Worker process address.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerProcessReportMessage.setAddress(Address address)
Set the origin address.
|
void |
AgentProcessReportMessage.setAddress(Address address)
Set the origin address.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractBarrierGroupMessage.setAddress(Address address)
Set the origin address.
|
Copyright © 2000-2014. All Rights Reserved.