Package | Description |
---|---|
net.grinder.communication |
The Grinder communication subsystem.
|
net.grinder.messages.console |
Messages that can be sent to the console.
|
net.grinder.synchronisation |
Synchronisation classes.
|
net.grinder.synchronisation.messages |
Messages used by distributed implementations of the synchronisation classes.
|
Modifier and Type | Class and Description |
---|---|
static class |
Acceptor.ShutdownException
Indicates the Acceptor has been shut down.
|
static class |
BlockingSender.NoResponseException
Exception indicating that the server chose to send no response back
to a
BlockingSender.blockingSend(Message) . |
Modifier and Type | Method and Description |
---|---|
Message |
BlockingSender.blockingSend(Message message)
Send the given message and await a response.
|
Message |
ClientSender.blockingSend(Message message)
Send the given message and await a response.
|
Message |
MessageDispatchRegistry.BlockingHandler.blockingSend(T message)
Handle the given message.
|
static ClientSender |
ClientSender.connect(ClientReceiver clientReceiver)
Factory method that makes a
Sender around the existing TCP
connection owned by the supplied ClientReceiver . |
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 . |
void |
QueuedSenderDecorator.flush()
Send any pending messages queued with
Sender.send(net.grinder.communication.Message) . |
void |
QueuedSender.flush()
Send any pending messages queued with
Sender.send(net.grinder.communication.Message) . |
void |
TeeSender.handle(Message message)
Handle the given message.
|
void |
MessageDispatchRegistry.Handler.handle(T message)
Handle the given message.
|
void |
ServerReceiver.receiveFrom(Acceptor acceptor,
ConnectionType[] connectionTypes,
int numberOfThreads,
long idleThreadPollDelay,
long inactiveClientTimeOut)
Registers a new
Acceptor from which the ServerReceiver
should process messages. |
protected OutputStream |
FanOutServerSender.resourceToOutputStream(ResourcePool.Resource resource)
Return an output stream from a socket resource.
|
void |
FanOutServerSender.send(Address address,
Message message)
Send a message to a particular address.
|
void |
QueuedSenderDecorator.send(Message message)
Queue the given message for later sending.
|
void |
IgnoreShutdownSender.send(Message message)
Send the given message using the delegate.
|
void |
MessageDispatchSender.send(Message message)
Sends a message to each handler until one claims to have handled the
message.
|
void |
Sender.send(Message message)
Send the given message.
|
void |
TeeSender.send(Message message)
Send the given message.
|
void |
ClientSender.sendKeepAlive()
Send a no-op message that keeps this connection alive.
|
void |
AddressAwareMessage.setAddress(Address address)
Set the origin address.
|
void |
Acceptor.shutdown()
Shut down this acceptor.
|
Message |
ServerReceiver.waitForMessage()
Block until a message is available, or another thread has called
ServerReceiver.shutdown() . |
Message |
StreamReceiver.waitForMessage()
Block until a message is available.
|
Message |
Receiver.waitForMessage()
Block until a message is available, or another thread has
called
Receiver.shutdown() . |
Constructor and Description |
---|
Acceptor(String addressString,
int port,
int numberOfThreads,
TimeAuthority timeAuthority)
Constructor.
|
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 |
AbstractBarrierGroups.BarrierGroupImplementation.addBarrier()
Increase the number of barriers in the group.
|
void |
BarrierGroup.addBarrier()
Increase the number of barriers in the group.
|
void |
AbstractBarrierGroups.BarrierGroupImplementation.addWaiter(BarrierIdentity barrierIdentity)
Add a waiter.
|
void |
BarrierGroup.addWaiter(BarrierIdentity barrierIdentity)
Add a waiter.
|
void |
BarrierImplementation.await()
Wait until all other barriers with the same name have invoked
Barrier.await() . |
boolean |
BarrierImplementation.await(long timeout)
Equivalent to
await(timeout, TimeUnit.MILLISECONDS) . |
boolean |
BarrierImplementation.await(long timeout,
TimeUnit unit)
Version of
Barrier.await() that allows a timeout to be specified. |
void |
BarrierImplementation.cancel()
Cancel this
Barrier and reduce the total number of instances for
the barrier name. |
void |
AbstractBarrierGroups.cancelAll()
Calls
BarrierGroup.cancelAll() on all of our barrier groups. |
void |
AbstractBarrierGroups.BarrierGroupImplementation.cancelAll()
Cancels all waiters and removes all barriers.
|
void |
BarrierGroup.cancelAll()
Cancels all waiters and removes all barriers.
|
void |
AbstractBarrierGroups.BarrierGroupImplementation.cancelWaiter(BarrierIdentity barrierIdentity)
Cancel a waiter.
|
void |
BarrierGroup.cancelWaiter(BarrierIdentity barrierIdentity)
Cancel a waiter.
|
void |
AbstractBarrierGroups.BarrierGroupImplementation.removeBarriers(long n)
Decrease the number of barriers in the group.
|
void |
BarrierGroup.removeBarriers(long n)
Decrease the number of barriers in the group.
|
Constructor and Description |
---|
BarrierImplementation(BarrierGroup group,
BarrierIdentity.Factory identityFactory)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractBarrierGroupMessage.setAddress(Address address)
Set the origin address.
|
Copyright © 2000-2014. All Rights Reserved.