Package org.apache.ambari.server.actionmanager

Examples of org.apache.ambari.server.actionmanager.ActionManager

706
707
708
709
710
711
712
713
714
715
716
    statusCmd1.setServiceName(HDFS);
    dummyCmds.add(statusCmd1);
    HeartbeatMonitor hm = mock(HeartbeatMonitor.class);
    when(hm.generateStatusCommands(anyString())).thenReturn(dummyCmds);

    ActionManager am = getMockActionManager();
    Clusters fsm = clusters;
    ActionQueue actionQueue = new ActionQueue();
    HeartBeatHandler handler = new HeartBeatHandler(fsm, actionQueue, am,
        injector);
    handler.setHeartbeatMonitor(hm);
View Full Code Here
732
733
734
735
736
737
738
739
740
741
742
    assertTrue(registrationResponse.getStatusCommands().get(0).equals(statusCmd1));
  }

  @Test
  public void testTaskInProgressHandling() throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>(){{
      add(DummyHostname1);
View Full Code Here
793
794
795
796
797
798
799
800
801
802
803
   * @throws InvalidStateTransitionException
   */
  @Test
  public void testCommandReportOnHeartbeatUpdatedState()
      throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>() {{
      add(DummyHostname1);
View Full Code Here
907
908
909
910
911
912
913
914
915
916
917
        State.INSTALLED, serviceComponentHost1.getState());
  }

  @Test
  public void testUpgradeSpecificHandling() throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>() {{
      add(DummyHostname1);
View Full Code Here
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
        State.UPGRADING, serviceComponentHost1.getState());
  }

  @Test
  public void testStatusHeartbeatWithVersion() throws Exception {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>(){{
      add(DummyHostname1);
View Full Code Here
1068
1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
    assertTrue(hb.getAgentEnv().getHostHealth().getServerTimeStampAtReporting() >= hb.getTimestamp());
  }

  @Test
  public void testComponentUpgradeCompleteReport() throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>(){{
      add(DummyHostname1);
View Full Code Here
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
            stack122, serviceComponentHost2.getStackVersion());
  }

  @Test
  public void testComponentUpgradeInProgressReport() throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>(){{
      add(DummyHostname1);
View Full Code Here
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
  }


  @Test
  public void testComponentUpgradeFailReport() throws AmbariException, InvalidStateTransitionException {
    ActionManager am = getMockActionManager();
    Cluster cluster = getDummyCluster();

    @SuppressWarnings("serial")
    Set<String> hostNames = new HashSet<String>(){{
      add(DummyHostname1);
View Full Code Here
1307
1308
1309
1310
1311
1312
1313
1314
    assertEquals("Stack version of SCH should not change after fail report",
            State.INSTALL_FAILED, serviceComponentHost2.getState());
  }

  private ActionManager getMockActionManager() {
    return new ActionManager(0, 0, null, null,
              new ActionDBInMemoryImpl(), new HostsMap((String) null), null, unitOfWork, null);
  }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
    injector.getInstance(PersistService.class).stop();
  }

  @Test
  public void testHeartbeat() throws Exception {
    ActionManager am = getMockActionManager();
    Clusters fsm = clusters;
    fsm.addHost(DummyHostname1);
    Host hostObject = clusters.getHost(DummyHostname1);
    hostObject.setIPv4("ipv4");
    hostObject.setIPv6("ipv6");
View Full Code Here
TOP

Related Classes of org.apache.ambari.server.actionmanager.ActionManager

  • org.apache.ambari.server.agent.TestHeartbeatHandler
  • org.apache.ambari.server.agent.TestHeartbeatMonitor
  • org.apache.ambari.server.controller.AmbariServer
  • org.apache.ambari.server.controller.internal.ActionResourceProviderTest
  • org.apache.ambari.server.controller.internal.RequestResourceProvider
  • org.apache.ambari.server.controller.internal.RequestResourceProviderTest
  • org.apache.ambari.server.controller.internal.RequestStageContainerTest
  • org.apache.ambari.server.state.host.HostTest
  • java.util.concurrent.atomic.AtomicLong
    • Copyright © 2018 www.massapicom. 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.