Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

perf_bench_test start #54

Merged
merged 14 commits into from
Nov 20, 2020
Merged

perf_bench_test start #54

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
851506b
skeleton of perf_bench_test
Nov 6, 2020
ccb489f
fixed semaphore release
Nov 6, 2020
9957224
changed execution logic
Nov 6, 2020
36a4969
add waiting time interval
Nov 11, 2020
4198ec5
update perf_bench_test.go
Nov 15, 2020
598be97
remove comments and add imageName to parameters of goroutine.
Nov 15, 2020
2a5fa3d
implement warm invocations
Nov 17, 2020
265806e
change from burst requests per second to inject a request per time in…
Nov 17, 2020
5c09914
move targetRPS and executionTime to runtime args, and remove the sema…
Nov 18, 2020
15330cf
Refactor TestBenchRequestPerSecond
Nov 19, 2020
e13ff78
Fix data racing of WaitGroup. Minor fix logs and comments.
Nov 20, 2020
44e7fe1
add TestBenchRequestPerSecond to bench
Nov 20, 2020
1561439
Minor fix log and comments
Nov 20, 2020
d97bba8
Minor fix bench
Nov 20, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fixed semaphore release
  • Loading branch information
NiuJ1ao authored and NiuJ1ao committed Nov 20, 2020
commit ccb489f4bed32d7a99fea7be27ec9d17693f4f9f
62 changes: 34 additions & 28 deletions perf_bench_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ func TestBenchRequestPerSecond(t *testing.T) {
requestPerSec = 1
concurrency = 1
totalSeconds = 5 // in second
duration = 30 * time.Second
// duration = 30 * time.Second
)

funcPool = NewFuncPool(!isSaveMemoryConst, servedTh, pinnedFuncNum, isTestModeConst)
Expand All @@ -60,44 +60,50 @@ func TestBenchRequestPerSecond(t *testing.T) {
for i := 0; i < requestPerSec; i++ {
tStart := time.Now()
sem <- true
funcName := funcs[funcIdx]
imageName := images[funcName]

// pull image
resp, _, err := funcPool.Serve(context.Background(), "plr_fnc", imageName, "record")
go func() {
defer func() { <-sem }()

require.NoError(t, err, "Function returned error")
require.Equal(t, resp.Payload, "Hello, record_response!")
funcName := funcs[funcIdx]
imageName := images[funcName]

vmIDString := strconv.Itoa(vmID)
// pull image
resp, _, err := funcPool.Serve(context.Background(), "plr_fnc", imageName, "record")

createSnapshots(t, concurrency, vmID, imageName, isSyncOffload)
log.Info("All snapshots created")
require.NoError(t, err, "Function returned error")
require.Equal(t, resp.Payload, "Hello, record_response!")

createRecords(t, concurrency, vmID, imageName, isSyncOffload)
log.Info("All records done")
vmIDString := strconv.Itoa(vmID)

if !*isWithCache {
dropPageCache()
}
createSnapshots(t, concurrency, vmID, imageName, isSyncOffload)
log.Info("Snapshots created")

// serve
resp, _, err = funcPool.Serve(context.Background(), vmIDString, imageName, "replay")
require.NoError(t, err, "Function returned error")
require.Equal(t, resp.Payload, "Hello, replay_response!")
createRecords(t, concurrency, vmID, imageName, isSyncOffload)
log.Info("Records done")

message, err := funcPool.RemoveInstance(vmIDString, imageName, isSyncOffload)
require.NoError(t, err, "Function returned error, "+message)
if !*isWithCache {
dropPageCache()
}

funcIdx++
funcIdx %= len(funcs)
vmID++
// serve
resp, _, err = funcPool.Serve(context.Background(), vmIDString, imageName, "replay")
require.NoError(t, err, "Function returned error")
require.Equal(t, resp.Payload, "Hello, replay_response!")

// wait for time interval
timeLeft := duration.Nanoseconds() - time.Since(tStart).Nanoseconds()
require.GreaterOrEqual(t, timeLeft, 0)
message, err := funcPool.RemoveInstance(vmIDString, imageName, isSyncOffload)
require.NoError(t, err, "Function returned error, "+message)

time.Sleep(time.Duration(timeLeft))
funcIdx++
funcIdx %= len(funcs)
vmID++

log.Printf("Instance finished in %f seconds", time.Since(tStart).Seconds())
// wait for time interval
// timeLeft := duration.Nanoseconds() - time.Since(tStart).Nanoseconds()
// require.GreaterOrEqual(t, timeLeft, 0)

// time.Sleep(time.Duration(timeLeft))
}()
}

}
Expand Down