@@ -146,6 +146,28 @@ public void testLogIsDurableAcrossReopenSerial() throws Exception {
146146 assertEquals (3L , count .totalValue .get ());
147147 }
148148
149+ @ Test
150+ public void testSeparateReadersAndLogsInSharedManager () throws Exception {
151+ final int n = 5 ;
152+ Log [] logs = new Log [n ];
153+ CountingReader [] counts = new CountingReader [n ];
154+ for (int i = 0 ; i < n ; i ++) {
155+ counts [i ] = new CountingReader (1 , true );
156+ logs [i ] = manager .openLog ("loner" + i );
157+ }
158+ for (int i = 0 ; i < n ; i ++) {
159+ logs [i ].registerReader (ReadMarker .fromNow (),counts [i ]);
160+ logs [i ].add (BufferUtil .getLongBuffer (1L << (i + 1 )));
161+ }
162+ // Check message receipt.
163+ for (int i = 0 ; i < n ; i ++) {
164+ log .debug ("Awaiting CountingReader[{}]" , i );
165+ counts [i ].await (TIMEOUT_MS );
166+ assertEquals (1L << (i + 1 ), counts [i ].totalValue .get ());
167+ assertEquals (1 , counts [i ].totalMsg .get ());
168+ }
169+ }
170+
149171 @ Test
150172 @ Tag (LogTest .requiresOrderPreserving )
151173 public void testMultipleLogsWithSingleReaderSerial () throws Exception {
@@ -174,28 +196,6 @@ public void testMultipleLogsWithSingleReaderSerial() throws Exception {
174196 assertEquals (value - 1 , count .totalValue .get ());
175197 }
176198
177- @ Test
178- public void testSeparateReadersAndLogsInSharedManager () throws Exception {
179- final int n = 5 ;
180- Log [] logs = new Log [n ];
181- CountingReader [] counts = new CountingReader [n ];
182- for (int i = 0 ; i < n ; i ++) {
183- counts [i ] = new CountingReader (1 , true );
184- logs [i ] = manager .openLog ("loner" + i );
185- }
186- for (int i = 0 ; i < n ; i ++) {
187- logs [i ].registerReader (ReadMarker .fromNow (),counts [i ]);
188- logs [i ].add (BufferUtil .getLongBuffer (1L << (i + 1 )));
189- }
190- // Check message receipt.
191- for (int i = 0 ; i < n ; i ++) {
192- log .debug ("Awaiting CountingReader[{}]" , i );
193- counts [i ].await (TIMEOUT_MS );
194- assertEquals (1L << (i + 1 ), counts [i ].totalValue .get ());
195- assertEquals (1 , counts [i ].totalMsg .get ());
196- }
197- }
198-
199199 @ Test
200200 @ Tag (LogTest .requiresOrderPreserving )
201201 public void testFuzzMessagesSerial () throws Exception {
0 commit comments