Changeset 843:0b1d8563dbe3
- Timestamp:
- 02/03/12 20:09:57 (4 months ago)
- Branch:
- default
- Location:
- kraken-confdb
- Files:
-
- 7 added
- 4 edited
-
pom.xml (modified) (1 diff)
-
src/main/java/org/krakenapps/confdb/file/FileConfigCollection.java (modified) (1 diff)
-
src/main/java/org/krakenapps/confdb/file/FileManifest.java (modified) (1 diff)
-
src/test/java/org/krakenapps/confdb/file/DatabaseTest.java (modified) (1 diff)
-
src/test/resources/rollback-bug/changeset.dat (added)
-
src/test/resources/rollback-bug/changeset.log (added)
-
src/test/resources/rollback-bug/col.id (added)
-
src/test/resources/rollback-bug/col2.dat (added)
-
src/test/resources/rollback-bug/col2.log (added)
-
src/test/resources/rollback-bug/manifest.dat (added)
-
src/test/resources/rollback-bug/manifest.log (added)
Legend:
- Unmodified
- Added
- Removed
-
kraken-confdb/pom.xml
r821 r840 10 10 </parent> 11 11 <artifactId>kraken-confdb</artifactId> 12 <version>0.7. 0</version>12 <version>0.7.1</version> 13 13 <packaging>bundle</packaging> 14 14 <name>Kraken Config Database</name> -
kraken-confdb/src/main/java/org/krakenapps/confdb/file/FileConfigCollection.java
r828 r843 139 139 for (long index = 0; index < count; index++) { 140 140 RevLog log = reader.read(index); 141 if (manifest.containsDoc(col.getName(), log.getDocId(), log.getRev())) 141 // assume that rev is unique 142 if ((log.getOperation() == CommitOp.CreateDoc || log.getOperation() == CommitOp.UpdateDoc) 143 && manifest.containsDoc(col.getName(), log.getDocId(), log.getRev())) 142 144 snapshot.add(log); 143 145 } -
kraken-confdb/src/main/java/org/krakenapps/confdb/file/FileManifest.java
r830 r843 232 232 return true; 233 233 } 234 235 @Override 236 public String toString() { 237 return "col=" + colId + ", doc=" + docId; 238 } 234 239 } 235 240 } -
kraken-confdb/src/test/java/org/krakenapps/confdb/file/DatabaseTest.java
r821 r843 250 250 251 251 @Test 252 public void testThreadLock() { 253 // coming soon 252 public void testRollbackBug() throws IOException { 253 FileConfigDatabase db = new FileConfigDatabase(new File("src/test/resources"), "rollback-bug"); 254 ConfigCollection col = db.ensureCollection("table"); 255 ConfigIterator it = col.findAll(); 256 while (it.hasNext()) 257 it.next(); 254 258 } 255 259 }
Note: See TracChangeset
for help on using the changeset viewer.
