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

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

356
357
358
359
360
361
362
363
364
365
366
  try {
      watchdog =
                new WatchdogServiceImpl(properties, systemRegistry, txnProxy,
          dummyShutdownCtrl);
  } finally {
            if (watchdog != null) watchdog.shutdown();
        }
    }

    @Test public void testConstructedVersion() throws Exception {
  txnScheduler.runTask(new TestAbstractKernelRunnable() {
View Full Code Here
387
388
389
390
391
392
393
394
395
396
397
  WatchdogServiceImpl watchdog =
      new WatchdogServiceImpl(
    SgsTestNode.getDefaultProperties(
        "TestWatchdogServiceImpl", null, null),
    systemRegistry, txnProxy, dummyShutdownCtrl); 
  watchdog.shutdown();
    }

    @Test(expected = IllegalStateException.class)
    public void testConstructorWithMajorVersionMismatch()
  throws Exception
View Full Code Here
451
452
453
454
455
456
457
458
459
460
461
                    checkHealth(watchdog, Health.RED);
                }
            }, taskOwner);

  } finally {
      watchdog.shutdown();
      dataService.shutdown();
  }
    }

    @Test(expected = IllegalStateException.class)
View Full Code Here
462
463
464
465
466
467
468
469
470
471
472
    public void testGetLocalNodeHealthServiceShuttingDown() throws Exception {
  WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      SgsTestNode.getDefaultProperties(
    "TestWatchdogServiceImpl", null, null),
      systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();
  watchdog.getLocalNodeHealth();
    }

    @Test(expected = TransactionNotActiveException.class)
    public void testGetLocalNodeHealthNoTransaction() throws Exception {
View Full Code Here
511
512
513
514
515
516
517
518
519
520
521
                    }
                }
            }, taskOwner);
     
  } finally {
      watchdog.shutdown();
      dataService.shutdown();
  }
    }

    @Test(expected = IllegalStateException.class)
View Full Code Here
522
523
524
525
526
527
528
529
530
531
532
    public void testIsLocalNodeAliveServiceShuttingDown() throws Exception {
  WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      SgsTestNode.getDefaultProperties(
    "TestWatchdogServiceImpl", null, null),
      systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();
  watchdog.isLocalNodeAlive();
    }

    @Test(expected = TransactionNotActiveException.class)
    public void testIsLocalNodeAliveNoTransaction() throws Exception {
View Full Code Here
559
560
561
562
563
564
565
566
567
568
569
         "to return false");
      }
     
  } finally {
      dataService.shutdown();
      watchdog.shutdown();
  }
    }

    @Test(expected = IllegalStateException.class)
    public void testIsLocalNodeAliveNonTransactionalServiceShuttingDown()
View Full Code Here
571
572
573
574
575
576
577
578
579
580
581
    {
  WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      SgsTestNode.getDefaultProperties(
    "TestWatchdogServiceImpl", null, null),
      systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();
  watchdog.isLocalNodeAliveNonTransactional();
    }

    @Test public void testIsLocalNodeAliveNonTransactionalNoTransaction() {
  assertTrue(watchdogService.isLocalNodeAliveNonTransactional());
View Full Code Here
682
683
684
685
686
687
688
689
690
691
692
    public void testGetNodesServiceShuttingDown() throws Exception {
  final WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      SgsTestNode.getDefaultProperties(
    "TestWatchdogServiceImpl", null, null),
      systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();

        txnScheduler.runTask(new TestAbstractKernelRunnable() {
                public void run() throws Exception {
        watchdog.getNodes();
                }
View Full Code Here
728
729
730
731
732
733
734
735
736
737
738
    public void testGetNodeServiceShuttingDown() throws Exception {
  final WatchdogServiceImpl watchdog = new WatchdogServiceImpl(
      SgsTestNode.getDefaultProperties(
    "TestWatchdogServiceImpl", null, null),
      systemRegistry, txnProxy, dummyShutdownCtrl);
  watchdog.shutdown();
        txnScheduler.runTask(new TestAbstractKernelRunnable() {
                public void run() throws Exception {
        watchdog.getNode(0);
                }
            }, taskOwner);
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.