Repository: ambari Updated Branches: refs/heads/branch-2.5 10b2281ec -> ac19fd107 refs/heads/trunk aeb5d4e55 -> 70f23c070
AMBARI-20119. "Use RedHat Satellite/Spacewalk" setting not working correctly in Ambari 2.4.2.0 (dlysnichenko) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/ac19fd10 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/ac19fd10 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/ac19fd10 Branch: refs/heads/branch-2.5 Commit: ac19fd107ea453d3dbe2d1d81e04303500d52abc Parents: 10b2281 Author: Lisnichenko Dmitro <[email protected]> Authored: Thu Feb 23 14:24:14 2017 +0200 Committer: Lisnichenko Dmitro <[email protected]> Committed: Thu Feb 23 14:24:14 2017 +0200 ---------------------------------------------------------------------- .../ambari/server/state/RepositoryInfo.java | 21 ++++++++++++++++++-- .../stack/upgrade/RepositoryVersionHelper.java | 2 ++ .../upgrade/RepositoryVersionHelperTest.java | 3 ++- 3 files changed, 23 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/ac19fd10/ambari-server/src/main/java/org/apache/ambari/server/state/RepositoryInfo.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/state/RepositoryInfo.java b/ambari-server/src/main/java/org/apache/ambari/server/state/RepositoryInfo.java index 0b8cab8..854f03f 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/state/RepositoryInfo.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/state/RepositoryInfo.java @@ -34,6 +34,7 @@ public class RepositoryInfo { private String latestBaseUrl; private boolean baseSaved = false; private boolean unique = false; + private boolean ambariManagedRepositories = true; /** * @return the baseUrl @@ -156,6 +157,7 @@ public class RepositoryInfo { + ", repoName=" + repoName + ", mirrorsList=" + mirrorsList + ", unique=" + unique + + ", ambariManagedRepositories=" + ambariManagedRepositories + " ]"; } @@ -170,12 +172,13 @@ public class RepositoryInfo { Objects.equal(repoName, that.repoName) && Objects.equal(mirrorsList, that.mirrorsList) && Objects.equal(defaultBaseUrl, that.defaultBaseUrl) && - Objects.equal(latestBaseUrl, that.latestBaseUrl); + Objects.equal(latestBaseUrl, that.latestBaseUrl) && + Objects.equal(ambariManagedRepositories, that.ambariManagedRepositories); } @Override public int hashCode() { - return Objects.hashCode(baseUrl, osType, repoId, repoName, mirrorsList, defaultBaseUrl, latestBaseUrl); + return Objects.hashCode(baseUrl, osType, repoId, repoName, mirrorsList, defaultBaseUrl, latestBaseUrl, ambariManagedRepositories); } public RepositoryResponse convertToResponse() @@ -235,4 +238,18 @@ public class RepositoryInfo { public void setUnique(boolean unique) { this.unique = unique; } + + /** + * @return true if repositories managed by ambari + */ + public boolean isAmbariManagedRepositories() { + return ambariManagedRepositories; + } + + /** + * @param ambariManagedRepositories set is repositories managed by ambari + */ + public void setAmbariManagedRepositories(boolean ambariManagedRepositories) { + this.ambariManagedRepositories = ambariManagedRepositories; + } } http://git-wip-us.apache.org/repos/asf/ambari/blob/ac19fd10/ambari-server/src/main/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelper.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelper.java b/ambari-server/src/main/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelper.java index 9ca6cf4..ef40211 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelper.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelper.java @@ -158,6 +158,7 @@ public class RepositoryVersionHelper { repositoryJson.addProperty(RepositoryResourceProvider.REPOSITORY_REPO_ID_PROPERTY_ID, repository.getRepoId()); repositoryJson.addProperty(RepositoryResourceProvider.REPOSITORY_UNIQUE_PROPERTY_ID, repository.isUnique()); repositoriesJson.add(repositoryJson); + operatingSystemJson.addProperty(OperatingSystemResourceProvider.OPERATING_SYSTEM_AMBARI_MANAGED_REPOS, repository.isAmbariManagedRepositories()); } operatingSystemJson.add(RepositoryVersionResourceProvider.SUBRESOURCE_REPOSITORIES_PROPERTY_ID, repositoriesJson); operatingSystemJson.addProperty(OperatingSystemResourceProvider.OPERATING_SYSTEM_OS_TYPE_PROPERTY_ID, operatingSystem.getKey()); @@ -175,6 +176,7 @@ public class RepositoryVersionHelper { repositoryInfo.setRepoName(repositoryEntity.getName()); repositoryInfo.setBaseUrl(repositoryEntity.getBaseUrl()); repositoryInfo.setOsType(os.getOsType()); + repositoryInfo.setAmbariManagedRepositories(os.isAmbariManagedRepos()); repositoryInfos.add(repositoryInfo); } } http://git-wip-us.apache.org/repos/asf/ambari/blob/ac19fd10/ambari-server/src/test/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelperTest.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelperTest.java b/ambari-server/src/test/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelperTest.java index 437cc42..01e91d1 100644 --- a/ambari-server/src/test/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelperTest.java +++ b/ambari-server/src/test/java/org/apache/ambari/server/state/stack/upgrade/RepositoryVersionHelperTest.java @@ -58,9 +58,10 @@ public class RepositoryVersionHelperTest { repository.setOsType("os"); repository.setRepoId("repoId"); repository.setUnique(true); + repository.setAmbariManagedRepositories(true); repositories.add(repository); final String serialized = helper.serializeOperatingSystems(repositories); - Assert.assertEquals("[{\"repositories\":[{\"Repositories/base_url\":\"baseurl\",\"Repositories/repo_id\":\"repoId\",\"Repositories/unique\":true}],\"OperatingSystems/os_type\":\"os\"}]", serialized); + Assert.assertEquals("[{\"OperatingSystems/ambari_managed_repositories\":true,\"repositories\":[{\"Repositories/base_url\":\"baseurl\",\"Repositories/repo_id\":\"repoId\",\"Repositories/unique\":true}],\"OperatingSystems/os_type\":\"os\"}]", serialized); } }
