Lines Matching refs:change
58 // Read change from the queue
59 Change change = q.take();
60 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() );
62 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier);
65 if ( change.csn == null )
68 if (change.csn.compareTo(RUVcsn) < 0) {
70 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn "
71 + change.csn + " has already been replayed");
77 // Write change on stand-alone server
78 applicationConnection.apply(change);
80 // Write change CSN to file under "db" directory
82 if (EclReadAndPlay.files.containsKey(change.replicaIdentifier)) {
83 f = EclReadAndPlay.files.get(change.replicaIdentifier);
84 // f.renameTo(new File(EclReadAndPlay.dbPath, new String(change.replicaIdentifier+".tmp") ));
86 f = new File(EclReadAndPlay.dbPath, change.replicaIdentifier + ".csn");
87 EclReadAndPlay.files.put(change.replicaIdentifier,f);
91 out.write(change.csn.value);
95 EclReadAndPlay.RUV.put(change.replicaIdentifier,change.csn);
98 EclReadAndPlay.inc_ops(change.changeNumber);
100 EclReadAndPlay.inc_ops(change.changelogCookie);
102 // Log a message for the written change on "logs/access" file
104 + "- INFO: " + change.type + " \""
105 + change.dn + "\" (" + change.csn +" / "
106 + change.changeNumber + ")" );