Lines Matching refs:change
59 // Read change from the queue
60 Change change = q.take();
61 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() );
63 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier);
66 if ( change.csn == null )
69 if (change.csn.compareTo(RUVcsn) < 0) {
71 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn "
72 + change.csn + " has already been replayed");
78 // Write change on stand-alone server
79 applicationConnection.apply(change);
81 // Write change CSN to file under "db" directory
83 if (EclReadAndPlay.files.containsKey(change.replicaIdentifier)) {
84 f = EclReadAndPlay.files.get(change.replicaIdentifier);
85 // f.renameTo(new File(EclReadAndPlay.dbPath, new String(change.replicaIdentifier+".tmp") ));
87 f = new File(EclReadAndPlay.dbPath, change.replicaIdentifier + ".csn");
88 EclReadAndPlay.files.put(change.replicaIdentifier,f);
92 out.write(change.csn.value);
96 EclReadAndPlay.RUV.put(change.replicaIdentifier,change.csn);
99 EclReadAndPlay.inc_ops(change.changeNumber);
101 EclReadAndPlay.inc_ops(change.changelogCookie);
103 // Log a message for the written change on "logs/access" file
105 + "- INFO: " + change.type + " \""
106 + change.dn + "\" (" + change.csn +" / "
107 + change.changeNumber + ")" );