< prev index next >
src/com/sun/javatest/TestResultCache.java
Print this page
rev 145 : 7902237: Fixing raw use of parameterized class
Reviewed-by: jjg
*** 674,684 ****
// merge any tests in testsToWrite
// testsToWrite is a thread-safe fifo, so it is safe to keep reading
// it till its empty, even though some tests may even have been added
// after the worker woke up
TestResult tr;
! while ((tr = (TestResult) (testsToWrite.remove())) != null) {
// check if test is in the set we've just read
String name = tr.getTestName();
TestResult tr2 = tests.get(name);
// if the cache file contains a conflicting entry,
// reload the test from the .jtr file; otherwise, add it to the cache
--- 674,684 ----
// merge any tests in testsToWrite
// testsToWrite is a thread-safe fifo, so it is safe to keep reading
// it till its empty, even though some tests may even have been added
// after the worker woke up
TestResult tr;
! while ((tr = testsToWrite.remove()) != null) {
// check if test is in the set we've just read
String name = tr.getTestName();
TestResult tr2 = tests.get(name);
// if the cache file contains a conflicting entry,
// reload the test from the .jtr file; otherwise, add it to the cache
*** 692,703 ****
raf.seek(0);
long now = System.currentTimeMillis();
lastSerial = (int) ((now >> 16) + (now & 0xffff));
raf.writeInt(lastSerial);
! for (Iterator iter = tests.values().iterator(); iter.hasNext(); ) {
! tr = (TestResult) (iter.next());
writeCacheEntry(tr);
}
if (DEBUG_WORK)
Debug.println("TRC.writeCache write all (" + tests.size() + " tests)");
--- 692,703 ----
raf.seek(0);
long now = System.currentTimeMillis();
lastSerial = (int) ((now >> 16) + (now & 0xffff));
raf.writeInt(lastSerial);
! for (Iterator<TestResult> iter = tests.values().iterator(); iter.hasNext(); ) {
! tr = iter.next();
writeCacheEntry(tr);
}
if (DEBUG_WORK)
Debug.println("TRC.writeCache write all (" + tests.size() + " tests)");
*** 712,722 ****
// it till its empty, even though some tests may even have been added
// after the worker woke up
int debugCount = 0;
raf.seek(lastFileSize);
TestResult tr;
! while ((tr = (TestResult) (testsToWrite.remove())) != null) {
if (tests != null) {
// check if test is in the set we've just read
String name = tr.getTestName();
TestResult tr2 = tests.get(name);
if (tr2 != null) {
--- 712,722 ----
// it till its empty, even though some tests may even have been added
// after the worker woke up
int debugCount = 0;
raf.seek(lastFileSize);
TestResult tr;
! while ((tr = testsToWrite.remove()) != null) {
if (tests != null) {
// check if test is in the set we've just read
String name = tr.getTestName();
TestResult tr2 = tests.get(name);
if (tr2 != null) {
*** 881,891 ****
private boolean fullUpdateRequested;
private boolean compressNeeded;
private boolean compressRequested;
private boolean flushRequested;
private boolean shutdownRequested;
! private Fifo testsToWrite = new Fifo();
private static final String V1_FILENAME = "ResultCache.jtw";
private static final String V1_LOCKNAME = V1_FILENAME + ".lck";
private static final String V2_FILENAME = "ResultCache2.jtw";
private static final String V2_LOCKNAME = V2_FILENAME + ".lck";
--- 881,891 ----
private boolean fullUpdateRequested;
private boolean compressNeeded;
private boolean compressRequested;
private boolean flushRequested;
private boolean shutdownRequested;
! private Fifo<TestResult> testsToWrite = new Fifo<>();
private static final String V1_FILENAME = "ResultCache.jtw";
private static final String V1_LOCKNAME = V1_FILENAME + ".lck";
private static final String V2_FILENAME = "ResultCache2.jtw";
private static final String V2_LOCKNAME = V2_FILENAME + ".lck";
< prev index next >