Lines Matching refs:EclReadAndPlay
52 String eclCookie = EclReadAndPlay.INITIAL_COOKIE;
68 EclReadAndPlay.println("INFO", "Connecting to master " + master.host + ":" + master.port + " ......");
70 masterConnection.authenticate( 3, EclReadAndPlay.bindDn, EclReadAndPlay.bindPwd );
71 EclReadAndPlay.println("INFO", "...... Connected to master " + master.host + ":" + master.port );
78 for ( CSN csn: EclReadAndPlay.RUV.values() ) {
86 if ( EclReadAndPlay.eclMode.equals("draft") ) {
91 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString
96 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c );
100 EclReadAndPlay.println("WARNING", "Cannot find changenumber, setting it to 1");
101 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER;
104 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
105 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
113 EclReadAndPlay.println("DEBUG", "Found firstChangeNumber " + changeNumberString);
117 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + c );
121 EclReadAndPlay.println("WARNING", "Cannot find firstChangeNumber, setting it to 1");
122 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER;
125 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
130 EclReadAndPlay.println("DEBUG", "Found changeLogCookie " + eclCookie
133 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
134 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
135 eclCookie = EclReadAndPlay.INITIAL_COOKIE;
138 EclReadAndPlay.println("WARNING", "Cannot find a changelog entry for csn " + csn );
139 EclReadAndPlay.println("WARNING", "Will start from the first changelog entry");
140 eclCookie = EclReadAndPlay.INITIAL_COOKIE;
145 synchronized (EclReadAndPlay.lock) {
146 EclReadAndPlay.lock.notifyAll();
155 while (idleTime < EclReadAndPlay.MAX_IDLE_TIME) {
156 if ( EclReadAndPlay.eclMode.equals("draft") ) {
157 int limit = changeNumber + (EclReadAndPlay.queueSize - 1);
162 EclReadAndPlay.println("DEBUG", "Getting changes " + changeNumber + " to " + limit);
166 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
175 EclReadAndPlay.println("DEBUG", "Getting changes from cookie: " + eclCookie);
185 EclReadAndPlay.println("DEBUG", "No new change found in ECL => have slept for 100ms");
191 EclReadAndPlay.println("DEBUG", "Going through change entries found in the ECL.");
200 //EclReadAndPlay.println("DEBUG", "Changelog entry: " + entry.toString());
206 EclReadAndPlay.println("DEBUG", "Ignoring change " + entry.getDN() );
207 if ( EclReadAndPlay.eclMode.equals("draft") )
208 EclReadAndPlay.inc_ignored(changeNumber);
209 else if ( EclReadAndPlay.eclMode.equals("opends") )
210 EclReadAndPlay.inc_ignored(eclCookie);
213 if ( EclReadAndPlay.eclMode.equals("draft") ) {
215 EclReadAndPlay.println("DEBUG", "change=" + entry.getDN() + ", changenumber = "
217 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
221 EclReadAndPlay.println ("DEBUG", " ECL cookie value ========> " + eclCookie );
228 if ( EclReadAndPlay.displayMissingChanges == true ) {
229 if ( EclReadAndPlay.eclMode.equals("draft") ) {
235 EclReadAndPlay.lastChangeNumber = Integer.parseInt(attr.getStringValueArray()[0]);
237 } else if ( EclReadAndPlay.eclMode.equals("opends") ) {
243 EclReadAndPlay.lastExternalChangelogCookie = attr.getStringValueArray()[0];
248 } /* while (idleTime <= EclReadAndPlay.MAX_IDLE_TIME) */
250 EclReadAndPlay.println("WARNING", "No new changes read in the ECL for " + Integer.toString(idleTime) +
261 EclReadAndPlay.println( "WARNING", "Connection lost to " + master.host + ":" + master.port + ".");
264 EclReadAndPlay.println( "ERROR" , e.toString() );