Package com.sun.sgs.impl.service.watchdog

Examples of com.sun.sgs.impl.service.watchdog.WatchdogServiceImpl.shutdown()

994
995
996
997
998
999
1000
1001
1002
1003
1004
  throws Exception
    {
  DataService dataService = createDataService(serviceProps);
  WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      serviceProps, systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();
  watchdog.addRecoveryListener(new DummyRecoveryListener());
  dataService.shutdown();
    }

    @Test(expected = NullPointerException.class)
View Full Code Here
1454
1455
1456
1457
1458
1459
1460
1461
1462
1463
1464
  }
           
  // The shutdown controller should be incremented as a result of the
  // failure being reported
  assertEquals(1, dummyShutdownCtrl.getShutdownCount());
  watchdogService.shutdown();
  dataService.shutdown();
    }

    /**
     * Check that a node can shutdown and report a failure when it detects
View Full Code Here
229
230
231
232
233
234
235
236
237
238
239
      dataService = createDataService(serviceProps);
            watchdog = new WatchdogServiceImpl(
    serviceProps, systemRegistry, txnProxy, dummyShutdownCtrl); 
        } finally {
      if (dataService != null) dataService.shutdown();
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test(expected = NullPointerException.class)
    public void testConstructorNullProperties() throws Exception {
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
        WatchdogServiceImpl watchdog = null;
  try {
      watchdog = new WatchdogServiceImpl(null, systemRegistry, txnProxy,
                 dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test(expected = NullPointerException.class)
    public void testConstructorNullRegistry() throws Exception {
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
        WatchdogServiceImpl watchdog = null;
  try {
      watchdog = new WatchdogServiceImpl(serviceProps, null, txnProxy,
                 dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test(expected = NullPointerException.class)
    public void testConstructorNullProxy() throws Exception {
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
  try {
      watchdog =
                    new WatchdogServiceImpl(serviceProps, systemRegistry, null,
              dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }
   
    @Test(expected = NullPointerException.class)
    public void testConstructorNullShutdownCtrl() throws Exception {
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
        try {
            watchdog = new WatchdogServiceImpl(serviceProps, systemRegistry,
                 txnProxy, null);
        } finally {
            if (watchdog != null) {
                watchdog.shutdown();
            }
        }
    }

    @Test(expected = IllegalArgumentException.class)
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
  try {
      watchdog =
                new WatchdogServiceImpl(properties, systemRegistry, txnProxy,
          dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test(expected = IllegalArgumentException.class)
    public void testConstructorPortTooLarge() throws Exception {
View Full Code Here
318
319
320
321
322
323
324
325
326
327
328
  try {
      watchdog =
                new WatchdogServiceImpl(properties, systemRegistry, txnProxy,
          dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test(expected = IllegalArgumentException.class)
    public void testConstructorStartServerRenewIntervalTooSmall()
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
  try {
      watchdog =
                new WatchdogServiceImpl(properties, systemRegistry, txnProxy,
          dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test public void testConstructorStartServerWithLargeRenewInterval()
  throws Exception
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.