Lines Matching refs:assured
64 * Test the client part (plugin) of the assured feature in both safe data and
67 * Also check for monitoring values for assured replication
79 "assured-sr-sent-updates", "assured-sr-acknowledged-updates",
80 "assured-sr-not-acknowledged-updates", "assured-sr-timeout-updates",
81 "assured-sr-wrong-status-updates", "assured-sr-replay-error-updates",
82 "assured-sr-received-updates", "assured-sr-received-updates-acked",
83 "assured-sr-received-updates-not-acked", "assured-sd-sent-updates",
84 "assured-sd-acknowledged-updates", "assured-sd-timeout-updates");
120 private final String NOT_ASSURED_DN = "ou=not-assured," + TEST_ROOT_DN_STRING;
179 * Creates a domain using the passed assured settings.
195 fail("Unexpected assured level.");
197 // Create an assured config entry ldif, matching passed assured settings
215 configEntryLdif = prefixLdif + "ds-cfg-assured-type: safe-read\n" +
216 "ds-cfg-assured-timeout: " + assuredTimeout + "ms\n";
219 configEntryLdif = prefixLdif + "ds-cfg-assured-type: safe-data\n" +
220 "ds-cfg-assured-sd-level: " + safeDataLevel + "\n" +
221 "ds-cfg-assured-timeout: " + assuredTimeout + "ms\n";
224 fail("Unexpected assured level.");
237 * Creates a domain without assured mode
242 // Create a not assured config entry ldif
266 * for assured features test.
309 * Constructor for RS receiving updates in SR assured mode or not assured
310 * The assured boolean means:
312 * - false: not assured
314 public FakeReplicationServer(byte groupId, int port, int serverId, boolean assured,
322 if (assured)
329 /** Constructor for RS receiving updates in SD assured mode. */
343 public void setAssured(boolean assured)
345 this.isAssured = assured;
461 // Sanity checking for assured parameters
471 debugInfo("Received start session assured parameters are ok.");
481 * Tells if the received handshake parameters regarding assured config were
508 // If we come here, assured parameters sent by DS are as expected and
561 // Send add message in assured mode
570 /** Read the coming update and check parameters are not assured. */
605 * Receives an {@link UpdateMsg} and checks that received update assured
620 debugInfo("Received update assured parameters are ok.");
720 // Create and start a RS expecting clients in safe data assured mode with
731 // Create a safe data assured domain
740 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
753 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
772 .assertValue("assured-sd-sent-updates", 1)
773 .assertValue("assured-sd-timeout-updates", 1)
783 // sent in assured mode
832 // Create and start a RS expecting clients in safe read assured mode
843 // Create a safe data assured domain
846 // Create a safe read assured domain
853 String entry = "dn: ou=assured-sr-timeout-entry" + rsGroupId + "," + SAFE_READ_DN + "\n" +
866 String entry = "dn: ou=assured-sr-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
884 .assertValue("assured-sr-sent-updates", 1)
885 .assertValue("assured-sr-not-acknowledged-updates", 1)
886 .assertValue("assured-sr-timeout-updates", 1)
896 // sent in assured mode
908 /** Tests parameters sent in session handshake and updates, when not using assured replication. */
915 // Create and start a RS expecting not assured clients
920 // Create a not assured domain
926 String entry = "dn: ou=not-assured-entry," + NOT_ASSURED_DN + "\n" +
999 // Create and start a RS expecting clients in safe data assured mode with
1005 // Create a safe data assured domain
1012 String entry = "dn: ou=assured-sd-no-timeout-entry," + SAFE_DATA_DN + "\n" +
1024 .assertValue("assured-sd-sent-updates", 1)
1025 .assertValue("assured-sd-acknowledged-updates", 1)
1045 // Create and start a RS expecting clients in safe read assured mode
1050 // Create a safe read assured domain
1057 String entry = "dn: ou=assured-sr-no-timeout-entry," + SAFE_READ_DN + "\n" +
1069 .assertValue("assured-sr-sent-updates", 1)
1070 .assertValue("assured-sr-acknowledged-updates", 1)
1090 // Create and start a RS expecting clients in safe read assured mode
1095 // Create a safe read assured domain
1102 // Make the RS send an assured add message
1103 String entryStr = "dn: ou=assured-sr-reply-entry," + SAFE_READ_DN + "\n" +
1129 .assertValue("assured-sr-received-updates", 1)
1130 .assertValue("assured-sr-received-updates-acked", 1)
1147 // Make the RS send a not possible assured add message
1177 // Create and start a RS expecting clients in safe data assured mode
1182 // Create a safe data assured domain
1187 // Make the RS send an assured add message: we expect a read timeout as
1189 String entryStr = "dn: ou=assured-sd-reply-entry," + SAFE_DATA_DN + "\n" +
1219 // Create and start a RS expecting clients in safe data assured mode with
1225 // Create a safe data assured domain
1232 String entryDn = "ou=assured-sd-many-errors-entry," + SAFE_DATA_DN;
1247 .assertValue("assured-sd-sent-updates", 1)
1248 .assertValue("assured-sd-timeout-updates", 1)
1265 .assertValue("assured-sd-sent-updates", 2)
1266 .assertValue("assured-sd-timeout-updates", 2)
1282 .assertValue("assured-sd-sent-updates", 3)
1283 .assertValue("assured-sd-timeout-updates", 3)
1328 // Create and start a RS expecting clients in safe read assured mode
1333 // Create a safe read assured domain
1340 String entryDn = "ou=assured-sr-many-errors-entry," + SAFE_READ_DN;
1355 .assertValue("assured-sr-sent-updates", 1)
1356 .assertValue("assured-sr-not-acknowledged-updates", 1)
1357 .assertValue("assured-sr-replay-error-updates", 1)
1375 .assertValue("assured-sr-sent-updates", 2)
1376 .assertValue("assured-sr-not-acknowledged-updates", 2)
1377 .assertValue("assured-sr-timeout-updates", 1)
1378 .assertValue("assured-sr-wrong-status-updates", 1)
1379 .assertValue("assured-sr-replay-error-updates", 2)
1395 .assertValue("assured-sr-sent-updates", 3)
1396 .assertValue("assured-sr-not-acknowledged-updates", 3)
1397 .assertValue("assured-sr-timeout-updates", 2)
1398 .assertValue("assured-sr-wrong-status-updates", 1)
1399 .assertValue("assured-sr-replay-error-updates", 2)
1422 * - assured-sr-server-not-acknowledged-updates in SR mode
1423 * - assured-sd-server-timeout-updates in SD mode
1451 /* Find the multi valued attribute matching the requested assured mode */
1456 assuredAttr = "assured-sr-server-not-acknowledged-updates";
1459 assuredAttr = "assured-sd-server-timeout-updates";
1462 throw new Exception("Unknown assured type");