subprojects/s4-comm/src/test/java/org/apache/s4/comm/tcp/NetworkGlitchTest.java

package org.apache.s4.comm.tcp;

import org.apache.s4.comm.util.PartitionInfo;
import org.junit.Assert;
import org.slf4j.LoggerFactory;

public class NetworkGlitchTest extends TCPBasedTest {
    public NetworkGlitchTest() {
        super(2);
        logger = LoggerFactory.getLogger(NetworkGlitchTest.class);
    }

    @Override
    public void testDelivery() throws InterruptedException {
        PartitionInfo util = partitions[0];

        startThreads();

        for (int i = 0; i < 4; i++) {
            Thread.sleep(500);
            logger.debug("Messages sent so far - {}", util.sendThread.sendCounts);
            ((TCPEmitter) util.emitter).removeChannel(0);
            logger.debug("Channel closed");
        }

        waitForThreads();

        Assert.assertTrue("Message delivery", messageDelivery());

        logger.info("Message ordering - " + messageOrdering());
        Assert.assertTrue("Pairwise message ordering", messageOrdering());
    }
}