Lines Matching refs:EclReadAndPlay
51 String eclCookie = EclReadAndPlay.INITIAL_COOKIE;
67 EclReadAndPlay.println("INFO", "Connecting to master " + master.host + ":" + master.port + " ......");
69 masterConnection.authenticate( 3, EclReadAndPlay.bindDn, EclReadAndPlay.bindPwd );
70 EclReadAndPlay.println("INFO", "...... Connected to master " + master.host + ":" + master.port );
77 for ( CSN csn: EclReadAndPlay.RUV.values() ) {
85 if ( EclReadAndPlay.eclMode.equals("draft") ) {
90 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString
95 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c );
99 EclReadAndPlay.println("WARNING", "Cannot find changenumber, setting it to 1");
100 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER;
103 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
104 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
112 EclReadAndPlay.println("DEBUG", "Found firstChangeNumber " + changeNumberString);
116 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + c );
120 EclReadAndPlay.println("WARNING", "Cannot find firstChangeNumber, setting it to 1");
121 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER;
124 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
129 EclReadAndPlay.println("DEBUG", "Found changeLogCookie " + eclCookie
132 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
133 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
134 eclCookie = EclReadAndPlay.INITIAL_COOKIE;
137 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
138 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
139 eclCookie = EclReadAndPlay.INITIAL_COOKIE;
144 synchronized (EclReadAndPlay.lock) {
145 EclReadAndPlay.lock.notifyAll();
154 while (idleTime < EclReadAndPlay.MAX_IDLE_TIME) {
155 if ( EclReadAndPlay.eclMode.equals("draft") ) {
156 int limit = changeNumber + (EclReadAndPlay.queueSize - 1);
161 EclReadAndPlay.println("DEBUG", "Getting changes " + changeNumber + " to " + limit);
165 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
174 EclReadAndPlay.println("DEBUG", "Getting changes from cookie: " + eclCookie);
184 EclReadAndPlay.println("DEBUG", "No new change found in ECL => have slept for 100ms");
190 EclReadAndPlay.println("DEBUG", "Going through change entries found in the ECL.");
199 //EclReadAndPlay.println("DEBUG", "Changelog entry: " + entry.toString());
205 EclReadAndPlay.println("DEBUG", "Ignoring change " + entry.getDN() );
206 if ( EclReadAndPlay.eclMode.equals("draft") )
207 EclReadAndPlay.inc_ignored(changeNumber);
208 else if ( EclReadAndPlay.eclMode.equals("opends") )
209 EclReadAndPlay.inc_ignored(eclCookie);
212 if ( EclReadAndPlay.eclMode.equals("draft") ) {
214 EclReadAndPlay.println("DEBUG", "change=" + entry.getDN() + ", changenumber = "
216 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
220 EclReadAndPlay.println ("DEBUG", " ECL cookie value ========> " + eclCookie );
227 if ( EclReadAndPlay.displayMissingChanges == true ) {
228 if ( EclReadAndPlay.eclMode.equals("draft") ) {
234 EclReadAndPlay.lastChangeNumber = Integer.parseInt(attr.getStringValueArray()[0]);
236 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
242 EclReadAndPlay.lastExternalChangelogCookie = attr.getStringValueArray()[0];
247 } /* while (idleTime <= EclReadAndPlay.MAX_IDLE_TIME) */
249 EclReadAndPlay.println("WARNING", "No new changes read in the ECL for " + Integer.toString(idleTime) +
260 EclReadAndPlay.println( "WARNING", "Connection lost to " + master.host + ":" + master.port + ".");
263 EclReadAndPlay.println( "ERROR" , e.toString() );