github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 22:17:14 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #13789 from socaa/resource-consumer-memory

Browse Source 
Auto commit by PR queue bot
This commit is contained in:
k8s-merge-robot 2015-09-10 08:49:42 -07:00
commit 08fbe2bc10
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/images/resource-consumer/resource_consumer_handler.go
View File

@ -104,8 +104,7 @@ func (handler ResourceConsumerHandler) handleConsumeMem(w http.ResponseWriter, q
http.Error(w, incorrectFunctionArgument, http.StatusBadRequest) http.Error(w, incorrectFunctionArgument, http.StatusBadRequest)
return return
} }
ConsumeMem(megabytes, durationSec) go ConsumeMem(megabytes, durationSec)
fmt.Fprintln(w, "Warning: not implemented!")
fmt.Fprintln(w, consumeMemAddress[1:]) fmt.Fprintln(w, consumeMemAddress[1:])
fmt.Fprintln(w, megabytes, megabytesQuery) fmt.Fprintln(w, megabytes, megabytesQuery)
fmt.Fprintln(w, durationSec, durationSecQuery) fmt.Fprintln(w, durationSec, durationSecQuery)

12
test/images/resource-consumer/utils.go
View File

@ -20,9 +20,13 @@ import (
"fmt" "fmt"
"log" "log"
"os/exec" "os/exec"
"strconv"
) )
const consumeCPUBinary = "./consume-cpu/consume-cpu" const (
consumeCPUBinary = "./consume-cpu/consume-cpu"
consumeMemBinary = "stress"
)
func ConsumeCPU(millicores int, durationSec int) { func ConsumeCPU(millicores int, durationSec int) {
log.Printf("ConsumeCPU millicores: %v, durationSec: %v", millicores, durationSec) log.Printf("ConsumeCPU millicores: %v, durationSec: %v", millicores, durationSec)
@ -35,7 +39,11 @@ func ConsumeCPU(millicores int, durationSec int) {
func ConsumeMem(megabytes int, durationSec int) { func ConsumeMem(megabytes int, durationSec int) {
log.Printf("ConsumeMem megabytes: %v, durationSec: %v", megabytes, durationSec) log.Printf("ConsumeMem megabytes: %v, durationSec: %v", megabytes, durationSec)
// not implemented megabytesString := strconv.Itoa(megabytes) + "M"
durationSecString := strconv.Itoa(durationSec)
// creating new consume memory process
consumeMem := exec.Command(consumeMemBinary, "-m", "1", "--vm-bytes", megabytesString, "--vm-hang", "0", "-t", durationSecString)
consumeMem.Start()
} }
func GetCurrentStatus() { func GetCurrentStatus() {