memorymanager - Code Search

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)

github.com/kubernetes/kubernetes

pkg/kubelet/cm/container_manager_linux.go

		klog.ErrorS(err, "Failed to initialize cpu manager")
		return nil, err
	}
	cm.topologyManager.AddHintProvider(cm.cpuManager)

	if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryManager) {
		cm.memoryManager, err = memorymanager.NewManager(
			nodeConfig.ExperimentalMemoryManagerPolicy,
			machineInfo,
			cm.GetNodeAllocatableReservation(),
			nodeConfig.ExperimentalMemoryManagerReservedMemory,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue May 21 10:18:16 UTC 2024

- 35.1K bytes

- Viewed (0)

github.com/gradle/gradle

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)

github.com/kubernetes/kubernetes

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)

github.com/kubernetes/kubernetes

pkg/kubelet/cm/memorymanager/policy_none.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/kubernetes/pkg/kubelet/cm/memorymanager/state"
	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
)

const policyTypeNone policyType = "None"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon Jul 05 17:52:25 UTC 2021

- 2.2K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

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)

github.com/gradle/gradle

subprojects/core/src/main/java/org/gradle/internal/service/scopes/GradleUserHomeScopeServices.java

        ClassPathRegistry classPathRegistry,
        TemporaryFileProvider temporaryFileProvider,
        JavaExecHandleFactory execHandleFactory,
        JvmVersionDetector jvmVersionDetector,
        MemoryManager memoryManager,
        GradleUserHomeDirProvider gradleUserHomeDirProvider,
        OutputEventListener outputEventListener
    ) {
        return new DefaultWorkerProcessFactory(
            loggingManagerInternal,

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon May 27 12:34:44 UTC 2024

- 13.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/cm/memorymanager/memory_manager.go

WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package memorymanager

import (
	"context"
	"fmt"
	"sync"

	cadvisorapi "github.com/google/cadvisor/info/v1"

	v1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/api/resource"
	"k8s.io/apimachinery/pkg/util/sets"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Nov 01 00:50:45 UTC 2023

- 17.1K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/cm/memorymanager/policy_static.go

					if !ok {
						return fmt.Errorf("[memorymanager] (pod: %s, container: %s) the memory assignment uses the NUMA that does not exist", pod, containerName)
					}

					nodeState.NumberOfAssignments++
					nodeState.Cells = b.NUMAAffinity

					memoryState, ok := nodeState.MemoryMap[b.Type]
					if !ok {

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sun Nov 12 07:34:55 UTC 2023

- 34K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/cm/container_manager_stub.go

	"k8s.io/apimachinery/pkg/types"
	internalapi "k8s.io/cri-api/pkg/apis"
	podresourcesapi "k8s.io/kubelet/pkg/apis/podresources/v1"
	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager"
	"k8s.io/kubernetes/pkg/kubelet/cm/memorymanager"
	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
	"k8s.io/kubernetes/pkg/kubelet/config"
	kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
	"k8s.io/kubernetes/pkg/kubelet/lifecycle"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Mar 15 02:26:59 UTC 2023

- 5.9K bytes

- Viewed (0)

Search Options