< prev index next >

src/java.base/linux/classes/jdk/internal/platform/cgroupv1/CgroupV1Subsystem.java

Print this page
@  rev 57735 : Review feedback 2
|
o  rev 57734 : Review feedback
|
o  rev 57733 : 8231111: Cgroups v2: Rework Metrics in java.base so as to recognize unified hierarchy
|  Reviewed-by: bobv, mchung
~
o  rev 56862 : 8231111: Cgroups v2: Rework Metrics in java.base so as to recognize unified hierarchy
|  Reviewed-by: bobv
~

*** 1,7 **** /* ! * Copyright (c) 2018, 2019, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Oracle designates this --- 1,7 ---- /* ! * Copyright (c) 2018, 2020, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Oracle designates this
*** 24,68 **** */ package jdk.internal.platform.cgroupv1; import java.io.IOException; - import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; - import java.security.AccessController; - import java.security.PrivilegedActionException; - import java.security.PrivilegedExceptionAction; import java.util.stream.Stream; ! import jdk.internal.platform.cgroupv1.SubSystem.MemorySubSystem; ! ! public class Metrics implements jdk.internal.platform.Metrics { ! private MemorySubSystem memory; ! private SubSystem cpu; ! private SubSystem cpuacct; ! private SubSystem cpuset; ! private SubSystem blkio; private boolean activeSubSystems; ! // Values returned larger than this number are unlimited. ! static long unlimited_minimum = 0x7FFFFFFFFF000000L; ! ! private static final Metrics INSTANCE = initContainerSubSystems(); private static final String PROVIDER_NAME = "cgroupv1"; ! private Metrics() { activeSubSystems = false; } ! public static Metrics getInstance() { return INSTANCE; } ! private static Metrics initContainerSubSystems() { ! Metrics metrics = new Metrics(); /** * Find the cgroup mount points for subsystems * by reading /proc/self/mountinfo * --- 24,64 ---- */ package jdk.internal.platform.cgroupv1; import java.io.IOException; import java.nio.file.Path; import java.nio.file.Paths; import java.util.stream.Stream; ! import jdk.internal.platform.CgroupSubsystem; ! import jdk.internal.platform.CgroupSubsystemController; ! import jdk.internal.platform.CgroupUtil; ! import jdk.internal.platform.CgroupV1Metrics; ! ! public class CgroupV1Subsystem implements CgroupSubsystem, CgroupV1Metrics { ! private CgroupV1MemorySubSystemController memory; ! private CgroupV1SubsystemController cpu; ! private CgroupV1SubsystemController cpuacct; ! private CgroupV1SubsystemController cpuset; ! private CgroupV1SubsystemController blkio; private boolean activeSubSystems; ! private static final CgroupV1Subsystem INSTANCE = initSubSystem(); private static final String PROVIDER_NAME = "cgroupv1"; ! private CgroupV1Subsystem() { activeSubSystems = false; } ! public static CgroupV1Subsystem getInstance() { return INSTANCE; } ! private static CgroupV1Subsystem initSubSystem() { ! CgroupV1Subsystem subsystem = new CgroupV1Subsystem(); /** * Find the cgroup mount points for subsystems * by reading /proc/self/mountinfo *
*** 71,85 **** * * Example for host: * 34 28 0:29 / /sys/fs/cgroup/MemorySubSystem rw,nosuid,nodev,noexec,relatime shared:16 - cgroup cgroup rw,MemorySubSystem */ try (Stream<String> lines = ! readFilePrivileged(Paths.get("/proc/self/mountinfo"))) { lines.filter(line -> line.contains(" - cgroup ")) .map(line -> line.split(" ")) ! .forEach(entry -> createSubSystem(metrics, entry)); } catch (IOException e) { return null; } --- 67,81 ---- * * Example for host: * 34 28 0:29 / /sys/fs/cgroup/MemorySubSystem rw,nosuid,nodev,noexec,relatime shared:16 - cgroup cgroup rw,MemorySubSystem */ try (Stream<String> lines = ! CgroupUtil.readFilePrivileged(Paths.get("/proc/self/mountinfo"))) { lines.filter(line -> line.contains(" - cgroup ")) .map(line -> line.split(" ")) ! .forEach(entry -> createSubSystemController(subsystem, entry)); } catch (IOException e) { return null; }
*** 105,176 **** * * /sys/fs/cgroup/memory/user.slice * */ try (Stream<String> lines = ! readFilePrivileged(Paths.get("/proc/self/cgroup"))) { lines.map(line -> line.split(":")) .filter(line -> (line.length >= 3)) ! .forEach(line -> setSubSystemPath(metrics, line)); } catch (IOException e) { return null; } // Return Metrics object if we found any subsystems. ! if (metrics.activeSubSystems()) { ! return metrics; } return null; } - static Stream<String> readFilePrivileged(Path path) throws IOException { - try { - PrivilegedExceptionAction<Stream<String>> pea = () -> Files.lines(path); - return AccessController.doPrivileged(pea); - } catch (PrivilegedActionException e) { - unwrapIOExceptionAndRethrow(e); - throw new InternalError(e.getCause()); - } - } - - static void unwrapIOExceptionAndRethrow(PrivilegedActionException pae) throws IOException { - Throwable x = pae.getCause(); - if (x instanceof IOException) - throw (IOException) x; - if (x instanceof RuntimeException) - throw (RuntimeException) x; - if (x instanceof Error) - throw (Error) x; - } /** * createSubSystem objects and initialize mount points */ ! private static void createSubSystem(Metrics metric, String[] mountentry) { if (mountentry.length < 5) return; Path p = Paths.get(mountentry[4]); String[] subsystemNames = p.getFileName().toString().split(","); for (String subsystemName: subsystemNames) { switch (subsystemName) { case "memory": ! metric.setMemorySubSystem(new MemorySubSystem(mountentry[3], mountentry[4])); break; case "cpuset": ! metric.setCpuSetSubSystem(new SubSystem(mountentry[3], mountentry[4])); break; case "cpuacct": ! metric.setCpuAcctSubSystem(new SubSystem(mountentry[3], mountentry[4])); break; case "cpu": ! metric.setCpuSubSystem(new SubSystem(mountentry[3], mountentry[4])); break; case "blkio": ! metric.setBlkIOSubSystem(new SubSystem(mountentry[3], mountentry[4])); break; default: // Ignore subsystems that we don't support break; } --- 101,153 ---- * * /sys/fs/cgroup/memory/user.slice * */ try (Stream<String> lines = ! CgroupUtil.readFilePrivileged(Paths.get("/proc/self/cgroup"))) { lines.map(line -> line.split(":")) .filter(line -> (line.length >= 3)) ! .forEach(line -> setSubSystemControllerPath(subsystem, line)); } catch (IOException e) { return null; } // Return Metrics object if we found any subsystems. ! if (subsystem.activeSubSystems()) { ! return subsystem; } return null; } /** * createSubSystem objects and initialize mount points */ ! private static void createSubSystemController(CgroupV1Subsystem subsystem, String[] mountentry) { if (mountentry.length < 5) return; Path p = Paths.get(mountentry[4]); String[] subsystemNames = p.getFileName().toString().split(","); for (String subsystemName: subsystemNames) { switch (subsystemName) { case "memory": ! subsystem.setMemorySubSystem(new CgroupV1MemorySubSystemController(mountentry[3], mountentry[4])); break; case "cpuset": ! subsystem.setCpuSetController(new CgroupV1SubsystemController(mountentry[3], mountentry[4])); break; case "cpuacct": ! subsystem.setCpuAcctController(new CgroupV1SubsystemController(mountentry[3], mountentry[4])); break; case "cpu": ! subsystem.setCpuController(new CgroupV1SubsystemController(mountentry[3], mountentry[4])); break; case "blkio": ! subsystem.setBlkIOController(new CgroupV1SubsystemController(mountentry[3], mountentry[4])); break; default: // Ignore subsystems that we don't support break; }
*** 178,240 **** } /** * setSubSystemPath based on the contents of /proc/self/cgroup */ ! private static void setSubSystemPath(Metrics metric, String[] entry) { ! String controller; String base; ! SubSystem subsystem = null; ! SubSystem subsystem2 = null; ! controller = entry[1]; base = entry[2]; ! if (controller != null && base != null) { ! switch (controller) { case "memory": ! subsystem = metric.MemorySubSystem(); break; case "cpuset": ! subsystem = metric.CpuSetSubSystem(); break; case "cpu,cpuacct": case "cpuacct,cpu": ! subsystem = metric.CpuSubSystem(); ! subsystem2 = metric.CpuAcctSubSystem(); break; case "cpuacct": ! subsystem = metric.CpuAcctSubSystem(); break; case "cpu": ! subsystem = metric.CpuSubSystem(); break; case "blkio": ! subsystem = metric.BlkIOSubSystem(); break; // Ignore subsystems that we don't support default: break; } } ! if (subsystem != null) { ! subsystem.setPath(base); ! if (subsystem instanceof MemorySubSystem) { ! MemorySubSystem memorySubSystem = (MemorySubSystem)subsystem; boolean isHierarchial = getHierarchical(memorySubSystem); memorySubSystem.setHierarchical(isHierarchial); } ! metric.setActiveSubSystems(); } ! if (subsystem2 != null) { ! subsystem2.setPath(base); } } ! private static boolean getHierarchical(MemorySubSystem subsystem) { ! long hierarchical = SubSystem.getLongValue(subsystem, "memory.use_hierarchy"); return hierarchical > 0; } private void setActiveSubSystems() { activeSubSystems = true; --- 155,217 ---- } /** * setSubSystemPath based on the contents of /proc/self/cgroup */ ! private static void setSubSystemControllerPath(CgroupV1Subsystem subsystem, String[] entry) { ! String controllerName; String base; ! CgroupV1SubsystemController controller = null; ! CgroupV1SubsystemController controller2 = null; ! controllerName = entry[1]; base = entry[2]; ! if (controllerName != null && base != null) { ! switch (controllerName) { case "memory": ! controller = subsystem.memoryController(); break; case "cpuset": ! controller = subsystem.cpuSetController(); break; case "cpu,cpuacct": case "cpuacct,cpu": ! controller = subsystem.cpuController(); ! controller2 = subsystem.cpuAcctController(); break; case "cpuacct": ! controller = subsystem.cpuAcctController(); break; case "cpu": ! controller = subsystem.cpuController(); break; case "blkio": ! controller = subsystem.blkIOController(); break; // Ignore subsystems that we don't support default: break; } } ! if (controller != null) { ! controller.setPath(base); ! if (controller instanceof CgroupV1MemorySubSystemController) { ! CgroupV1MemorySubSystemController memorySubSystem = (CgroupV1MemorySubSystemController)controller; boolean isHierarchial = getHierarchical(memorySubSystem); memorySubSystem.setHierarchical(isHierarchial); } ! subsystem.setActiveSubSystems(); } ! if (controller2 != null) { ! controller2.setPath(base); } } ! private static boolean getHierarchical(CgroupV1MemorySubSystemController controller) { ! long hierarchical = getLongValue(controller, "memory.use_hierarchy"); return hierarchical > 0; } private void setActiveSubSystems() { activeSubSystems = true;
*** 242,308 **** private boolean activeSubSystems() { return activeSubSystems; } ! private void setMemorySubSystem(MemorySubSystem memory) { this.memory = memory; } ! private void setCpuSubSystem(SubSystem cpu) { this.cpu = cpu; } ! private void setCpuAcctSubSystem(SubSystem cpuacct) { this.cpuacct = cpuacct; } ! private void setCpuSetSubSystem(SubSystem cpuset) { this.cpuset = cpuset; } ! private void setBlkIOSubSystem(SubSystem blkio) { this.blkio = blkio; } ! private SubSystem MemorySubSystem() { return memory; } ! private SubSystem CpuSubSystem() { return cpu; } ! private SubSystem CpuAcctSubSystem() { return cpuacct; } ! private SubSystem CpuSetSubSystem() { return cpuset; } ! private SubSystem BlkIOSubSystem() { return blkio; } public String getProvider() { return PROVIDER_NAME; } /***************************************************************** * CPU Accounting Subsystem ****************************************************************/ public long getCpuUsage() { ! return SubSystem.getLongValue(cpuacct, "cpuacct.usage"); } public long[] getPerCpuUsage() { ! String usagelist = SubSystem.getStringValue(cpuacct, "cpuacct.usage_percpu"); if (usagelist == null) { ! return new long[0]; } String list[] = usagelist.split(" "); long percpu[] = new long[list.length]; for (int i = 0; i < list.length; i++) { --- 219,293 ---- private boolean activeSubSystems() { return activeSubSystems; } ! private void setMemorySubSystem(CgroupV1MemorySubSystemController memory) { this.memory = memory; } ! private void setCpuController(CgroupV1SubsystemController cpu) { this.cpu = cpu; } ! private void setCpuAcctController(CgroupV1SubsystemController cpuacct) { this.cpuacct = cpuacct; } ! private void setCpuSetController(CgroupV1SubsystemController cpuset) { this.cpuset = cpuset; } ! private void setBlkIOController(CgroupV1SubsystemController blkio) { this.blkio = blkio; } ! private CgroupV1SubsystemController memoryController() { return memory; } ! private CgroupV1SubsystemController cpuController() { return cpu; } ! private CgroupV1SubsystemController cpuAcctController() { return cpuacct; } ! private CgroupV1SubsystemController cpuSetController() { return cpuset; } ! private CgroupV1SubsystemController blkIOController() { return blkio; } + private static long getLongValue(CgroupSubsystemController controller, + String parm) { + return CgroupSubsystemController.getLongValue(controller, + parm, + CgroupV1SubsystemController::convertStringToLong, + CgroupSubsystem.LONG_RETVAL_UNLIMITED); + } + public String getProvider() { return PROVIDER_NAME; } /***************************************************************** * CPU Accounting Subsystem ****************************************************************/ public long getCpuUsage() { ! return getLongValue(cpuacct, "cpuacct.usage"); } public long[] getPerCpuUsage() { ! String usagelist = CgroupSubsystemController.getStringValue(cpuacct, "cpuacct.usage_percpu"); if (usagelist == null) { ! return null; } String list[] = usagelist.split(" "); long percpu[] = new long[list.length]; for (int i = 0; i < list.length; i++) {
*** 310,358 **** } return percpu; } public long getCpuUserUsage() { ! return SubSystem.getLongEntry(cpuacct, "cpuacct.stat", "user"); } public long getCpuSystemUsage() { ! return SubSystem.getLongEntry(cpuacct, "cpuacct.stat", "system"); } /***************************************************************** * CPU Subsystem ****************************************************************/ public long getCpuPeriod() { ! return SubSystem.getLongValue(cpu, "cpu.cfs_period_us"); } public long getCpuQuota() { ! return SubSystem.getLongValue(cpu, "cpu.cfs_quota_us"); } public long getCpuShares() { ! long retval = SubSystem.getLongValue(cpu, "cpu.shares"); if (retval == 0 || retval == 1024) ! return -1; else return retval; } public long getCpuNumPeriods() { ! return SubSystem.getLongEntry(cpu, "cpu.stat", "nr_periods"); } public long getCpuNumThrottled() { ! return SubSystem.getLongEntry(cpu, "cpu.stat", "nr_throttled"); } public long getCpuThrottledTime() { ! return SubSystem.getLongEntry(cpu, "cpu.stat", "throttled_time"); } public long getEffectiveCpuCount() { return Runtime.getRuntime().availableProcessors(); } --- 295,343 ---- } return percpu; } public long getCpuUserUsage() { ! return CgroupV1SubsystemController.getLongEntry(cpuacct, "cpuacct.stat", "user"); } public long getCpuSystemUsage() { ! return CgroupV1SubsystemController.getLongEntry(cpuacct, "cpuacct.stat", "system"); } /***************************************************************** * CPU Subsystem ****************************************************************/ public long getCpuPeriod() { ! return getLongValue(cpu, "cpu.cfs_period_us"); } public long getCpuQuota() { ! return getLongValue(cpu, "cpu.cfs_quota_us"); } public long getCpuShares() { ! long retval = getLongValue(cpu, "cpu.shares"); if (retval == 0 || retval == 1024) ! return CgroupSubsystem.LONG_RETVAL_UNLIMITED; else return retval; } public long getCpuNumPeriods() { ! return CgroupV1SubsystemController.getLongEntry(cpu, "cpu.stat", "nr_periods"); } public long getCpuNumThrottled() { ! return CgroupV1SubsystemController.getLongEntry(cpu, "cpu.stat", "nr_throttled"); } public long getCpuThrottledTime() { ! return CgroupV1SubsystemController.getLongEntry(cpu, "cpu.stat", "throttled_time"); } public long getEffectiveCpuCount() { return Runtime.getRuntime().availableProcessors(); }
*** 361,519 **** /***************************************************************** * CPUSet Subsystem ****************************************************************/ public int[] getCpuSetCpus() { ! return SubSystem.StringRangeToIntArray(SubSystem.getStringValue(cpuset, "cpuset.cpus")); } public int[] getEffectiveCpuSetCpus() { ! return SubSystem.StringRangeToIntArray(SubSystem.getStringValue(cpuset, "cpuset.effective_cpus")); } public int[] getCpuSetMems() { ! return SubSystem.StringRangeToIntArray(SubSystem.getStringValue(cpuset, "cpuset.mems")); } public int[] getEffectiveCpuSetMems() { ! return SubSystem.StringRangeToIntArray(SubSystem.getStringValue(cpuset, "cpuset.effective_mems")); } public double getCpuSetMemoryPressure() { ! return SubSystem.getDoubleValue(cpuset, "cpuset.memory_pressure"); } ! public boolean isCpuSetMemoryPressureEnabled() { ! long val = SubSystem.getLongValue(cpuset, "cpuset.memory_pressure_enabled"); return (val == 1); } /***************************************************************** * Memory Subsystem ****************************************************************/ public long getMemoryFailCount() { ! return SubSystem.getLongValue(memory, "memory.failcnt"); } public long getMemoryLimit() { ! long retval = SubSystem.getLongValue(memory, "memory.limit_in_bytes"); ! if (retval > unlimited_minimum) { if (memory.isHierarchical()) { // memory.limit_in_bytes returned unlimited, attempt // hierarchical memory limit String match = "hierarchical_memory_limit"; ! retval = SubSystem.getLongValueMatchingLine(memory, "memory.stat", ! match, ! Metrics::convertHierachicalLimitLine); } } ! return retval > unlimited_minimum ? -1L : retval; ! } ! ! public static long convertHierachicalLimitLine(String line) { ! String[] tokens = line.split("\\s"); ! if (tokens.length == 2) { ! String strVal = tokens[1]; ! return SubSystem.convertStringToLong(strVal); ! } ! return unlimited_minimum + 1; // unlimited } public long getMemoryMaxUsage() { ! return SubSystem.getLongValue(memory, "memory.max_usage_in_bytes"); } public long getMemoryUsage() { ! return SubSystem.getLongValue(memory, "memory.usage_in_bytes"); } public long getKernelMemoryFailCount() { ! return SubSystem.getLongValue(memory, "memory.kmem.failcnt"); } public long getKernelMemoryLimit() { ! long retval = SubSystem.getLongValue(memory, "memory.kmem.limit_in_bytes"); ! return retval > unlimited_minimum ? -1L : retval; } public long getKernelMemoryMaxUsage() { ! return SubSystem.getLongValue(memory, "memory.kmem.max_usage_in_bytes"); } public long getKernelMemoryUsage() { ! return SubSystem.getLongValue(memory, "memory.kmem.usage_in_bytes"); } public long getTcpMemoryFailCount() { ! return SubSystem.getLongValue(memory, "memory.kmem.tcp.failcnt"); } public long getTcpMemoryLimit() { ! long retval = SubSystem.getLongValue(memory, "memory.kmem.tcp.limit_in_bytes"); ! return retval > unlimited_minimum ? -1L : retval; } public long getTcpMemoryMaxUsage() { ! return SubSystem.getLongValue(memory, "memory.kmem.tcp.max_usage_in_bytes"); } public long getTcpMemoryUsage() { ! return SubSystem.getLongValue(memory, "memory.kmem.tcp.usage_in_bytes"); } public long getMemoryAndSwapFailCount() { ! return SubSystem.getLongValue(memory, "memory.memsw.failcnt"); } public long getMemoryAndSwapLimit() { ! long retval = SubSystem.getLongValue(memory, "memory.memsw.limit_in_bytes"); ! if (retval > unlimited_minimum) { if (memory.isHierarchical()) { // memory.memsw.limit_in_bytes returned unlimited, attempt // hierarchical memory limit String match = "hierarchical_memsw_limit"; ! retval = SubSystem.getLongValueMatchingLine(memory, "memory.stat", ! match, ! Metrics::convertHierachicalLimitLine); } } ! return retval > unlimited_minimum ? -1L : retval; } public long getMemoryAndSwapMaxUsage() { ! return SubSystem.getLongValue(memory, "memory.memsw.max_usage_in_bytes"); } public long getMemoryAndSwapUsage() { ! return SubSystem.getLongValue(memory, "memory.memsw.usage_in_bytes"); } ! public boolean isMemoryOOMKillEnabled() { ! long val = SubSystem.getLongEntry(memory, "memory.oom_control", "oom_kill_disable"); return (val == 0); } public long getMemorySoftLimit() { ! long retval = SubSystem.getLongValue(memory, "memory.soft_limit_in_bytes"); ! return retval > unlimited_minimum ? -1L : retval; } /***************************************************************** * BlKIO Subsystem ****************************************************************/ public long getBlkIOServiceCount() { ! return SubSystem.getLongEntry(blkio, "blkio.throttle.io_service_bytes", "Total"); } public long getBlkIOServiced() { ! return SubSystem.getLongEntry(blkio, "blkio.throttle.io_serviced", "Total"); } } --- 346,490 ---- /***************************************************************** * CPUSet Subsystem ****************************************************************/ public int[] getCpuSetCpus() { ! return CgroupSubsystemController.stringRangeToIntArray(CgroupSubsystemController.getStringValue(cpuset, "cpuset.cpus")); } public int[] getEffectiveCpuSetCpus() { ! return CgroupSubsystemController.stringRangeToIntArray(CgroupSubsystemController.getStringValue(cpuset, "cpuset.effective_cpus")); } public int[] getCpuSetMems() { ! return CgroupSubsystemController.stringRangeToIntArray(CgroupSubsystemController.getStringValue(cpuset, "cpuset.mems")); } public int[] getEffectiveCpuSetMems() { ! return CgroupSubsystemController.stringRangeToIntArray(CgroupSubsystemController.getStringValue(cpuset, "cpuset.effective_mems")); } public double getCpuSetMemoryPressure() { ! return CgroupV1SubsystemController.getDoubleValue(cpuset, "cpuset.memory_pressure"); } ! public Boolean isCpuSetMemoryPressureEnabled() { ! long val = getLongValue(cpuset, "cpuset.memory_pressure_enabled"); return (val == 1); } /***************************************************************** * Memory Subsystem ****************************************************************/ public long getMemoryFailCount() { ! return getLongValue(memory, "memory.failcnt"); } public long getMemoryLimit() { ! long retval = getLongValue(memory, "memory.limit_in_bytes"); ! if (retval > CgroupV1SubsystemController.UNLIMITED_MIN) { if (memory.isHierarchical()) { // memory.limit_in_bytes returned unlimited, attempt // hierarchical memory limit String match = "hierarchical_memory_limit"; ! retval = CgroupV1SubsystemController.getLongValueMatchingLine(memory, "memory.stat", ! match); } } ! return CgroupV1SubsystemController.longValOrUnlimited(retval); } public long getMemoryMaxUsage() { ! return getLongValue(memory, "memory.max_usage_in_bytes"); } public long getMemoryUsage() { ! return getLongValue(memory, "memory.usage_in_bytes"); } public long getKernelMemoryFailCount() { ! return getLongValue(memory, "memory.kmem.failcnt"); } public long getKernelMemoryLimit() { ! return CgroupV1SubsystemController.longValOrUnlimited(getLongValue(memory, "memory.kmem.limit_in_bytes")); } public long getKernelMemoryMaxUsage() { ! return getLongValue(memory, "memory.kmem.max_usage_in_bytes"); } public long getKernelMemoryUsage() { ! return getLongValue(memory, "memory.kmem.usage_in_bytes"); } public long getTcpMemoryFailCount() { ! return getLongValue(memory, "memory.kmem.tcp.failcnt"); } public long getTcpMemoryLimit() { ! return CgroupV1SubsystemController.longValOrUnlimited(getLongValue(memory, "memory.kmem.tcp.limit_in_bytes")); } public long getTcpMemoryMaxUsage() { ! return getLongValue(memory, "memory.kmem.tcp.max_usage_in_bytes"); } public long getTcpMemoryUsage() { ! return getLongValue(memory, "memory.kmem.tcp.usage_in_bytes"); } public long getMemoryAndSwapFailCount() { ! return getLongValue(memory, "memory.memsw.failcnt"); } public long getMemoryAndSwapLimit() { ! long retval = getLongValue(memory, "memory.memsw.limit_in_bytes"); ! if (retval > CgroupV1SubsystemController.UNLIMITED_MIN) { if (memory.isHierarchical()) { // memory.memsw.limit_in_bytes returned unlimited, attempt // hierarchical memory limit String match = "hierarchical_memsw_limit"; ! retval = CgroupV1SubsystemController.getLongValueMatchingLine(memory, "memory.stat", ! match); } } ! return CgroupV1SubsystemController.longValOrUnlimited(retval); } public long getMemoryAndSwapMaxUsage() { ! return getLongValue(memory, "memory.memsw.max_usage_in_bytes"); } public long getMemoryAndSwapUsage() { ! return getLongValue(memory, "memory.memsw.usage_in_bytes"); } ! public Boolean isMemoryOOMKillEnabled() { ! long val = CgroupV1SubsystemController.getLongEntry(memory, "memory.oom_control", "oom_kill_disable"); return (val == 0); } public long getMemorySoftLimit() { ! return CgroupV1SubsystemController.longValOrUnlimited(getLongValue(memory, "memory.soft_limit_in_bytes")); } /***************************************************************** * BlKIO Subsystem ****************************************************************/ public long getBlkIOServiceCount() { ! return CgroupV1SubsystemController.getLongEntry(blkio, "blkio.throttle.io_service_bytes", "Total"); } public long getBlkIOServiced() { ! return CgroupV1SubsystemController.getLongEntry(blkio, "blkio.throttle.io_serviced", "Total"); } }
< prev index next >