Modifier and Type | Interface and Description |
---|---|
interface |
Buffer
JDK
ByteBuffer was taken as base for Grizzly
Buffer interface, but Buffer has several extensions:
it's possible to prepend some data to a Buffer and release Buffer, when
it's not required any more. |
Modifier and Type | Class and Description |
---|---|
class |
FileTransfer
A simple class that abstracts
FileChannel.transferTo(long, long, java.nio.channels.WritableByteChannel)
for use with Grizzly 2.0 AsyncQueueWriter . |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
void |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
push back logic is deprecated
|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
void |
AbstractWriter.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
Writer.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
push back logic is deprecated
|
void |
AbstractWriter.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
Writer.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
Modifier and Type | Method and Description |
---|---|
WritableMessage |
AsyncWriteQueueRecord.getWritableMessage() |
Modifier and Type | Method and Description |
---|---|
static AsyncWriteQueueRecord |
AsyncWriteQueueRecord.create(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isUncountable) |
void |
PushBackHandler.onAccept(Connection connection,
WritableMessage message)
Deprecated.
The method is invoked once message is accepted by
Writer . |
void |
PushBackHandler.onPushBack(Connection connection,
WritableMessage message,
PushBackContext pushBackContext)
Deprecated.
The method is invoked if message was refused by
Writer
due to I/O or memory limitations. |
protected void |
AsyncWriteQueueRecord.set(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
void |
AsyncQueueWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncQueueWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
void |
AsyncQueueWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
Constructor and Description |
---|
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
Modifier and Type | Class and Description |
---|---|
class |
BuffersBuffer |
protected class |
ByteBufferManager.SmallByteBufferWrapper
ByteBufferWrapper implementation, which supports trimming. |
class |
ByteBufferWrapper
Buffer implementation, which uses the ByteBuffer underneath. |
class |
CompositeBuffer |
class |
HeapBuffer
Buffer implementation, which uses the ByteBuffer underneath. |
Modifier and Type | Method and Description |
---|---|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
protected long |
TemporarySelectorWriter.write0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult,
long timeout,
TimeUnit timeunit)
Flush the buffer by looping until the
Buffer is empty |
protected abstract long |
TemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
protected long |
TemporarySelectorWriter.write0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult,
long timeout,
TimeUnit timeunit)
Flush the buffer by looping until the
Buffer is empty |
protected abstract long |
TemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
int |
TCPNIOTransport.write(TCPNIOConnection connection,
WritableMessage message) |
int |
TCPNIOTransport.write(TCPNIOConnection connection,
WritableMessage message,
WriteResult currentResult) |
long |
UDPNIOTransport.write(UDPNIOConnection connection,
SocketAddress dstAddress,
WritableMessage message) |
long |
UDPNIOTransport.write(UDPNIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
TCPNIOAsyncQueueWriter.write0(NIOConnection connection,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
UDPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
TCPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Modifier and Type | Method and Description |
---|---|
long |
UDPNIOTransport.write(UDPNIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
TCPNIOAsyncQueueWriter.write0(NIOConnection connection,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
UDPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
protected long |
TCPNIOTemporarySelectorWriter.writeNow0(NIOConnection connection,
SocketAddress dstAddress,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult) |
Copyright © 2015 Oracle Corporation. All rights reserved.