Permalink
Browse files

Fix two failing tests

  • Loading branch information...
1 parent e48828a commit 9baff1fcbb02fd5cca157a806eccd1bc5a3e35e0 @dgomezferro committed May 3, 2012
View
5 src/test/java/com/yahoo/omid/tso/TestBasicTransaction.java
@@ -25,6 +25,7 @@
import org.junit.Test;
import com.yahoo.omid.tso.messages.AbortedTransactionReport;
+import com.yahoo.omid.tso.messages.CleanedTransactionReport;
import com.yahoo.omid.tso.messages.CommitRequest;
import com.yahoo.omid.tso.messages.CommitResponse;
import com.yahoo.omid.tso.messages.CommittedTransactionReport;
@@ -69,8 +70,8 @@ public void testConflicts() throws IOException, InterruptedException {
AbortedTransactionReport atr = clientHandler.receiveMessage(AbortedTransactionReport.class);
assertEquals(cr2.startTimestamp, atr.startTimestamp);
// Full Abort report
- FullAbortRequest far = clientHandler.receiveMessage(FullAbortRequest.class);
- assertEquals(cr2.startTimestamp, far.startTimestamp);
+ CleanedTransactionReport cltr = clientHandler.receiveMessage(CleanedTransactionReport.class);
+ assertEquals(cr2.startTimestamp, cltr.startTimestamp);
TimestampResponse tr3 = clientHandler.receiveMessage(TimestampResponse.class);
View
13 src/test/java/com/yahoo/omid/tso/TestCommitAbortedReport.java
@@ -24,6 +24,7 @@
import com.yahoo.omid.tso.RowKey;
import com.yahoo.omid.tso.messages.AbortedTransactionReport;
+import com.yahoo.omid.tso.messages.CleanedTransactionReport;
import com.yahoo.omid.tso.messages.CommitQueryRequest;
import com.yahoo.omid.tso.messages.CommitRequest;
import com.yahoo.omid.tso.messages.CommitResponse;
@@ -91,18 +92,18 @@ public void testCommitAbortedReport() throws Exception {
secondClientHandler.receiveMessage();
//
- // Full Aborted Transaction Report
+ // Cleaned Transaction Report
//
clientHandler.sendMessage(new TimestampRequest());
- FullAbortRequest far1 = clientHandler.receiveMessage(FullAbortRequest.class);
- assertEquals(tr2.timestamp, far1.startTimestamp);
+ CleanedTransactionReport cltr1 = clientHandler.receiveMessage(CleanedTransactionReport.class);
+ assertEquals(tr2.timestamp, cltr1.startTimestamp);
//
- // Full Aborted Transaction Report
+ // Cleaned Transaction Report
//
secondClientHandler.sendMessage(new TimestampRequest());
- FullAbortRequest far2 = secondClientHandler.receiveMessage(FullAbortRequest.class);
- assertEquals(tr2.timestamp, far2.startTimestamp);
+ CleanedTransactionReport cltr2 = secondClientHandler.receiveMessage(CleanedTransactionReport.class);
+ assertEquals(tr2.timestamp, cltr2.startTimestamp);
}
}

0 comments on commit 9baff1f

Please sign in to comment.