private void prepareRPConsistencyGroupData() throws Exception {
  log.info("Preparing RecoverPoint consistency group data for RecoverPointConsistencyGroupMigration");
  TenantOrg tenantOrg=new TenantOrg();
  URI tenantOrgURI=URIUtil.createId(TenantOrg.class);
  tenantOrg.setId(tenantOrgURI);
  _dbClient.createObject(tenantOrg);
  Project proj=new Project();
  URI projectURI=URIUtil.createId(Project.class);
  String projectLabel="project";
  proj.setId(projectURI);
  proj.setLabel(projectLabel);
  proj.setTenantOrg(new NamedURI(tenantOrgURI,projectLabel));
  _dbClient.createObject(proj);
  ProtectionSet cg1ps=createProtectionSetData("cg1",projectURI);
  List<Volume> cg1Volumes=createRpVolumes("cg1volume1",1,cg1ps);
  cg1Volumes.addAll(createRpVolumes("cg1volume2",1,cg1ps));
  addVolumesToProtectionSet(cg1ps.getId(),cg1Volumes);
  createBlockSnapshotData("cg1Snap",cg1Volumes);
  ProtectionSet cg2ps=createProtectionSetData("cg2",projectURI);
  List<Volume> cg2Volumes=createRpVolumes("cg2volume1",2,cg2ps);
  cg2Volumes.addAll(createRpVolumes("cg2volume2",2,cg2ps));
  addVolumesToProtectionSet(cg2ps.getId(),cg2Volumes);
  createBlockSnapshotData("cg2Snap",cg2Volumes);
  ProtectionSet cg3ps=createProtectionSetData("cg3",projectURI);
  List<Volume> cg3Volumes=createRpVolumes("cg3volume1",3,cg3ps);
  addVolumesToProtectionSet(cg3ps.getId(),cg3Volumes);
  createBlockSnapshotData("cg3Snap",cg3Volumes);
  for (  URI volumeURI : rpTestVolumeURIs) {
    Volume volume=_dbClient.queryObject(Volume.class,volumeURI);
    Assert.assertNotNull(String.format("RecoverPoint test volume %s not found",volumeURI),volume);
  }
}

private void prepareRPConsistencyGroupData ( ) throws Exception { log . info ( "Preparing RecoverPoint consistency group data for RecoverPointConsistencyGroupMigration" ) ; TenantOrg tenantOrg = new TenantOrg ( ) ; URI tenantOrgURI = URIUtil . createId ( TenantOrg . class ) ; tenantOrg . setId ( tenantOrgURI ) ; _dbClient . createObject ( tenantOrg ) ; Project proj = new Project ( ) ; URI projectURI = URIUtil . createId ( Project . class ) ; String projectLabel = "project" ; proj . setId ( projectURI ) ; proj . setLabel ( projectLabel ) ; proj . setTenantOrg ( new NamedURI ( tenantOrgURI , projectLabel ) ) ; _dbClient . createObject ( proj ) ; ProtectionSet cg1ps = createProtectionSetData ( "cg1" , projectURI ) ; List < Volume > cg1Volumes = createRpVolumes ( "cg1volume1" , 1 , cg1ps ) ; cg1Volumes . addAll ( createRpVolumes ( "cg1volume2" , 1 , cg1ps ) ) ; addVolumesToProtectionSet ( cg1ps . getId ( ) , cg1Volumes ) ; createBlockSnapshotData ( "cg1Snap" , cg1Volumes ) ; ProtectionSet cg2ps = createProtectionSetData ( "cg2" , projectURI ) ; List < Volume > cg2Volumes = createRpVolumes ( "cg2volume1" , 2 , cg2ps ) ; cg2Volumes . addAll ( createRpVolumes ( "cg2volume2" , 2 , cg2ps ) ) ; addVolumesToProtectionSet ( cg2ps . getId ( ) , cg2Volumes ) ; createBlockSnapshotData ( "cg2Snap" , cg2Volumes ) ; ProtectionSet cg3ps = createProtectionSetData ( "cg3" , projectURI ) ; List < Volume > cg3Volumes = createRpVolumes ( "cg3volume1" , 3 , cg3ps ) ; addVolumesToProtectionSet ( cg3ps . getId ( ) , cg3Volumes ) ; createBlockSnapshotData ( "cg3Snap" , cg3Volumes ) ; for ( URI volumeURI : rpTestVolumeURIs ) { Volume volume = _dbClient . queryObject ( Volume . class , volumeURI ) ; Assert . assertNotNull ( String . format ( "RecoverPoint test volume %s not found" , volumeURI ) , volume ) ; } }
prepares the data for rp volume tests .
