public class PooledByteBufAllocator
extends org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.AbstractByteBufAllocator
implements org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBufAllocatorMetricProvider
Modifier and Type | Field and Description |
---|---|
static PooledByteBufAllocator |
DEFAULT |
Constructor and Description |
---|
PooledByteBufAllocator() |
PooledByteBufAllocator(boolean preferDirect) |
PooledByteBufAllocator(boolean preferDirect,
int nHeapArena,
int nDirectArena,
int pageSize,
int maxOrder)
|
PooledByteBufAllocator(boolean preferDirect,
int nHeapArena,
int nDirectArena,
int pageSize,
int maxOrder,
int tinyCacheSize,
int smallCacheSize,
int normalCacheSize)
|
PooledByteBufAllocator(boolean preferDirect,
int nHeapArena,
int nDirectArena,
int pageSize,
int maxOrder,
int tinyCacheSize,
int smallCacheSize,
int normalCacheSize,
boolean useCacheForAllThreads) |
PooledByteBufAllocator(boolean preferDirect,
int nHeapArena,
int nDirectArena,
int pageSize,
int maxOrder,
int tinyCacheSize,
int smallCacheSize,
int normalCacheSize,
boolean useCacheForAllThreads,
int directMemoryCacheAlignment) |
PooledByteBufAllocator(int nHeapArena,
int nDirectArena,
int pageSize,
int maxOrder) |
Modifier and Type | Method and Description |
---|---|
int |
chunkSize()
Deprecated.
use
PooledByteBufAllocatorMetric.chunkSize() . |
static int |
defaultMaxOrder()
Default maximum order - System Property: io.netty.allocator.maxOrder - default 11
|
static int |
defaultNormalCacheSize()
Default normal cache size - System Property: io.netty.allocator.normalCacheSize - default 64
|
static int |
defaultNumDirectArena()
Default number of direct arenas - System Property: io.netty.allocator.numDirectArenas - default 2 * cores
|
static int |
defaultNumHeapArena()
Default number of heap arenas - System Property: io.netty.allocator.numHeapArenas - default 2 * cores
|
static int |
defaultPageSize()
Default buffer page size - System Property: io.netty.allocator.pageSize - default 8192
|
static boolean |
defaultPreferDirect()
Default prefer direct - System Property: io.netty.noPreferDirect - default false
|
static int |
defaultSmallCacheSize()
Default small cache size - System Property: io.netty.allocator.smallCacheSize - default 256
|
static int |
defaultTinyCacheSize()
Default tiny cache size - System Property: io.netty.allocator.tinyCacheSize - default 512
|
static boolean |
defaultUseCacheForAllThreads()
Default thread caching behavior - System Property: io.netty.allocator.useCacheForAllThreads - default true
|
List<org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PoolArenaMetric> |
directArenas()
Deprecated.
use
PooledByteBufAllocatorMetric.directArenas() . |
String |
dumpStats()
Returns the status of the allocator (which contains all metrics) as string.
|
void |
freeThreadLocalCache()
Deprecated.
|
boolean |
hasThreadLocalCache()
Deprecated.
|
List<org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PoolArenaMetric> |
heapArenas()
Deprecated.
use
PooledByteBufAllocatorMetric.heapArenas() . |
boolean |
isDirectBufferPooled() |
static boolean |
isDirectMemoryCacheAlignmentSupported()
Return
true if direct memory cache alignment is supported, false otherwise. |
org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PooledByteBufAllocatorMetric |
metric() |
protected org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBuf |
newDirectBuffer(int initialCapacity,
int maxCapacity) |
protected org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBuf |
newHeapBuffer(int initialCapacity,
int maxCapacity) |
int |
normalCacheSize()
Deprecated.
use
PooledByteBufAllocatorMetric.normalCacheSize() . |
int |
numDirectArenas()
Deprecated.
use
PooledByteBufAllocatorMetric.numDirectArenas() . |
int |
numHeapArenas()
Deprecated.
use
PooledByteBufAllocatorMetric.numHeapArenas() . |
int |
numThreadLocalCaches()
Deprecated.
use
PooledByteBufAllocatorMetric.numThreadLocalCaches() . |
int |
smallCacheSize()
Deprecated.
use
PooledByteBufAllocatorMetric.smallCacheSize() . |
int |
tinyCacheSize()
Deprecated.
use
PooledByteBufAllocatorMetric.tinyCacheSize() . |
buffer, buffer, buffer, calculateNewCapacity, compositeBuffer, compositeBuffer, compositeDirectBuffer, compositeDirectBuffer, compositeHeapBuffer, compositeHeapBuffer, directBuffer, directBuffer, directBuffer, heapBuffer, heapBuffer, heapBuffer, ioBuffer, ioBuffer, ioBuffer, toLeakAwareBuffer, toLeakAwareBuffer, toString
public static final PooledByteBufAllocator DEFAULT
public PooledByteBufAllocator()
public PooledByteBufAllocator(boolean preferDirect)
public PooledByteBufAllocator(int nHeapArena, int nDirectArena, int pageSize, int maxOrder)
@Deprecated public PooledByteBufAllocator(boolean preferDirect, int nHeapArena, int nDirectArena, int pageSize, int maxOrder)
@Deprecated public PooledByteBufAllocator(boolean preferDirect, int nHeapArena, int nDirectArena, int pageSize, int maxOrder, int tinyCacheSize, int smallCacheSize, int normalCacheSize)
public PooledByteBufAllocator(boolean preferDirect, int nHeapArena, int nDirectArena, int pageSize, int maxOrder, int tinyCacheSize, int smallCacheSize, int normalCacheSize, boolean useCacheForAllThreads)
public PooledByteBufAllocator(boolean preferDirect, int nHeapArena, int nDirectArena, int pageSize, int maxOrder, int tinyCacheSize, int smallCacheSize, int normalCacheSize, boolean useCacheForAllThreads, int directMemoryCacheAlignment)
protected org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBuf newHeapBuffer(int initialCapacity, int maxCapacity)
newHeapBuffer
in class org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.AbstractByteBufAllocator
protected org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBuf newDirectBuffer(int initialCapacity, int maxCapacity)
newDirectBuffer
in class org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.AbstractByteBufAllocator
public static int defaultNumHeapArena()
public static int defaultNumDirectArena()
public static int defaultPageSize()
public static int defaultMaxOrder()
public static boolean defaultUseCacheForAllThreads()
public static boolean defaultPreferDirect()
public static int defaultTinyCacheSize()
public static int defaultSmallCacheSize()
public static int defaultNormalCacheSize()
public static boolean isDirectMemoryCacheAlignmentSupported()
true
if direct memory cache alignment is supported, false
otherwise.public boolean isDirectBufferPooled()
isDirectBufferPooled
in interface org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBufAllocator
@Deprecated public boolean hasThreadLocalCache()
@Deprecated public void freeThreadLocalCache()
Thread
.public org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PooledByteBufAllocatorMetric metric()
metric
in interface org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.ByteBufAllocatorMetricProvider
@Deprecated public int numHeapArenas()
PooledByteBufAllocatorMetric.numHeapArenas()
.@Deprecated public int numDirectArenas()
PooledByteBufAllocatorMetric.numDirectArenas()
.@Deprecated public List<org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PoolArenaMetric> heapArenas()
PooledByteBufAllocatorMetric.heapArenas()
.List
of all heap PoolArenaMetric
s that are provided by this pool.@Deprecated public List<org.apache.beam.vendor.grpc.v1p21p0.io.netty.buffer.PoolArenaMetric> directArenas()
PooledByteBufAllocatorMetric.directArenas()
.List
of all direct PoolArenaMetric
s that are provided by this pool.@Deprecated public int numThreadLocalCaches()
PooledByteBufAllocatorMetric.numThreadLocalCaches()
.PooledByteBufAllocator
.@Deprecated public int tinyCacheSize()
PooledByteBufAllocatorMetric.tinyCacheSize()
.@Deprecated public int smallCacheSize()
PooledByteBufAllocatorMetric.smallCacheSize()
.@Deprecated public int normalCacheSize()
PooledByteBufAllocatorMetric.normalCacheSize()
.@Deprecated public final int chunkSize()
PooledByteBufAllocatorMetric.chunkSize()
.public String dumpStats()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.