- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for memorymanager (0.16 sec)
-
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/health/memory/MemoryManager.java
package org.gradle.process.internal.health.memory; import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; @ServiceScope(Scope.Global.class) public interface MemoryManager { void addListener(JvmMemoryStatusListener listener); void addListener(OsMemoryStatusListener listener); void removeListener(JvmMemoryStatusListener listener);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/test/groovy/org/gradle/process/internal/health/memory/DefaultMemoryManagerTest.groovy
osMemoryInfo.freeMemory = MemoryAmount.of('4g').bytes def memoryManager = newMemoryManager() and: def holder = Mock(MemoryHolder) memoryManager.addMemoryHolder(holder) when: memoryManager.requestFreeMemory(0) then: 0 * holder.attemptToRelease(_) cleanup: memoryManager.stop() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 20 23:56:19 UTC 2023 - 9.6K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerDaemonExpirationIntegrationTest.groovy
import org.gradle.process.internal.health.memory.MemoryManager task expireWorkers { doFirst { def freeMemory CountDownLatch latch = new CountDownLatch(1) def memoryManager = services.get(MemoryManager.class) memoryManager.addListener(new OsMemoryStatusListener() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 3.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultWorkerProcessFactory.java
private final OutputEventListener outputEventListener; private final ApplicationClassesInSystemClassLoaderWorkerImplementationFactory workerImplementationFactory; private final MemoryManager memoryManager; private int connectTimeoutSeconds = 120; public DefaultWorkerProcessFactory( LoggingManager loggingManager, MessagingServer server, ClassPathRegistry classPathRegistry,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 09 14:01:29 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/cm/internal_container_lifecycle.go
cpuManager cpumanager.Manager memoryManager memorymanager.Manager topologyManager topologymanager.Manager } func (i *internalContainerLifecycleImpl) PreStartContainer(pod *v1.Pod, container *v1.Container, containerID string) error { if i.cpuManager != nil { i.cpuManager.AddContainer(pod, container, containerID) } if i.memoryManager != nil { i.memoryManager.AddContainer(pod, container, containerID) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 06:43:12 UTC 2023 - 1.8K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/process/internal/worker/DefaultWorkerProcessBuilderSpec.groovy
} def applicationClassesInSystemClassLoaderWorkerImplementationFactory = Mock(ApplicationClassesInSystemClassLoaderWorkerImplementationFactory) def outputEventListener = Mock(OutputEventListener) def memoryManager = Mock(MemoryManager) def versionDetector = Mock(JvmVersionDetector) { getJavaVersion(_) >> JavaVersion.VERSION_1_9 } DefaultWorkerProcessBuilder builder = new DefaultWorkerProcessBuilder(javaExecHandleFactory,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 15 21:01:42 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkersServices.java
ListenerManager listenerManager, MemoryManager memoryManager, OsMemoryInfo memoryInfo, ClassPathRegistry classPathRegistry,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:57:50 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/kubelet/cm/internal_container_lifecycle_linux.go
allocatedCPUs := i.cpuManager.GetCPUAffinity(string(pod.UID), container.Name) if !allocatedCPUs.IsEmpty() { containerConfig.Linux.Resources.CpusetCpus = allocatedCPUs.String() } } if i.memoryManager != nil { numaNodes := i.memoryManager.GetMemoryNUMANodes(pod, container) if numaNodes.Len() > 0 { var affinity []string for _, numaNode := range sets.List(numaNodes) { affinity = append(affinity, strconv.Itoa(numaNode)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/integTest/groovy/org/gradle/process/internal/health/memory/MemoryStatusUpdateIntegrationTest.groovy
doLast { final CountDownLatch osNotification = new CountDownLatch(1) final CountDownLatch jvmNotification = new CountDownLatch(1) MemoryManager manager = services.get(MemoryManager.class) manager.addListener(new JvmMemoryStatusListener() { void onJvmMemoryStatus(JvmMemoryStatus memoryStatus) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Dec 29 14:36:01 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
See the License for the specific language governing permissions and limitations under the License. */ package memorymanager import ( v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/cm/containermap" "k8s.io/kubernetes/pkg/kubelet/cm/memorymanager/state" "k8s.io/kubernetes/pkg/kubelet/cm/topologymanager" "k8s.io/kubernetes/pkg/kubelet/config"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0)