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

fix flaky java tests

Browse Source
This commit is contained in:
Alex Dadgar
2017-10-18 18:07:36 -07:00
parent e175c56082
commit 8de487c241
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
client/driver/java_test.go
View File

@@ -205,6 +205,7 @@ func TestJavaDriver_Start_Kill_Wait(t *testing.T) {
Driver: "java",
Config: map[string]interface{}{
"jar_path": "demoapp.jar",
"args": []string{"5"},
},
LogConfig: &structs.LogConfig{
MaxFiles: 10,
@@ -229,16 +230,19 @@ func TestJavaDriver_Start_Kill_Wait(t *testing.T) {
t.Fatalf("err: %v", err)
}
errCh := make(chan error, 1)
go func() {
time.Sleep(100 * time.Millisecond)
time.Sleep(10 * time.Millisecond)
err := resp.Handle.Kill()
if err != nil {
t.Fatalf("err: %v", err)
errCh <- err
}
}()
// Task should terminate quickly
select {
case err := <-errCh:
t.Fatalf("err: %v", err)
case res := <-resp.Handle.WaitCh():
if res.Successful() {
t.Fatal("should err")
@@ -267,6 +271,7 @@ func TestJavaDriver_Signal(t *testing.T) {
Driver: "java",
Config: map[string]interface{}{
"jar_path": "demoapp.jar",
"args": []string{"5"},
},
LogConfig: &structs.LogConfig{
MaxFiles: 10,
@@ -291,16 +296,19 @@ func TestJavaDriver_Signal(t *testing.T) {
t.Fatalf("err: %v", err)
}
errCh := make(chan error, 1)
go func() {
time.Sleep(100 * time.Millisecond)
time.Sleep(10 * time.Millisecond)
err := resp.Handle.Signal(syscall.SIGHUP)
if err != nil {
t.Fatalf("err: %v", err)
errCh <- err
}
}()
// Task should terminate quickly
select {
case err := <-errCh:
t.Fatalf("err: %v", err)
case res := <-resp.Handle.WaitCh():
if res.Successful() {
t.Fatal("should err")