hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/ozone/container/common/TestEndPoint.java
@Test
  public void testContainerReportSend() throws Exception {
    final int count = 1000;
    scmServerImpl.reset();
    try (EndpointStateMachine rpcEndPoint =
             createEndpoint(SCMTestUtils.getConf(),
                 serverAddress, 1000)) {
      ContainerReportsResponseProto responseProto = rpcEndPoint
          .getEndPoint().sendContainerReport(createDummyContainerReports(
              count));
      Assert.assertNotNull(responseProto);
    }
    Assert.assertEquals(1, scmServerImpl.getContainerReportsCount());
    Assert.assertEquals(count, scmServerImpl.getContainerCount());
  }
/**
   * Tests that rpcEndpoint sendContainerReport works as expected.
   * @throws Exception
   */
Tests that rpcEndpoint sendContainerReport works as expected.
@throws Exception
Tests that rpcEndpoint sendContainerReport works as expected . @throws Exception
@Test
  public void testContainerReportSend() throws Exception {
    final int count = 1000;
    scmServerImpl.reset();
    try (EndpointStateMachine rpcEndPoint =
             createEndpoint(SCMTestUtils.getConf(),
                 serverAddress, 1000)) {
      ContainerReportsResponseProto responseProto = rpcEndPoint
          .getEndPoint().sendContainerReport(createDummyContainerReports(
              count));
      Assert.assertNotNull(responseProto);
    }
    Assert.assertEquals(1, scmServerImpl.getContainerReportsCount());
    Assert.assertEquals(count, scmServerImpl.getContainerCount());
  }
@ Test public void testContainerReportSend ( ) throws Exception { final int count = 1000 ; scmServerImpl . reset ( ) ; try ( EndpointStateMachine rpcEndPoint = createEndpoint ( SCMTestUtils . getConf ( ) , serverAddress , 1000 ) ) { ContainerReportsResponseProto responseProto = rpcEndPoint . getEndPoint ( ) . sendContainerReport ( createDummyContainerReports ( count ) ) ; Assert . assertNotNull ( responseProto ) ; } Assert . assertEquals ( 1 , scmServerImpl . getContainerReportsCount ( ) ) ; Assert . assertEquals ( count , scmServerImpl . getContainerCount ( ) ) ; }
Tests that rpcEndpoint sendContainerReport works as expected.
Tests that rpcEndpoint sendContainerReport works as expected .