42
42
import com .google .common .base .Preconditions ;
43
43
44
44
/**
45
- *
46
- * @author Alexander Patrikalakis
47
- *
45
+ *
46
+ * @author Alexander Patrikalakis
47
+ * @author Johan Jacobs
48
+ *
48
49
*/
49
50
@ Category ({ MultiIdAuthorityLogStoreCategory .class , MultipleItemTestCategory .class })
50
51
public class MultiDynamoDBLogTest extends AbstractDynamoDBLogTest {
@@ -62,6 +63,14 @@ public MultiDynamoDBLogTest() throws Exception {
62
63
* testMultipleReadersOnSingleLog
63
64
* testMultipleReadersOnSingleLogSerial
64
65
*
66
+ * https://github.com/awslabs/dynamodb-titan-storage-backend/issues/115
67
+ * Related to issue 160 above, increasing the delay time for each of the following tests
68
+ * allows the tests to pass. Investigation is needed to understand what the effect of increasing the delay
69
+ * has to allow the tests to pass:
70
+ * mediumSendReceiveSerial
71
+ * testMultipleReadersOnSingleLog
72
+ * testMultipleReadersOnSingleLogSerial
73
+ *
65
74
* BEGIN code copied from:
66
75
* https://github.com/JanusGraph/janusgraph/blob/v0.1.0/janusgraph-test/src/main/java/org/janusgraph/diskstorage/log/LogTest.java#L50
67
76
*/
@@ -70,23 +79,17 @@ public MultiDynamoDBLogTest() throws Exception {
70
79
@ Override
71
80
@ Test
72
81
public void mediumSendReceiveSerial () throws Exception {
73
- //TODO investigate
74
- // https://github.com/awslabs/dynamodb-titan-storage-backend/issues/115
75
- // simpleSendReceiveMine(2000,1, LONGER_TIMEOUT_MS);
82
+ simpleSendReceiveMine (2000 ,50 , LONGER_TIMEOUT_MS );
76
83
}
77
84
@ Override
78
85
@ Test
79
86
public void testMultipleReadersOnSingleLog () throws Exception {
80
- //TODO investigate
81
- // https://github.com/awslabs/dynamodb-titan-storage-backend/issues/115
82
- // sendReceiveMine(4, 2000, 5, false, LONGER_TIMEOUT_MS);
87
+ sendReceiveMine (4 , 2000 , 50 , false , LONGER_TIMEOUT_MS );
83
88
}
84
89
@ Override
85
90
@ Test
86
91
public void testMultipleReadersOnSingleLogSerial () throws Exception {
87
- //TODO investigate
88
- // https://github.com/awslabs/dynamodb-titan-storage-backend/issues/115
89
- // sendReceiveMine(4, 2000, 5, true, LONGER_TIMEOUT_MS);
92
+ sendReceiveMine (4 , 2000 , 50 , true , LONGER_TIMEOUT_MS );
90
93
}
91
94
private void simpleSendReceiveMine (int numMessages , int delayMS , long timeoutMS ) throws Exception {
92
95
sendReceiveMine (1 , numMessages , delayMS , true , timeoutMS );
0 commit comments