github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Memory consumption added to Resource Consumer

pull/6/head
Ewa Socala 2015-09-10 13:50:49 +02:00
parent cfa5e516a8
commit 9e640b356c
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)
return
}
ConsumeMem(megabytes, durationSec)
fmt.Fprintln(w, "Warning: not implemented!")
go ConsumeMem(megabytes, durationSec)
fmt.Fprintln(w, consumeMemAddress[1:])
fmt.Fprintln(w, megabytes, megabytesQuery)
fmt.Fprintln(w, durationSec, durationSecQuery)

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

@ -20,9 +20,13 @@ import (
"fmt"
"log"
"os/exec"
"strconv"
)
const consumeCPUBinary = "./consume-cpu/consume-cpu"
const (
consumeCPUBinary = "./consume-cpu/consume-cpu"
consumeMemBinary = "stress"
)
func ConsumeCPU(millicores int, durationSec int) {
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) {
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() {