forked from docker-java/docker-java
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathWaitContainerCmdImplTest.java
More file actions
125 lines (91 loc) · 4.47 KB
/
Copy pathWaitContainerCmdImplTest.java
File metadata and controls
125 lines (91 loc) · 4.47 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package com.github.dockerjava.core.command;
import com.github.dockerjava.api.command.CreateContainerResponse;
import com.github.dockerjava.api.command.InspectContainerResponse;
import com.github.dockerjava.api.exception.DockerClientException;
import com.github.dockerjava.api.exception.DockerException;
import com.github.dockerjava.api.exception.NotFoundException;
import com.github.dockerjava.api.model.WaitResponse;
import com.github.dockerjava.client.AbstractDockerClientTest;
import org.testng.ITestResult;
import org.testng.annotations.AfterMethod;
import org.testng.annotations.AfterTest;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.BeforeTest;
import org.testng.annotations.Test;
import java.lang.reflect.Method;
import java.util.concurrent.TimeUnit;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.*;
@Test(groups = "integration")
public class WaitContainerCmdImplTest extends AbstractDockerClientTest {
@BeforeTest
public void beforeTest() throws Exception {
super.beforeTest();
}
@AfterTest
public void afterTest() {
super.afterTest();
}
@BeforeMethod
public void beforeMethod(Method method) {
super.beforeMethod(method);
}
@AfterMethod
public void afterMethod(ITestResult result) {
super.afterMethod(result);
}
@Test
public void testWaitContainer() throws DockerException {
CreateContainerResponse container = dockerClient.createContainerCmd("busybox").withCmd("true").exec();
LOG.info("Created container: {}", container.toString());
assertThat(container.getId(), not(isEmptyString()));
dockerClient.startContainerCmd(container.getId()).exec();
int exitCode = dockerClient.waitContainerCmd(container.getId()).exec(new WaitContainerResultCallback())
.awaitStatusCode();
LOG.info("Container exit code: {}", exitCode);
assertThat(exitCode, equalTo(0));
InspectContainerResponse inspectContainerResponse = dockerClient.inspectContainerCmd(container.getId()).exec();
LOG.info("Container Inspect: {}", inspectContainerResponse.toString());
assertThat(inspectContainerResponse.getState().getRunning(), is(equalTo(false)));
assertThat(inspectContainerResponse.getState().getExitCode(), is(equalTo(exitCode)));
}
@Test(expectedExceptions = NotFoundException.class)
public void testWaitNonExistingContainer() throws DockerException {
WaitContainerResultCallback callback = new WaitContainerResultCallback() {
public void onNext(WaitResponse waitResponse) {
fail("expected NotFoundException");
}
};
dockerClient.waitContainerCmd("non-existing").exec(callback).awaitStatusCode();
}
@Test
public void testWaitContainerAbort() throws Exception {
CreateContainerResponse container = dockerClient.createContainerCmd("busybox").withCmd("sleep", "9999").exec();
LOG.info("Created container: {}", container.toString());
assertThat(container.getId(), not(isEmptyString()));
dockerClient.startContainerCmd(container.getId()).exec();
WaitContainerResultCallback callback = dockerClient.waitContainerCmd(container.getId()).exec(
new WaitContainerResultCallback());
Thread.sleep(5000);
callback.close();
dockerClient.killContainerCmd(container.getId()).exec();
InspectContainerResponse inspectContainerResponse = dockerClient.inspectContainerCmd(container.getId()).exec();
LOG.info("Container Inspect: {}", inspectContainerResponse.toString());
assertThat(inspectContainerResponse.getState().getRunning(), is(equalTo(false)));
}
@Test
public void testWaitContainerTimeout() throws Exception {
CreateContainerResponse container = dockerClient.createContainerCmd("busybox").withCmd("sleep", "10").exec();
LOG.info("Created container: {}", container.toString());
assertThat(container.getId(), not(isEmptyString()));
dockerClient.startContainerCmd(container.getId()).exec();
WaitContainerResultCallback callback = dockerClient.waitContainerCmd(container.getId()).exec(
new WaitContainerResultCallback());
try {
callback.awaitStatusCode(100, TimeUnit.MILLISECONDS);
fail("Should throw exception on timeout.");
} catch(DockerClientException e){
LOG.info(e.getMessage());
}
}
}