Class NettyNioBufferReleasingAllocator

java.lang.Object

eu.cloudnetservice.driver.network.netty.buffer.NettyNioBufferReleasingAllocator

All Implemented Interfaces:

io.netty5.buffer.AllocatorControl, io.netty5.buffer.BufferAllocator, io.netty5.util.SafeCloseable, AutoCloseable

@Internal
public final class NettyNioBufferReleasingAllocator
extends Object
implements io.netty5.buffer.BufferAllocator, io.netty5.buffer.AllocatorControl

A buffer allocator that is allocating nio buffers and frees them directly when they are closed.

Since:

4.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final record	NettyNioBufferReleasingAllocator.DirectBufferFreeDrop	A drop implementation that ínvokes the cleaner of ByteBuffers directly upon dropping.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private final io.netty5.buffer.bytebuffer.ByteBufferMemoryManager	manager

Constructor Summary

Constructors

Constructor	Description
NettyNioBufferReleasingAllocator()	Constructs a new buffer allocator instance.

Method Summary

Modifier and Type	Method	Description
@NonNull io.netty5.buffer.Buffer	allocate(int size)
void	close()
@NonNull Supplier<io.netty5.buffer.Buffer>	constBufferSupplier(byte[] bytes)
@NonNull io.netty5.buffer.AllocationType	getAllocationType()
@NonNull io.netty5.buffer.BufferAllocator	getAllocator()
boolean	isPooling()
static boolean	notAbleToFreeBuffers()	Get if this allocator can free direct buffers.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty5.buffer.BufferAllocator

compose, compose, compose, copyOf, copyOf, copyOf

Field Details

manager

private final io.netty5.buffer.bytebuffer.ByteBufferMemoryManager manager

closed

private volatile boolean closed

Constructor Details

NettyNioBufferReleasingAllocator

public NettyNioBufferReleasingAllocator()

Constructs a new buffer allocator instance. All instances are backed by a byte buffer memory manager.

Method Details

notAbleToFreeBuffers

public static boolean notAbleToFreeBuffers()

Get if this allocator can free direct buffers. If this method returns false, this allocator shouldn't be used as it does nothing. Use the default netty allocator instead.

Returns:

if this allocator is able to free direct nio buffers.

getAllocationType

@NonNull
public @NonNull io.netty5.buffer.AllocationType getAllocationType()

Specified by:

getAllocationType in interface io.netty5.buffer.BufferAllocator

allocate

@NonNull
public @NonNull io.netty5.buffer.Buffer allocate(int size)

Specified by:

allocate in interface io.netty5.buffer.BufferAllocator

constBufferSupplier

@NonNull
public @NonNull Supplier<io.netty5.buffer.Buffer> constBufferSupplier(byte[] bytes)

Specified by:

constBufferSupplier in interface io.netty5.buffer.BufferAllocator

getAllocator

@NonNull
public @NonNull io.netty5.buffer.BufferAllocator getAllocator()

Specified by:

getAllocator in interface io.netty5.buffer.AllocatorControl

isPooling

public boolean isPooling()

Specified by:

isPooling in interface io.netty5.buffer.BufferAllocator

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface io.netty5.buffer.BufferAllocator

Specified by:

close in interface io.netty5.util.SafeCloseable