kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-09 11:55:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Bump again

Browse Source
This commit is contained in:
Alex Dadgar
2016-01-21 12:55:35 -08:00
parent 85a2c05697
commit 50d5fb7db6
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
client/driver/raw_exec_test.go
View File

@@ -285,7 +285,7 @@ func TestRawExecDriver_Start_Kill_Wait(t *testing.T) {
Name: "sleep",
Config: map[string]interface{}{
"command": testtask.Path(),
"args": []string{"sleep", "5s"},
"args": []string{"sleep", "15s"},
},
Resources: basicResources,
}
@@ -304,7 +304,7 @@ func TestRawExecDriver_Start_Kill_Wait(t *testing.T) {
}
go func() {
time.Sleep(time.Duration(testutil.TestMultiplier()*1) * time.Second)
time.Sleep(1 * time.Second)
err := handle.Kill()
if err != nil {
t.Fatalf("err: %v", err)
@@ -317,7 +317,7 @@ func TestRawExecDriver_Start_Kill_Wait(t *testing.T) {
if res.Successful() {
t.Fatal("should err")
}
case <-time.After(3 * time.Second):
case <-time.After(time.Duration(testutil.TestMultiplier()*3) * time.Second):
t.Fatalf("timeout")
}
}

4
client/task_runner_test.go
View File

@@ -100,7 +100,7 @@ func TestTaskRunner_Destroy(t *testing.T) {
select {
case <-tr.WaitCh():
case <-time.After(15 * time.Second):
case <-time.After(time.Duration(testutil.TestMultiplier()*15) * time.Second):
t.Fatalf("timeout")
}
@@ -175,7 +175,7 @@ func TestTaskRunner_SaveRestoreState(t *testing.T) {
defer tr2.Destroy()
// Destroy and wait
time.Sleep(time.Duration(testutil.TestMultiplier()*2) * time.Second)
time.Sleep(time.Duration(testutil.TestMultiplier()*5) * time.Second)
if tr2.handle == nil {
t.Fatalf("RestoreState() didn't open handle")
}