21 Aug, 2013
2 commits
-
- Making private the start*() methods - Moved some code to here from some other classes - MAking private the buildAndSendTopoInfoTo*() methods. ReplicationServerDomain.java: Extracted method sendTopoInfoToAllExcept(). Renamed buildAndSendTopoInfoToDSs() to sendTopoInfoToAllDSsExcept() + made it private. Renamed buildAndSendTopoInfoToRSs() to sendTopoInfoToAllRSs() + made it private. Renamed changeStatusFromStatusAnalyzer() to changeStatus(). Made startStatusAnalyzer() and startMonitoringPublisher() private. Directly used the fields connectedDSs and connectedRSs instead of through their getters. Moved 2 register() methods here from DataServerHandler and ReplicationServerHandler. Renamed all variables and parameters named "handler" to disambiguated names. DataServerHandler.java: Renamed changeStatusFromStatusAnalyzer() to changeStatus(). Moved registerIntoDomain() + some other code to ReplicationServerDomain. ReplicationServerHandler.java: Moved registerIntoDomain() + some other code to ReplicationServerDomain. ReplicationServer.java Renamed all variables and parameters named "handler" to disambiguated names. Consequence of the change to ReplicationServerDomain.sendTopoInfoToAllExcept(). StatusAnalyzer.java: Consequence of the change to ReplicationServerDomain.changeStatusFromStatusAnalyzer(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9434 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
- copyright added - doc section added (to complete) git-svn-id: https://svn.forgerock.org/opendj/trunk@9433 41b1ffd8-f28e-4786-ab96-9950f0a78031
20 Aug, 2013
5 commits
-
Fixed off-by-one error. FractionalReplicationTest.java: Removed try / catch / fail test anti pattern. Removed useless comments. Extracted method waitTillEntryHasSynchroAttribute(). Made attributes private. git-svn-id: https://svn.forgerock.org/opendj/trunk@9432 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Used interfaces instead of concrete classes. Removed useless comments. Extracted method addMonitorData(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9431 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Extracted methods newMapIfNull(), getUserOrOperationalAttributes(), getAttributes(), putAttributes(), removeAttributes(), addAllIfNotNull(), onlyKeepAttributesWithAllOptions(), getAttribute(), onlyKeepAttributesWithAllOptions(), addObjectClass(), hasObjectClassOrAttribute(), hasObjectClass(), containsObjectClassByName(), hashCode(), equals(), appendAttributes(), newList(). Comments to javadoc. Used interfaces instead of concrete classes. Collapsed if statements. Put code on one line where possible. LDAPReplicationDomain.java: Extracted methods isSolveConflict(), needReconnection(), findReplicationSearchResultEntry(), isMandatoryAttribute(), isFractionalProhibited(AttributeType), canRemoveAttribute(), contains(), runAsSynchronizedOperation(). Removed useless else. Used interfaces instead of concrete classes. Put code on one line where possible. Removed useless comments. Simplified code in several places. Collapsed if statements. git-svn-id: https://svn.forgerock.org/opendj/trunk@9430 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
It was due to a side effect of the last commit as well as several locations where cleanup wasn't properly done after a test. git-svn-id: https://svn.forgerock.org/opendj/trunk@9429 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9428 41b1ffd8-f28e-4786-ab96-9950f0a78031
19 Aug, 2013
5 commits
-
…ze(PostOperationOperation op) method. Reviewed by JN, CR-2193. git-svn-id: https://svn.forgerock.org/opendj/trunk@9427 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
RSInfo.java, DSInfo.java: Made them (almost) immutable classes. LightweightServerHandler.java: Replaced many instance members with just one DSInfo instance member. git-svn-id: https://svn.forgerock.org/opendj/trunk@9426 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
…nknown function paramter - Added README to explain how to start the STAF daemon and run the tests git-svn-id: https://svn.forgerock.org/opendj/trunk@9425 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
ReplicationServerDomain.java: Used AtomicReference for statusAnalyzer and monitoringPublisher. As a consequence: - Changed update*(), start*() and stop*() methods. - Removed isRunning*() methods. MonitoringPublisher.java: Extracted getMessage() to make error messages more conherent. ServerReader.java: In run(), removed redundant code by checking whether the message is a RoutableMsg. Extracted method logException(). In ServerReader.run(), moved some code to ServerHandler.put(). Code cleanups: - inlined useless local variables - removed useless use of "this" before method calls. DataServerHandler.java, ECLServerHandler.java, ReplicationServerHandler.java: Extracted method createReplServerStartMsg(). ServerHandler.java: Renamed process(WindowProbeMsg) to replyToWindowProbe(). Made some instance members private. Moved createReplServerStartMsg here. In put(), moved decAndCheckWindow() call here from ServerReader.run(). WindowProbeMsg.java: Fixed javadocs + simplified code. git-svn-id: https://svn.forgerock.org/opendj/trunk@9424 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
ReplicationServer.java: Added getConnectedRSUrls(), that aggregates code from ReplicationServerDomain.getChangelogs() and from runConnect(). In applyConfigurationChange(), moved code to ReplicationServerDomain for better encapsulation. ReplicationServerDomain.java: Renamed checkForDuplicateDS() into isAlreadyConnectedToDS(). Renamed checkForDuplicateRS() into isAlreadyConnectedToRS(). Moved getChangelogs() to ReplicationServer. Made several methods private to reduce coupling and enforce class responsibilities. Generalized the use of isRunningStatusAnalyzer() and isRunningMonitoringPublisher() to improved readability. Inlined updateStatusAnalyzer() and updateMonitoringPublisher(). Moved code from ... to create updateDegradedStatusThreshold() and updateMonitoringPeriod(). In stopReplicationServers(), renamed parameter for increased readability. DataServerHandler.java: Inlined createStatusAnalyzer(). ServerHandler.java, ReplicationServerHandler.java: Inlined createMonitoringPublisher(). In lockDomain(), removed useless else. Code cleanup. StatusAnalyzer.java: Extracted isInterrupted(). Extracted getMessage() to make error messages more conherent. git-svn-id: https://svn.forgerock.org/opendj/trunk@9423 41b1ffd8-f28e-4786-ab96-9950f0a78031
15 Aug, 2013
1 commit
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9421 41b1ffd8-f28e-4786-ab96-9950f0a78031
14 Aug, 2013
5 commits
-
Renamed directoryServers to connectedDSs. Renamed replicationServers to connectedRSs. Removed the useless getConnectedLDAPservers(), replaced with getConnectedDSs(). Renamed a few local variables. DataServerHandler.java: Consequence of removing to ReplicationServerDomain.getConnectedLDAPservers() Extracted method changeStatus() from changeStatusFromStatusAnalyzer() and changeStatusForResetGenId(). Extracted method getStatusMachineEvent() from changeStatusForResetGenId(). InitOnLineTest.java Consequence of removing to ReplicationServerDomain.getConnectedLDAPservers(). Removed useless try / catch / fail. Extracted methods getCompletionTime(), assertAttributeValue(). Used Assertions.assertThat(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9418 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
- Updated i18n/datacomparison reference file git-svn-id: https://svn.forgerock.org/opendj/trunk@9417 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
In the ctor, renamed parameters. In other methods, used early exit. git-svn-id: https://svn.forgerock.org/opendj/trunk@9416 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Removed ReplicationServerDomain.getReplicationServer() to follow the Law of Demeter: "Only talk to your immediate friends." to promote loose coupling. Changed approxFirstMissingDate from Long object to long primitive. ReplicationServerDomain.java: Removed getReplicationServer(). Added getLocalRSMonitorInstanceName() and getLocalRSServerId(). *.java: Used the newly added ReplicationServerDomain.getLocalRSMonitorInstanceName() and ReplicationServerDomain.getLocalRSServerId(). LightweightServerHandler.java: Removed getLocalRSMonitorInstanceName(). MonitorMsg.java, MonitorData.java: Changed firstMissingDate from Long object to long primitive. Used StringBuilder in toString(). SynchronizationMsgTest.java Changed approxFirstMissingDate from Long object to long primitive. Extracted methods newList(), newSet(), getEntryAttributes(), assertAttributesEqual(). Used assertEquals() instead of assertTrue(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9415 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Removed avoidable references to replicationServerDomain.getReplicationServer(). Code cleanups: - collapsed if statements - applied early exits - Replaced useless use of StringBulders with string concatenations - Removed useless parentheses *ServerHandler.java: Replaced calls to this.replicationServerDomain.getReplicationServer() with directly using this.replicationServer . DataServerHandler.java: Inlined local variables. Removed useless catch. ECLServerHandler.java: Extracted method releaseIterator(). LightweightServerHandler.java: Extracted method getLocalRSMonitorInstanceName(). ReplicationServerHandler.java In isRemoteLDAPServer(), renamed parameter. MessageHandler.java: Extracted methods collectAllIteratorsWithChanges(), addIteratorIfNotEmpty(), releaseAllIterators(). ReplicationServerDomain.java Renamed replicationServer to localReplicationServer. In put(), renamed id to serverId + extracted method publishMessage(). In getChangelogIterator(), renamed parameter. Extracted methods replyWithMonitorMsg(), replyWithUnroutableMsgType(), forwardMsgToAllServers(), replyWithUnreachablePeerMsg() from process(). Renamed stopDbHandlers() to shutdownDbHandlers(). Extracted isServerConnected() from getEligibleCN(). DbHandler.java, JEReplicationIterator.java: Renamed parameter. git-svn-id: https://svn.forgerock.org/opendj/trunk@9414 41b1ffd8-f28e-4786-ab96-9950f0a78031
13 Aug, 2013
13 commits
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9413 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Thanks to JN for his help :) git-svn-id: https://svn.forgerock.org/opendj/trunk@9412 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Moved all JE changelog related classes to the new package org.opends.server.replication.server.changelog.je DbHandler.java, DraftCNData.java, DraftCNDB.java, DraftCNDbHandler.java, DraftCNDbIterator.java, JEReplicationIterator.java, package-info.java, ReplicationData.java, ReplicationDB.java, ReplicationDbEnv.java, ReplicationDraftCNKey.java, DbHandlerTest.java, DraftCNDbHandlerTest.java: Moved to package org.opends.server.replication.server.changelog.je ReplicationServer.java: Updated the imports. Made getTrimAge() public. Removed use of "this" from method invocation. Moved handleUnexpectedChangelogException() to ReplicationDbEnv. DraftCNDB.java, ReplicationDB.java: Moved handleUnexpectedDatabaseException() to ReplicationDbEnv. ReplicationDbEnv.java: Moved handleUnexpectedChangelogException() here from ReplicationServer, and renamed it to shutdownOnException(). Moved handleUnexpectedDatabaseException() here from DraftCNDB and ReplicationDB, and renamed it to shutdownOnException(). ECLServerHandler.java, ReplicationServerDomain.java, ExternalChangeLogTest.java: Updated the imports. git-svn-id: https://svn.forgerock.org/opendj/trunk@9411 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9410 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Extracted interface org.opends.server.replication.server.changelog.api.ReplicationIterator from org.opends.server.replication.server.ReplicationIterator and used it in all the places where the class was used. Renamed ReplicationIterator class to JEReplicationIterator. Moved ReplicationIteratorComparator from package org.opends.server.replication.server to org.opends.server.replication.server.changelog.api. MessageHandler.java: Minimal code cleanup. git-svn-id: https://svn.forgerock.org/opendj/trunk@9409 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
In next(), removed useless local variable. Renamed instance field from dbh to dbHandler. git-svn-id: https://svn.forgerock.org/opendj/trunk@9408 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9407 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Extracted constants SERVER_ID_1 and SERVER_ID_2. Renamed getAttributeValue() to getAttributeValueOrNull(). Extracted new getAttributeValue() from getAttributeValueOrNull(), checkValue() and checkPossibleValues(). In ECLGetEligibleCountTest(), extracted constants to better explicit the code + removed the count local variable + extracted method now() Removed useless code blocks. ReplicationServerDomain.java: In getEligibleCount(), removed a useless if statement. git-svn-id: https://svn.forgerock.org/opendj/trunk@9406 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Reviewed in CR 2142. git-svn-id: https://svn.forgerock.org/opendj/trunk@9405 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Converted comments to javadoc. git-svn-id: https://svn.forgerock.org/opendj/trunk@9404 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9403 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
…at files can cope with the absence of the file, we can remove it completely. CR-2142 git-svn-id: https://svn.forgerock.org/opendj/trunk@9402 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Upgraded to grizzly 2.3.5 which removes grizzly-rcm dependency :) git-svn-id: https://svn.forgerock.org/opendj/trunk@9401 41b1ffd8-f28e-4786-ab96-9950f0a78031
12 Aug, 2013
3 commits
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9400 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Hid low level JE's DatabaseException and ReplicationDBException from replication higher level code. They have been replaced by the newly created ChangelogException. Tidied up the exception handling by throwing or catching more specific exceptions. Moved some code to protect them with try / catch. Adding a few catch for specific handling of ChangelogException. Threw ChangelogException instead of Exception. Added handleUnexpectedDatabaseException() methods. ReplicationDBException.java: REMOVED (now useless) replication*.properties: Removed ERR_COULD_NOT_INITIALIZE_DB, not adding anything to ERR_COULD_NOT_READ_DB. Removed "this." from member method invocations. Used Integer.parseInt(). Used StaticUtils.close(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9399 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Removed another 200 lines. Extracted several methods: newSet(), generateChangeNumbers(), checkDn(), assertDnEquals(), debugAndWriteEntries(), createDomain(), runDeleteOperation(), assertOnlyDoneMsgReceived. Removed useless / unused / plain wrong code. Removed commented out code. assertTrue() => assertEquals(). Used assertj assertThat(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9398 41b1ffd8-f28e-4786-ab96-9950f0a78031
11 Aug, 2013
1 commit
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9397 41b1ffd8-f28e-4786-ab96-9950f0a78031
09 Aug, 2013
5 commits
-
In ECLTwoDomains(), inverted 2 parameters to fix another test failure. git-svn-id: https://svn.forgerock.org/opendj/trunk@9396 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
git-svn-id: https://svn.forgerock.org/opendj/trunk@9395 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
In ECLAfterChangelogTrim(), inverted 2 parameters to fix a test failure. Used AutoRefactor plugin. Extracted method waitForClose(). git-svn-id: https://svn.forgerock.org/opendj/trunk@9394 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Improved javadocs. ExternalChangeLogTest.java: In ECLTwoDomains(), fixed the test. Extracted runModifyOperation() and createMods(). PersistentSearchChangeType.java, ChangeOperationType.java: Improved javadocs. Increased vertical density. Code cleanup. LDAPReplicationDomain.java: Added comments / javadocs. DraftCNDB.java: Used static import to put if conditions on just one line. git-svn-id: https://svn.forgerock.org/opendj/trunk@9393 41b1ffd8-f28e-4786-ab96-9950f0a78031
-
Knocked off 500 lines of code by extracting various methods. This makes the code easier to read even though it is still sometimes puzzling. git-svn-id: https://svn.forgerock.org/opendj/trunk@9392 41b1ffd8-f28e-4786-ab96-9950f0a78031