Switch tests to mock_driver
This commit is contained in:
parent
2e57f39915
commit
5f9cb4c514
|
@ -135,21 +135,12 @@ func TestAllocRunner_RetryArtifact(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAllocRunner_TerminalUpdate_Destroy(t *testing.T) {
|
func TestAllocRunner_TerminalUpdate_Destroy(t *testing.T) {
|
||||||
ctestutil.ExecCompatible(t)
|
|
||||||
upd, ar := testAllocRunner(false)
|
upd, ar := testAllocRunner(false)
|
||||||
|
|
||||||
// Shrink chroot
|
|
||||||
ar.config.ChrootEnv = map[string]string{
|
|
||||||
"/bin": "/bin",
|
|
||||||
"/lib": "/lib",
|
|
||||||
"/lib32": "/lib32",
|
|
||||||
"/lib64": "/lib64",
|
|
||||||
}
|
|
||||||
|
|
||||||
// Ensure task takes some time
|
// Ensure task takes some time
|
||||||
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
||||||
task.Config["command"] = "/bin/sleep"
|
task.Driver = "mock_driver"
|
||||||
task.Config["args"] = []string{"10"}
|
task.Config["run_for"] = "10s"
|
||||||
go ar.Run()
|
go ar.Run()
|
||||||
|
|
||||||
testutil.WaitForResult(func() (bool, error) {
|
testutil.WaitForResult(func() (bool, error) {
|
||||||
|
@ -242,21 +233,12 @@ func TestAllocRunner_TerminalUpdate_Destroy(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAllocRunner_Destroy(t *testing.T) {
|
func TestAllocRunner_Destroy(t *testing.T) {
|
||||||
ctestutil.ExecCompatible(t)
|
|
||||||
upd, ar := testAllocRunner(false)
|
upd, ar := testAllocRunner(false)
|
||||||
|
|
||||||
// Shrink chroot
|
|
||||||
ar.config.ChrootEnv = map[string]string{
|
|
||||||
"/bin": "/bin",
|
|
||||||
"/lib": "/lib",
|
|
||||||
"/lib32": "/lib32",
|
|
||||||
"/lib64": "/lib64",
|
|
||||||
}
|
|
||||||
|
|
||||||
// Ensure task takes some time
|
// Ensure task takes some time
|
||||||
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
||||||
task.Config["command"] = "/bin/sleep"
|
task.Driver = "mock_driver"
|
||||||
task.Config["args"] = []string{"10"}
|
task.Config["run_for"] = "10s"
|
||||||
go ar.Run()
|
go ar.Run()
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
|
|
||||||
|
@ -306,13 +288,12 @@ func TestAllocRunner_Destroy(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAllocRunner_Update(t *testing.T) {
|
func TestAllocRunner_Update(t *testing.T) {
|
||||||
ctestutil.ExecCompatible(t)
|
|
||||||
_, ar := testAllocRunner(false)
|
_, ar := testAllocRunner(false)
|
||||||
|
|
||||||
// Ensure task takes some time
|
// Ensure task takes some time
|
||||||
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
task := ar.alloc.Job.TaskGroups[0].Tasks[0]
|
||||||
task.Config["command"] = "/bin/sleep"
|
task.Driver = "mock_driver"
|
||||||
task.Config["args"] = []string{"10"}
|
task.Config["run_for"] = "10s"
|
||||||
go ar.Run()
|
go ar.Run()
|
||||||
defer ar.Destroy()
|
defer ar.Destroy()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue