cluster 8gb

keting-ai · keting-ai · commit 0af900c0bf7b · 2024-01-08T05:02:34.000Z
diff --git a/src/boss/cloudvm/azure_worker.go b/src/boss/cloudvm/azure_worker.go
@@ -142,7 +142,7 @@ func (worker *Worker) start(firstTime bool) error {
 	run_one_time := "sudo python3 run_worker.py"
 
 	var run_worker_up string
-	run_worker_up = fmt.Sprintf("sudo ./ol worker up -i ol-min -d -o import_cache_tree=%s,worker_url=0.0.0.0,features.warmup=false,limits.mem_mb=600,mem_pool_mb=8192,trace.evictor=true", tree_path)
+	run_worker_up = fmt.Sprintf("sudo ./ol worker up -i ol-min -d -o import_cache_tree=%s,worker_url=0.0.0.0,features.warmup=false,limits.mem_mb=500,mem_pool_mb=8192,trace.evictor=true", tree_path)
 
 	var cmd string
 	if firstTime {
diff --git a/src/boss/cloudvm/worker.go b/src/boss/cloudvm/worker.go
@@ -600,7 +600,7 @@ func (pool *WorkerPool) RunLambda(w http.ResponseWriter, r *http.Request) {
 			smallWorker = curWorker
 		}
 	}
-	if smallWorkerTask < (worker.numTask - 40) {
+	if smallWorkerTask < (worker.numTask - 16) {
 		worker = smallWorker
 	}
 
@@ -831,9 +831,7 @@ func (pool *WorkerPool) ChangePolicy(policy string) {
 
 // forward request to worker
 // TODO: this is kept for other platforms
-var client = &http.Client{
-	Timeout: time.Second * 10,
-}
+var client = &http.Client{}
 
 func forwardTaskHelper(w http.ResponseWriter, req *http.Request, workerIp string) error {
 	host := fmt.Sprintf("%s:%d", workerIp, 5000) //TODO: read from config
diff --git a/src/common/config.go b/src/common/config.go
@@ -168,7 +168,7 @@ func LoadDefaults(olPath string) error {
 			Procs:               10,
 			Mem_mb:              50,
 			CPU_percent:         100,
-			Max_runtime_default: 180,
+			Max_runtime_default: 90,
 			Installer_mem_mb:    500,
 			Swappiness:          0,
 		},
@@ -178,6 +178,7 @@ func LoadDefaults(olPath string) error {
 			Enable_seccomp:      true,
 			Warmup:              false,
 			COW:                 true,
+			Reuse_cgroups:       true,
 		},
 		Trace: TraceConfig{
 			Cgroups: false,
diff --git a/src/worker/sandbox/evictors.go b/src/worker/sandbox/evictors.go
@@ -13,7 +13,7 @@ import (
 // evictor can only run if there's enough memory for two containers.
 // if there are only 2, our goal is to have free mem for on container.
 // 20% only applies to containers in excess of 2.
-const FREE_SANDBOXES_PERCENT_GOAL = 10
+const FREE_SANDBOXES_PERCENT_GOAL = 20
 
 // the maximum number of evictions we'll do concurrently
 const CONCURRENT_EVICTIONS = 8

Original file line number	Diff line number	Diff line change
`@@ -600,7 +600,7 @@ func (pool WorkerPool) RunLambda(w http.ResponseWriter, r http.Request) {`
`600`	`600`	`smallWorker = curWorker`
`601`	`601`	`}`
`602`	`602`	`}`
`603`		`- if smallWorkerTask < (worker.numTask - 40) {`
	`603`	`+ if smallWorkerTask < (worker.numTask - 16) {`
`604`	`604`	`worker = smallWorker`
`605`	`605`	`}`
`606`	`606`
`@@ -831,9 +831,7 @@ func (pool *WorkerPool) ChangePolicy(policy string) {`
`831`	`831`
`832`	`832`	`// forward request to worker`
`833`	`833`	`// TODO: this is kept for other platforms`
`834`		`-var client = &http.Client{`
`835`		`- Timeout: time.Second * 10,`
`836`		`-}`
	`834`	`+var client = &http.Client{}`
`837`	`835`
`838`	`836`	`func forwardTaskHelper(w http.ResponseWriter, req *http.Request, workerIp string) error {`
`839`	`837`	`host := fmt.Sprintf("%s:%d", workerIp, 5000) //TODO: read from config`