import org.jgroups.*;
import org.jgroups.util.Util;</BUG>
import java.util.LinkedList;
import java.util.List;
<BUG>import java.util.concurrent.CyclicBarrier;
public class ConcurrentStartFlushTest extends TestCase {

private JChannel c1, c2, c3;
private Receiver r1, r2, r3;
private static final long TIMEOUT=10000L;</BUG>
protected void setUp() throws Exception {

package org.jgroups.tests;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.CyclicBarrier;
import org.jgroups.BlockEvent;
import org.jgroups.Channel;
import org.jgroups.ExtendedReceiverAdapter;
import org.jgroups.UnblockEvent;
import org.jgroups.View;
import org.jgroups.util.Util;
public class ConcurrentStartFlushTest extends ChannelTestBase {
private Receiver r1, r2, r3;
Channel c1,c2,c3;
private static final long TIMEOUT=10000L;
