| | |
| | | private static final int DS6_SDL = -1; |
| | | private static SortedSet<String> DS6_RU = new TreeSet<String>(); |
| | | |
| | | private static String LOCAL_HOST_NAME; |
| | | |
| | | static |
| | | { |
| | | DS2_RU.add("ldap://fake_url_for_ds2"); |
| | | |
| | | DS6_RU.add("ldap://fake_url_for_ds6_A"); |
| | | DS6_RU.add("ldap://fake_url_for_ds6_B"); |
| | | |
| | | try |
| | | { |
| | | LOCAL_HOST_NAME = InetAddress.getLocalHost().getHostName(); |
| | | } |
| | | catch (UnknownHostException e) |
| | | { |
| | | fail("Unable to resolve local host name", e); |
| | | } |
| | | } |
| | | |
| | | private int rs1Port = -1; |
| | |
| | | |
| | | if (rsIdToExclude != RS1_ID) |
| | | { |
| | | replServers.add("localhost:" + rs1Port); |
| | | replServers.add(getHostPort(rs1Port)); |
| | | } |
| | | if (rsIdToExclude != RS2_ID) |
| | | { |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | } |
| | | if (rsIdToExclude != RS3_ID) |
| | | { |
| | | replServers.add("localhost:" + rs3Port); |
| | | replServers.add(getHostPort(rs3Port)); |
| | | } |
| | | |
| | | return replServers; |
| | |
| | | switch (dsId) |
| | | { |
| | | case DS1_ID: |
| | | replServers.add("localhost:" + rs1Port); |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add("localhost:" + rs3Port); |
| | | replServers.add(getHostPort(rs1Port)); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | replServers.add(getHostPort(rs3Port)); |
| | | |
| | | groupId = DS1_GID; |
| | | assuredType = DS1_AT; |
| | |
| | | refUrls = DS1_RU; |
| | | break; |
| | | case DS2_ID: |
| | | replServers.add("localhost:" + rs1Port); |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add("localhost:" + rs3Port); |
| | | replServers.add(getHostPort(rs1Port)); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | replServers.add(getHostPort(rs3Port)); |
| | | |
| | | groupId = DS2_GID; |
| | | assuredType = DS2_AT; |
| | |
| | | refUrls = DS2_RU; |
| | | break; |
| | | case DS3_ID: |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | |
| | | groupId = DS3_GID; |
| | | assuredType = DS3_AT; |
| | |
| | | refUrls = DS3_RU; |
| | | break; |
| | | case DS4_ID: |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | |
| | | groupId = DS4_GID; |
| | | assuredType = DS4_AT; |
| | |
| | | refUrls = DS4_RU; |
| | | break; |
| | | case DS5_ID: |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add("localhost:" + rs3Port); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | replServers.add(getHostPort(rs3Port)); |
| | | |
| | | groupId = DS5_GID; |
| | | assuredType = DS5_AT; |
| | |
| | | refUrls = DS5_RU; |
| | | break; |
| | | case DS6_ID: |
| | | replServers.add("localhost:" + rs2Port); |
| | | replServers.add("localhost:" + rs3Port); |
| | | replServers.add(getHostPort(rs2Port)); |
| | | replServers.add(getHostPort(rs3Port)); |
| | | |
| | | groupId = DS6_GID; |
| | | assuredType = DS6_AT; |
| | |
| | | { |
| | | int groupId = -1; |
| | | String serverUrl = null; |
| | | String localHostname = null; |
| | | try |
| | | { |
| | | localHostname = InetAddress.getLocalHost().getHostName(); |
| | | } catch (UnknownHostException ex) |
| | | { |
| | | fail("Could not get local host name: " + ex.getMessage()); |
| | | } |
| | | switch (rsId) |
| | | { |
| | | case RS1_ID: |
| | | groupId = RS1_GID; |
| | | serverUrl = localHostname + ":" + rs1Port; |
| | | serverUrl = getHostPort(rs1Port); |
| | | break; |
| | | case RS2_ID: |
| | | groupId = RS2_GID; |
| | | serverUrl = localHostname + ":" + rs2Port; |
| | | serverUrl = getHostPort(rs2Port); |
| | | break; |
| | | case RS3_ID: |
| | | groupId = RS3_GID; |
| | | serverUrl = localHostname + ":" + rs3Port; |
| | | serverUrl = getHostPort(rs3Port); |
| | | break; |
| | | default: |
| | | fail("Unknown replication server id."); |
| | |
| | | "CONNECTED RS SERVERS:\n" + rsStr); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | private String getHostPort(int port) |
| | | { |
| | | return LOCAL_HOST_NAME + ":" + port; |
| | | } |
| | | } |