andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix registration of global allocator

Browse Source
This commit is contained in:
Andrea Cavalli 2021-09-09 16:18:47 +02:00
parent d9fd4113e0
commit 6dda099cc1
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/it/cavallium/dbengine/netty/JMXNettyMonitoringManager.java
View File

@ -1,6 +1,7 @@
package it.cavallium.dbengine.netty; package it.cavallium.dbengine.netty;
import io.netty5.buffer.api.BufferAllocator; import io.netty5.buffer.api.BufferAllocator;
import io.netty5.buffer.api.DefaultGlobalBufferAllocator;
import io.netty5.buffer.api.pool.MetricUtils; import io.netty5.buffer.api.pool.MetricUtils;
import io.netty5.buffer.api.pool.PoolArenaMetric; import io.netty5.buffer.api.pool.PoolArenaMetric;
import io.netty5.buffer.api.pool.PooledBufferAllocator; import io.netty5.buffer.api.pool.PooledBufferAllocator;
@ -29,7 +30,8 @@ public class JMXNettyMonitoringManager {
} }
public static void initialize() { public static void initialize() {
getInstance(); var instance = getInstance();
instance.register("global", DefaultGlobalBufferAllocator.DEFAUL_GLOBAL_BUFFER_ALLOCATOR);
} }
public synchronized static JMXNettyMonitoringManager getInstance() { public synchronized static JMXNettyMonitoringManager getInstance() {
@ -55,10 +57,10 @@ public class JMXNettyMonitoringManager {
var jmx = new JMXPooledNettyMonitoring(name, pooledAllocator); var jmx = new JMXPooledNettyMonitoring(name, pooledAllocator);
type = "pooled"; type = "pooled";
mbean = new StandardMBean(jmx, JMXNettyMonitoringMBean.class); mbean = new StandardMBean(jmx, JMXNettyMonitoringMBean.class);
ObjectName botObjectName = new ObjectName("io.netty.stats:name=ByteBufAllocator,allocatorName=" + name + ",type=" + type); ObjectName botObjectName = new ObjectName("io.netty.stats:name=ByteBufAllocator,allocatorName=" + name + ",type=" + type);
platformMBeanServer.registerMBean(mbean, botObjectName); platformMBeanServer.registerMBean(mbean, botObjectName);
} }
} catch (MalformedObjectNameException | NotCompliantMBeanException | InstanceAlreadyExistsException | MBeanRegistrationException e) { } catch (MalformedObjectNameException | NotCompliantMBeanException | InstanceAlreadyExistsException | MBeanRegistrationException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }