Uses of Interface
io.netty.buffer.ByteBufAllocator
-
Packages that use ByteBufAllocator Package Description io.netty.buffer Abstraction of a byte buffer - the fundamental data structure to represent a low-level binary and text message.io.netty.channel The core channel API which is asynchronous and event-driven abstraction of various transports such as a NIO Channel.io.netty.channel.epoll Optimized transport for linux which uses EPOLL Edge-Triggered Mode for maximal performance.io.netty.channel.kqueue BSD specific transport.io.netty.channel.sctp Abstract SCTP socket interfaces which extend the core channel API.io.netty.channel.socket Abstract TCP and UDP socket interfaces which extend the core channel API.io.netty.channel.socket.nio NIO-based socket channel API implementation - recommended for a large number of connections (>= 1000).io.netty.channel.socket.oio Old blocking I/O based socket channel API implementation - recommended for a small number of connections (< 1000).io.netty.channel.unix Unix specific transport.io.netty.handler.codec Extensible decoder and its common implementations which deal with the packet fragmentation and reassembly issue found in a stream-based transport such as TCP/IP.io.netty.handler.codec.base64 io.netty.handler.codec.http Encoder, decoder and their related message types for HTTP.io.netty.handler.codec.http.multipart HTTP multipart support.io.netty.handler.codec.http.websocketx Encoder, decoder, handshakers and their related message types for Web Socket data frames.io.netty.handler.codec.http2 Handlers for sending and receiving HTTP/2 frames.io.netty.handler.codec.mqtt Encoder, decoder and different Message Types for MQTT.io.netty.handler.codec.redis Encoder, decoder for Redis.io.netty.handler.codec.spdy Encoder, decoder, session handler and their related message types for the SPDY protocol.io.netty.handler.pcap Capture data and write into Pcap format which helps in troubleshooting.io.netty.handler.ssl SSL · TLS implementation based onSSLEngineio.netty.handler.stream Writes very large data stream asynchronously neither spending a lot of memory nor gettingOutOfMemoryError. -
-
Uses of ByteBufAllocator in io.netty.buffer
Classes in io.netty.buffer that implement ByteBufAllocator Modifier and Type Class Description classAbstractByteBufAllocatorSkeletalByteBufAllocatorimplementation to extend.classAdaptiveByteBufAllocatorAn auto-tuning poolingByteBufAllocator, that follows an anti-generational hypothesis.classPooledByteBufAllocatorclassUnpooledByteBufAllocatorSimplisticByteBufAllocatorimplementation that does not pool anything.Fields in io.netty.buffer declared as ByteBufAllocator Modifier and Type Field Description private ByteBufAllocatorCompositeByteBuf. allocprivate ByteBufAllocatorEmptyByteBuf. allocprivate ByteBufAllocatorUnpooledDirectByteBuf. allocprivate ByteBufAllocatorUnpooledHeapByteBuf. allocprivate static ByteBufAllocatorUnpooled. ALLOCprivate ByteBufAllocatorAdaptiveByteBufAllocator.DirectChunkAllocator. allocatorprivate ByteBufAllocatorAdaptiveByteBufAllocator.HeapChunkAllocator. allocatorprivate ByteBufAllocatorFixedCompositeByteBuf. allocatorprivate ByteBufAllocatorPooledByteBuf. allocatorprivate ByteBufAllocatorReadOnlyByteBufferBuf. allocatorstatic ByteBufAllocatorByteBufAllocator. DEFAULT(package private) static ByteBufAllocatorByteBufUtil. DEFAULT_ALLOCATORMethods in io.netty.buffer that return ByteBufAllocator Modifier and Type Method Description ByteBufAllocatorAbstractPooledDerivedByteBuf. alloc()ByteBufAllocatorAbstractUnpooledSlicedByteBuf. alloc()ByteBufAllocatorAdaptivePoolingAllocator.AdaptiveByteBuf. alloc()abstract ByteBufAllocatorByteBuf. alloc()Returns theByteBufAllocatorwhich created this buffer.ByteBufAllocatorCompositeByteBuf. alloc()ByteBufAllocatorDuplicatedByteBuf. alloc()Deprecated.ByteBufAllocatorEmptyByteBuf. alloc()ByteBufAllocatorFixedCompositeByteBuf. alloc()ByteBufAllocatorPooledByteBuf. alloc()ByteBufAllocatorReadOnlyByteBuf. alloc()Deprecated.ByteBufAllocatorReadOnlyByteBufferBuf. alloc()ByteBufAllocatorSwappedByteBuf. alloc()Deprecated.ByteBufAllocatorUnpooledDirectByteBuf. alloc()ByteBufAllocatorUnpooledHeapByteBuf. alloc()ByteBufAllocatorWrappedByteBuf. alloc()ByteBufAllocatorWrappedCompositeByteBuf. alloc()Methods in io.netty.buffer with parameters of type ByteBufAllocator Modifier and Type Method Description static ByteBufByteBufUtil. encodeString(ByteBufAllocator alloc, java.nio.CharBuffer src, java.nio.charset.Charset charset)Encode the givenCharBufferusing the givenCharsetinto a newByteBufwhich is allocated via theByteBufAllocator.static ByteBufByteBufUtil. encodeString(ByteBufAllocator alloc, java.nio.CharBuffer src, java.nio.charset.Charset charset, int extraCapacity)Encode the givenCharBufferusing the givenCharsetinto a newByteBufwhich is allocated via theByteBufAllocator.(package private) static ByteBufByteBufUtil. encodeString0(ByteBufAllocator alloc, boolean enforceHeap, java.nio.CharBuffer src, java.nio.charset.Charset charset, int extraCapacity)(package private) static UnpooledUnsafeDirectByteBufUnsafeByteBufUtil. newUnsafeDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity, boolean allowSectionedInternalNioBufferAccess)static ByteBufByteBufUtil. readBytes(ByteBufAllocator alloc, ByteBuf buffer, int length)Read the given amount of bytes into a newByteBufthat is allocated from theByteBufAllocator.(package private) static voidByteBufUtil. readBytes(ByteBufAllocator allocator, java.nio.ByteBuffer buffer, int position, int length, java.io.OutputStream out)Read bytes from the givenByteBufferinto the givenOutputStreamusing thepositionandlength.static ByteBufByteBufUtil. writeAscii(ByteBufAllocator alloc, java.lang.CharSequence seq)static ByteBufByteBufUtil. writeUtf8(ByteBufAllocator alloc, java.lang.CharSequence seq)Constructors in io.netty.buffer with parameters of type ByteBufAllocator Constructor Description CompositeByteBuf(ByteBufAllocator alloc)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, int initSize)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, ByteBuf... buffers)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, ByteBuf[] buffers, int offset)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, CompositeByteBuf.ByteWrapper<T> wrapper, T[] buffers, int offset)CompositeByteBuf(ByteBufAllocator alloc, boolean direct, int maxNumComponents, java.lang.Iterable<ByteBuf> buffers)DirectChunkAllocator(ByteBufAllocator allocator)EmptyByteBuf(ByteBufAllocator alloc)EmptyByteBuf(ByteBufAllocator alloc, java.nio.ByteOrder order)FixedCompositeByteBuf(ByteBufAllocator allocator, ByteBuf... buffers)HeapChunkAllocator(ByteBufAllocator allocator)ReadOnlyByteBufferBuf(ByteBufAllocator allocator, java.nio.ByteBuffer buffer)ReadOnlyUnsafeDirectByteBuf(ByteBufAllocator allocator, java.nio.ByteBuffer byteBuffer)UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)Creates a new direct buffer.UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity, boolean allowSectionedInternalNioBufferAccess)Creates a new direct buffer.UnpooledDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity)Creates a new direct buffer by wrapping the specified initial buffer.UnpooledDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity, boolean doFree, boolean slice)UnpooledHeapByteBuf(ByteBufAllocator alloc, byte[] initialArray, int maxCapacity)Creates a new heap buffer with an existing byte array.UnpooledHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)Creates a new heap buffer with a newly allocated byte array.UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)Creates a new direct buffer.UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity, boolean allowSectionedInternalNioBufferAccess)UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity)Creates a new direct buffer by wrapping the specified initial buffer.UnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, java.nio.ByteBuffer initialBuffer, int maxCapacity, boolean doFree)UnpooledUnsafeHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity)Creates a new heap buffer with a newly allocated byte array.UnpooledUnsafeNoCleanerDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity, boolean allowSectionedInternalNioBufferAccess)WrappedUnpooledUnsafeDirectByteBuf(ByteBufAllocator alloc, long memoryAddress, int size, boolean doFree) -
Uses of ByteBufAllocator in io.netty.channel
Classes in io.netty.channel that implement ByteBufAllocator Modifier and Type Class Description classPreferHeapByteBufAllocatorWraps anotherByteBufAllocatorand use heapbuffers everywhere except when a direct buffer is explicit requested.Fields in io.netty.channel declared as ByteBufAllocator Modifier and Type Field Description private ByteBufAllocatorDefaultChannelConfig. allocatorprivate ByteBufAllocatorPreferHeapByteBufAllocator. allocatorFields in io.netty.channel with type parameters of type ByteBufAllocator Modifier and Type Field Description static ChannelOption<ByteBufAllocator>ChannelOption. ALLOCATORMethods in io.netty.channel that return ByteBufAllocator Modifier and Type Method Description ByteBufAllocatorAbstractChannel. alloc()ByteBufAllocatorAbstractChannelHandlerContext. alloc()ByteBufAllocatorChannel. alloc()Return the assignedByteBufAllocatorwhich will be used to allocateByteBufs.ByteBufAllocatorChannelHandlerContext. alloc()Return the assignedByteBufAllocatorwhich will be used to allocateByteBufs.ByteBufAllocatorCombinedChannelDuplexHandler.DelegatingChannelHandlerContext. alloc()ByteBufAllocatorChannelConfig. getAllocator()ReturnsByteBufAllocatorwhich is used for the channel to allocate buffers.ByteBufAllocatorDefaultChannelConfig. getAllocator()Methods in io.netty.channel with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBufDefaultMaxBytesRecvByteBufAllocator.HandleImpl. allocate(ByteBufAllocator alloc)ByteBufDefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle. allocate(ByteBufAllocator alloc)ByteBufRecvByteBufAllocator.DelegatingHandle. allocate(ByteBufAllocator alloc)ByteBufRecvByteBufAllocator.Handle. allocate(ByteBufAllocator alloc)Deprecated.Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.protected abstract ByteBufAbstractCoalescingBufferQueue. compose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)Calculate the result ofcurrent + next.protected ByteBufCoalescingBufferQueue. compose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)protected ByteBufAbstractCoalescingBufferQueue. composeFirst(ByteBufAllocator allocator, ByteBuf first)Deprecated.Use {AbstractCoalescingBufferQueue#composeFirst(ByteBufAllocator, ByteBuf, int)}protected ByteBufAbstractCoalescingBufferQueue. composeFirst(ByteBufAllocator allocator, ByteBuf first, int bufferSize)Calculate the firstByteBufwhich will be used in subsequent calls toAbstractCoalescingBufferQueue.compose(ByteBufAllocator, ByteBuf, ByteBuf).protected ByteBufAbstractCoalescingBufferQueue. composeIntoComposite(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)protected ByteBufAbstractCoalescingBufferQueue. copyAndCompose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)ByteBufAbstractCoalescingBufferQueue. remove(ByteBufAllocator alloc, int bytes, ChannelPromise aggregatePromise)Remove aByteBuffrom the queue with the specified number of bytes.ChannelConfigChannelConfig. setAllocator(ByteBufAllocator allocator)Set theByteBufAllocatorwhich is used for the channel to allocate buffers.ChannelConfigDefaultChannelConfig. setAllocator(ByteBufAllocator allocator)Constructors in io.netty.channel with parameters of type ByteBufAllocator Constructor Description PreferHeapByteBufAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.epoll
Methods in io.netty.channel.epoll that return ByteBufAllocator Modifier and Type Method Description protected ByteBufAllocatorAbstractEpollStreamChannel.EpollSocketWritableByteChannel. alloc()Methods in io.netty.channel.epoll with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBufEpollRecvByteAllocatorHandle. allocate(ByteBufAllocator alloc)private static ByteBufAbstractEpollChannel. newDirectBuffer0(java.lang.Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity)EpollChannelConfigEpollChannelConfig. setAllocator(ByteBufAllocator allocator)EpollDatagramChannelConfigEpollDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)EpollDomainDatagramChannelConfigEpollDomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)EpollDomainSocketChannelConfigEpollDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)EpollServerChannelConfigEpollServerChannelConfig. setAllocator(ByteBufAllocator allocator)EpollServerSocketChannelConfigEpollServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)EpollSocketChannelConfigEpollSocketChannelConfig. setAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue that return ByteBufAllocator Modifier and Type Method Description protected ByteBufAllocatorAbstractKQueueStreamChannel.KQueueSocketWritableByteChannel. alloc()Methods in io.netty.channel.kqueue with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBufKQueueRecvByteAllocatorHandle. allocate(ByteBufAllocator alloc)private static ByteBufAbstractKQueueChannel. newDirectBuffer0(java.lang.Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity)KQueueChannelConfigKQueueChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueDatagramChannelConfigKQueueDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueDomainDatagramChannelConfigKQueueDomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueDomainSocketChannelConfigKQueueDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueServerChannelConfigKQueueServerChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueServerSocketChannelConfigKQueueServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)KQueueSocketChannelConfigKQueueSocketChannelConfig. setAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.sctp
Methods in io.netty.channel.sctp with parameters of type ByteBufAllocator Modifier and Type Method Description SctpChannelConfigDefaultSctpChannelConfig. setAllocator(ByteBufAllocator allocator)SctpServerChannelConfigDefaultSctpServerChannelConfig. setAllocator(ByteBufAllocator allocator)SctpChannelConfigSctpChannelConfig. setAllocator(ByteBufAllocator allocator)SctpServerChannelConfigSctpServerChannelConfig. setAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.socket
Methods in io.netty.channel.socket with parameters of type ByteBufAllocator Modifier and Type Method Description DatagramChannelConfigDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)DatagramChannelConfigDefaultDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)ServerSocketChannelConfigDefaultServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)SocketChannelConfigDefaultSocketChannelConfig. setAllocator(ByteBufAllocator allocator)DuplexChannelConfigDuplexChannelConfig. setAllocator(ByteBufAllocator allocator)ServerSocketChannelConfigServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)SocketChannelConfigSocketChannelConfig. setAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.socket.nio
Methods in io.netty.channel.socket.nio with parameters of type ByteBufAllocator Modifier and Type Method Description NioDomainSocketChannel.NioDomainSocketChannelConfigNioDomainSocketChannel.NioDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.channel.socket.oio
Methods in io.netty.channel.socket.oio with parameters of type ByteBufAllocator Modifier and Type Method Description OioDatagramChannelConfigDefaultOioDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)OioServerSocketChannelConfigDefaultOioServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)Deprecated.OioSocketChannelConfigDefaultOioSocketChannelConfig. setAllocator(ByteBufAllocator allocator)Deprecated.OioDatagramChannelConfigOioDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)Deprecated.OioServerSocketChannelConfigOioServerSocketChannelConfig. setAllocator(ByteBufAllocator allocator)Deprecated.OioSocketChannelConfigOioSocketChannelConfig. setAllocator(ByteBufAllocator allocator)Deprecated. -
Uses of ByteBufAllocator in io.netty.channel.unix
Classes in io.netty.channel.unix that implement ByteBufAllocator Modifier and Type Class Description classPreferredDirectByteBufAllocatorFields in io.netty.channel.unix declared as ByteBufAllocator Modifier and Type Field Description private ByteBufAllocatorPreferredDirectByteBufAllocator. allocatorMethods in io.netty.channel.unix that return ByteBufAllocator Modifier and Type Method Description protected abstract ByteBufAllocatorSocketWritableByteChannel. alloc()Methods in io.netty.channel.unix with parameters of type ByteBufAllocator Modifier and Type Method Description DomainDatagramChannelConfigDomainDatagramChannelConfig. setAllocator(ByteBufAllocator allocator)DomainSocketChannelConfigDomainSocketChannelConfig. setAllocator(ByteBufAllocator allocator)voidPreferredDirectByteBufAllocator. updateAllocator(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.handler.codec
Methods in io.netty.handler.codec that return ByteBufAllocator Modifier and Type Method Description ByteBufAllocatorReplayingDecoderByteBuf. alloc()Methods in io.netty.handler.codec with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBufByteToMessageDecoder.Cumulator. cumulate(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf in)(package private) static ByteBufByteToMessageDecoder. expandCumulation(ByteBufAllocator alloc, ByteBuf oldCumulation, ByteBuf in) -
Uses of ByteBufAllocator in io.netty.handler.codec.base64
Methods in io.netty.handler.codec.base64 with parameters of type ByteBufAllocator Modifier and Type Method Description static ByteBufBase64. decode(ByteBuf src, int off, int len, Base64Dialect dialect, ByteBufAllocator allocator)(package private) ByteBufBase64.Decoder. decode(ByteBuf src, int off, int len, ByteBufAllocator allocator, Base64Dialect dialect)static ByteBufBase64. encode(ByteBuf src, int off, int len, boolean breakLines, Base64Dialect dialect, ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ByteBufAllocator Modifier and Type Method Description HttpContentHttpChunkedInput. readChunk(ByteBufAllocator allocator) -
Uses of ByteBufAllocator in io.netty.handler.codec.http.multipart
Methods in io.netty.handler.codec.http.multipart with parameters of type ByteBufAllocator Modifier and Type Method Description HttpContentHttpPostRequestEncoder. readChunk(ByteBufAllocator allocator)Returns the next available HttpChunk. -
Uses of ByteBufAllocator in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx with parameters of type ByteBufAllocator Modifier and Type Method Description WebSocketFrameWebSocketChunkedInput. readChunk(ByteBufAllocator allocator)Fetches a chunked data from the stream. -
Uses of ByteBufAllocator in io.netty.handler.codec.http2
Methods in io.netty.handler.codec.http2 that return ByteBufAllocator Modifier and Type Method Description ByteBufAllocatorAbstractHttp2StreamChannel. alloc()Methods in io.netty.handler.codec.http2 with parameters of type ByteBufAllocator Modifier and Type Method Description (package private) voidDefaultHttp2FrameReader.HeadersBlockBuilder. addFragment(ByteBuf fragment, int len, ByteBufAllocator alloc, boolean endOfHeaders)Adds a fragment to the block.FullHttpMessageInboundHttp2ToHttpAdapter.ImmediateSendDetector. copyIfNeeded(ByteBufAllocator allocator, FullHttpMessage msg)Determine if a copy must be made after an immediate send happens.private FullHttpMessageHttp2StreamFrameToHttpObjectCodec. newFullMessage(int id, Http2Headers headers, ByteBufAllocator alloc)protected FullHttpMessageInboundHttp2ToHttpAdapter. newMessage(Http2Stream stream, Http2Headers headers, boolean validateHttpHeaders, ByteBufAllocator alloc)Create a newFullHttpMessagebased upon the current connection parametersHttp2DataFrameHttp2DataChunkedInput. readChunk(ByteBufAllocator allocator)static FullHttpRequestHttpConversionUtil. toFullHttpRequest(int streamId, Http2Headers http2Headers, ByteBufAllocator alloc, boolean validateHttpHeaders)Create a new object to contain the request datastatic FullHttpResponseHttpConversionUtil. toFullHttpResponse(int streamId, Http2Headers http2Headers, ByteBufAllocator alloc, boolean validateHttpHeaders)Create a new object to contain the response data -
Uses of ByteBufAllocator in io.netty.handler.codec.mqtt
Methods in io.netty.handler.codec.mqtt with parameters of type ByteBufAllocator Modifier and Type Method Description private static ByteBufMqttEncoder. encodeMessageWithOnlySingleByteFixedHeader(ByteBufAllocator byteBufAllocator, MqttMessage message)private static ByteBufMqttEncoder. encodeMessageWithOnlySingleByteFixedHeaderAndMessageId(ByteBufAllocator byteBufAllocator, MqttMessage message)private static ByteBufMqttEncoder. encodeProperties(ByteBufAllocator byteBufAllocator, MqttProperties mqttProperties)private static ByteBufMqttEncoder. encodePropertiesIfNeeded(MqttVersion mqttVersion, ByteBufAllocator byteBufAllocator, MqttProperties mqttProperties) -
Uses of ByteBufAllocator in io.netty.handler.codec.redis
Methods in io.netty.handler.codec.redis with parameters of type ByteBufAllocator Modifier and Type Method Description private voidRedisEncoder. writeArrayHeader(ByteBufAllocator allocator, boolean isNull, long length, java.util.List<java.lang.Object> out)private voidRedisEncoder. writeArrayHeader(ByteBufAllocator allocator, ArrayHeaderRedisMessage msg, java.util.List<java.lang.Object> out)Write array header only without body.private voidRedisEncoder. writeArrayMessage(ByteBufAllocator allocator, ArrayRedisMessage msg, java.util.List<java.lang.Object> out)Write full constructed array message.private static voidRedisEncoder. writeBulkStringContent(ByteBufAllocator allocator, BulkStringRedisContent msg, java.util.List<java.lang.Object> out)private voidRedisEncoder. writeBulkStringHeader(ByteBufAllocator allocator, BulkStringHeaderRedisMessage msg, java.util.List<java.lang.Object> out)private static voidRedisEncoder. writeErrorMessage(ByteBufAllocator allocator, ErrorRedisMessage msg, java.util.List<java.lang.Object> out)private voidRedisEncoder. writeFullBulkStringMessage(ByteBufAllocator allocator, FullBulkStringRedisMessage msg, java.util.List<java.lang.Object> out)private static voidRedisEncoder. writeInlineCommandMessage(ByteBufAllocator allocator, InlineCommandRedisMessage msg, java.util.List<java.lang.Object> out)private voidRedisEncoder. writeIntegerMessage(ByteBufAllocator allocator, IntegerRedisMessage msg, java.util.List<java.lang.Object> out)private voidRedisEncoder. writeRedisMessage(ByteBufAllocator allocator, RedisMessage msg, java.util.List<java.lang.Object> out)private static voidRedisEncoder. writeSimpleStringMessage(ByteBufAllocator allocator, SimpleStringRedisMessage msg, java.util.List<java.lang.Object> out)private static voidRedisEncoder. writeString(ByteBufAllocator allocator, RedisMessageType type, java.lang.String content, java.util.List<java.lang.Object> out) -
Uses of ByteBufAllocator in io.netty.handler.codec.spdy
Methods in io.netty.handler.codec.spdy with parameters of type ByteBufAllocator Modifier and Type Method Description private static FullHttpRequestSpdyHttpDecoder. createHttpRequest(SpdyHeadersFrame requestFrame, ByteBufAllocator alloc)private FullHttpResponseSpdyHttpDecoder. createHttpResponse(SpdyHeadersFrame responseFrame, ByteBufAllocator alloc)(package private) abstract voidSpdyHeaderBlockDecoder. decode(ByteBufAllocator alloc, ByteBuf headerBlock, SpdyHeadersFrame frame)Decodes a SPDY Header Block, adding the Name/Value pairs to the given Headers frame.(package private) voidSpdyHeaderBlockRawDecoder. decode(ByteBufAllocator alloc, ByteBuf headerBlock, SpdyHeadersFrame frame)(package private) voidSpdyHeaderBlockZlibDecoder. decode(ByteBufAllocator alloc, ByteBuf headerBlock, SpdyHeadersFrame frame)private intSpdyHeaderBlockZlibDecoder. decompress(ByteBufAllocator alloc, SpdyHeadersFrame frame)(package private) abstract ByteBufSpdyHeaderBlockEncoder. encode(ByteBufAllocator alloc, SpdyHeadersFrame frame)private ByteBufSpdyHeaderBlockJZlibEncoder. encode(ByteBufAllocator alloc)ByteBufSpdyHeaderBlockJZlibEncoder. encode(ByteBufAllocator alloc, SpdyHeadersFrame frame)ByteBufSpdyHeaderBlockRawEncoder. encode(ByteBufAllocator alloc, SpdyHeadersFrame frame)private ByteBufSpdyHeaderBlockZlibEncoder. encode(ByteBufAllocator alloc, int len)ByteBufSpdyHeaderBlockZlibEncoder. encode(ByteBufAllocator alloc, SpdyHeadersFrame frame)ByteBufSpdyFrameEncoder. encodeDataFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf data)ByteBufSpdyFrameEncoder. encodeGoAwayFrame(ByteBufAllocator allocator, int lastGoodStreamId, int statusCode)ByteBufSpdyFrameEncoder. encodeHeadersFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf headerBlock)ByteBufSpdyFrameEncoder. encodePingFrame(ByteBufAllocator allocator, int id)ByteBufSpdyFrameEncoder. encodeRstStreamFrame(ByteBufAllocator allocator, int streamId, int statusCode)ByteBufSpdyFrameEncoder. encodeSettingsFrame(ByteBufAllocator allocator, SpdySettingsFrame spdySettingsFrame)ByteBufSpdyFrameEncoder. encodeSynReplyFrame(ByteBufAllocator allocator, int streamId, boolean last, ByteBuf headerBlock)ByteBufSpdyFrameEncoder. encodeSynStreamFrame(ByteBufAllocator allocator, int streamId, int associatedToStreamId, byte priority, boolean last, boolean unidirectional, ByteBuf headerBlock)ByteBufSpdyFrameEncoder. encodeUnknownFrame(ByteBufAllocator allocator, int frameType, byte flags, ByteBuf data)ByteBufSpdyFrameEncoder. encodeWindowUpdateFrame(ByteBufAllocator allocator, int streamId, int deltaWindowSize)private voidSpdyHeaderBlockZlibDecoder. ensureBuffer(ByteBufAllocator alloc) -
Uses of ByteBufAllocator in io.netty.handler.pcap
Methods in io.netty.handler.pcap with parameters of type ByteBufAllocator Modifier and Type Method Description private voidPcapWriteHandler. completeTCPWrite(java.net.InetSocketAddress srcAddr, java.net.InetSocketAddress dstAddr, ByteBuf tcpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx)Write TCP/IP L3 and L2 here.private voidPcapWriteHandler. completeUDPWrite(java.net.InetSocketAddress srcAddr, java.net.InetSocketAddress dstAddr, ByteBuf udpBuf, ByteBufAllocator byteBufAllocator, ChannelHandlerContext ctx)Write UDP/IP L3 and L2 here.private voidPcapWriteHandler. handleTcpPacket(ChannelHandlerContext ctx, ByteBuf packet, boolean isWriteOperation, ByteBufAllocator byteBufAllocator) -
Uses of ByteBufAllocator in io.netty.handler.ssl
Fields in io.netty.handler.ssl declared as ByteBufAllocator Modifier and Type Field Description (package private) ByteBufAllocatorReferenceCountedOpenSslEngine. allocMethods in io.netty.handler.ssl with parameters of type ByteBufAllocator Modifier and Type Method Description (package private) abstract ByteBufSslHandler.SslEngineType. allocateWrapBuffer(SslHandler handler, ByteBufAllocator allocator, int pendingBytes, int numComponents)private static ByteBufPemX509Certificate. append(ByteBufAllocator allocator, boolean useDirect, PemEncoded encoded, int count, ByteBuf pem)Appends thePemEncodedvalue to theByteBuf(last arg) and returns it.private static ByteBufPemX509Certificate. append(ByteBufAllocator allocator, boolean useDirect, java.security.cert.X509Certificate cert, int count, ByteBuf pem)Appends theX509Certificatevalue to theByteBuf(last arg) and returns it.(package private) OpenSslKeyMaterialOpenSslCachingKeyMaterialProvider. chooseKeyMaterial(ByteBufAllocator allocator, java.lang.String alias)(package private) OpenSslKeyMaterialOpenSslKeyMaterialProvider. chooseKeyMaterial(ByteBufAllocator allocator, java.lang.String alias)Returns theOpenSslKeyMaterialornull(if none) that should be used during the handshake by OpenSSL.(package private) OpenSslKeyMaterialOpenSslX509KeyManagerFactory.OpenSslKeyManagerFactorySpi.ProviderFactory.OpenSslPopulatedKeyMaterialProvider. chooseKeyMaterial(ByteBufAllocator allocator, java.lang.String alias)protected ByteBufSslHandlerCoalescingBufferQueue. compose(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf next)protected ByteBufSslHandlerCoalescingBufferQueue. composeFirst(ByteBufAllocator allocator, ByteBuf first, int bufferSize)private javax.net.ssl.SSLEngineJdkSslContext. configureAndWrapEngine(javax.net.ssl.SSLEngine engine, ByteBufAllocator alloc)private static ByteBufPemX509Certificate. newBuffer(ByteBufAllocator allocator, boolean useDirect, int initialCapacity)javax.net.ssl.SSLEngineDelegatingSslContext. newEngine(ByteBufAllocator alloc)javax.net.ssl.SSLEngineDelegatingSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)javax.net.ssl.SSLEngineJdkSslContext. newEngine(ByteBufAllocator alloc)javax.net.ssl.SSLEngineJdkSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)javax.net.ssl.SSLEngineReferenceCountedOpenSslContext. newEngine(ByteBufAllocator alloc)Returns a new server-sideSSLEnginewith the current configuration.javax.net.ssl.SSLEngineReferenceCountedOpenSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)abstract javax.net.ssl.SSLEngineSslContext. newEngine(ByteBufAllocator alloc)Creates a newSSLEngine.abstract javax.net.ssl.SSLEngineSslContext. newEngine(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)Creates a newSSLEngineusing advisory peer information.(package private) javax.net.ssl.SSLEngineOpenSslContext. newEngine0(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean jdkCompatibilityMode)(package private) javax.net.ssl.SSLEngineReferenceCountedOpenSslContext. newEngine0(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean jdkCompatibilityMode)protected SslHandlerDelegatingSslContext. newHandler(ByteBufAllocator alloc, boolean startTls)protected SslHandlerDelegatingSslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)protected SslHandlerDelegatingSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)protected SslHandlerDelegatingSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor executor)protected SslHandlerReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, boolean startTls)protected SslHandlerReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)protected SslHandlerReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)protected SslHandlerReferenceCountedOpenSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor executor)SslHandlerSslContext. newHandler(ByteBufAllocator alloc)Create a new SslHandler.protected SslHandlerSslContext. newHandler(ByteBufAllocator alloc, boolean startTls)Create a new SslHandler.protected SslHandlerSslContext. newHandler(ByteBufAllocator alloc, boolean startTls, java.util.concurrent.Executor executor)Create a new SslHandler.SslHandlerSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort)Creates a newSslHandlerprotected SslHandlerSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls)Create a new SslHandler.protected SslHandlerSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean startTls, java.util.concurrent.Executor delegatedTaskExecutor)SslHandlerSslContext. newHandler(ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, java.util.concurrent.Executor delegatedTaskExecutor)Creates a newSslHandlerwith advisory peer information.SslHandlerSslContext. newHandler(ByteBufAllocator alloc, java.util.concurrent.Executor delegatedTaskExecutor)Creates a newSslHandler.protected SslHandlerSniHandler. newSslHandler(SslContext context, ByteBufAllocator allocator)(package private) static ByteBufSslUtils. toBase64(ByteBufAllocator allocator, ByteBuf src)Same asBase64.encode(ByteBuf, boolean)but allows the use of a customByteBufAllocator.(package private) static longReferenceCountedOpenSslContext. toBIO(ByteBufAllocator allocator, PemEncoded pem)(package private) static longReferenceCountedOpenSslContext. toBIO(ByteBufAllocator allocator, java.security.cert.X509Certificate... certChain)(package private) static longReferenceCountedOpenSslContext. toBIO(ByteBufAllocator allocator, java.security.PrivateKey key)(package private) static PemEncodedPemPrivateKey. toPEM(ByteBufAllocator allocator, boolean useDirect, byte[] bytes)(package private) static PemEncodedPemPrivateKey. toPEM(ByteBufAllocator allocator, boolean useDirect, java.security.PrivateKey key)Creates aPemEncodedvalue from thePrivateKey.(package private) static PemEncodedPemX509Certificate. toPEM(ByteBufAllocator allocator, boolean useDirect, java.security.cert.X509Certificate... chain)Creates aPemEncodedvalue from theX509Certificates.private javax.net.ssl.SSLEngineResultSslHandler. wrap(ByteBufAllocator alloc, javax.net.ssl.SSLEngine engine, ByteBuf in, ByteBuf out)private javax.net.ssl.SSLEngineResultSslHandler. wrapMultiple(ByteBufAllocator alloc, javax.net.ssl.SSLEngine engine, ByteBuf in, ByteBuf out)javax.net.ssl.SSLEngineJdkAlpnApplicationProtocolNegotiator.AlpnWrapper. wrapSslEngine(javax.net.ssl.SSLEngine engine, ByteBufAllocator alloc, JdkApplicationProtocolNegotiator applicationNegotiator, boolean isServer)javax.net.ssl.SSLEngineJdkAlpnApplicationProtocolNegotiator.FailureWrapper. wrapSslEngine(javax.net.ssl.SSLEngine engine, ByteBufAllocator alloc, JdkApplicationProtocolNegotiator applicationNegotiator, boolean isServer)(package private) abstract javax.net.ssl.SSLEngineJdkApplicationProtocolNegotiator.AllocatorAwareSslEngineWrapperFactory. wrapSslEngine(javax.net.ssl.SSLEngine engine, ByteBufAllocator alloc, JdkApplicationProtocolNegotiator applicationNegotiator, boolean isServer)Abstract factory pattern for wrapping anSSLEngineobject.Constructors in io.netty.handler.ssl with parameters of type ByteBufAllocator Constructor Description OpenSslEngine(OpenSslContext context, ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean jdkCompatibilityMode, java.lang.String endpointIdentificationAlgorithm)ReferenceCountedOpenSslEngine(ReferenceCountedOpenSslContext context, ByteBufAllocator alloc, java.lang.String peerHost, int peerPort, boolean jdkCompatibilityMode, boolean leakDetection, java.lang.String endpointIdentificationAlgorithm)Create a new instance. -
Uses of ByteBufAllocator in io.netty.handler.stream
Methods in io.netty.handler.stream with parameters of type ByteBufAllocator Modifier and Type Method Description ByteBufChunkedFile. readChunk(ByteBufAllocator allocator)BChunkedInput. readChunk(ByteBufAllocator allocator)Fetches a chunked data from the stream.ByteBufChunkedNioFile. readChunk(ByteBufAllocator allocator)ByteBufChunkedNioStream. readChunk(ByteBufAllocator allocator)ByteBufChunkedStream. readChunk(ByteBufAllocator allocator)
-