Home | History | Annotate | Download | only in concurrent

Lines Matching refs:service

50       AbstractIdleService service = new DefaultService();
51 service.startAsync().awaitRunning();
52 assertEquals(Service.State.RUNNING, service.state());
53 service.stopAsync().awaitTerminated();
54 assertEquals(Service.State.TERMINATED, service.state());
59 AbstractIdleService service = new DefaultService() {
65 service.startAsync().awaitRunning();
70 assertEquals(Service.State.FAILED, service.state());
75 AbstractIdleService service = new DefaultService() {
80 service.startAsync().awaitRunning();
82 service.stopAsync().awaitTerminated();
87 assertEquals(Service.State.FAILED, service.state());
92 TestService service = new TestService();
93 assertEquals(0, service.startUpCalled);
94 service.startAsync().awaitRunning();
95 assertEquals(1, service.startUpCalled);
96 assertEquals(Service.State.RUNNING, service.state());
97 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder();
102 TestService service = new TestService() {
108 assertEquals(0, service.startUpCalled);
110 service.startAsync().awaitRunning();
115 assertEquals(1, service.startUpCalled);
116 assertEquals(Service.State.FAILED, service.state());
117 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder();
121 TestService service = new TestService();
122 service.stopAsync().awaitTerminated();
123 assertEquals(0, service.startUpCalled);
124 assertEquals(0, service.shutDownCalled);
125 assertEquals(Service.State.TERMINATED, service.state());
126 assertThat(service.transitionStates).isEmpty();
130 TestService service = new TestService();
131 service.startAsync().awaitRunning();
132 assertEquals(1, service.startUpCalled);
133 assertEquals(0, service.shutDownCalled);
134 service.stopAsync().awaitTerminated();
135 assertEquals(1, service.startUpCalled);
136 assertEquals(1, service.shutDownCalled);
137 assertEquals(Service.State.TERMINATED, service.state());
138 assertThat(service.transitionStates)
139 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder();
144 TestService service = new TestService() {
150 service.startAsync().awaitRunning();
151 assertEquals(1, service.startUpCalled);
152 assertEquals(0, service.shutDownCalled);
154 service.stopAsync().awaitTerminated();
159 assertEquals(1, service.startUpCalled);
160 assertEquals(1, service.shutDownCalled);
161 assertEquals(Service.State.FAILED, service.state());
162 assertThat(service.transitionStates)
163 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder();
167 AbstractIdleService service = new TestService();
168 assertEquals("TestService [NEW]", service.toString());
169 service.startAsync().awaitRunning();
170 assertEquals("TestService [RUNNING]", service.toString());
171 service.stopAsync().awaitTerminated();
172 assertEquals("TestService [TERMINATED]", service.toString());
176 // Create a service whose executor will never run its commands
177 Service service = new TestService() {
185 service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS);
188 assertThat(e.getMessage()).contains(Service.State.STARTING.toString());