424498 made bytebufferendpoint threadsafe

This commit is contained in:
Greg Wilkins 2013-12-20 12:49:57 +11:00
parent ab9040bb63
commit b91d1745ad
2 changed files with 23 additions and 6 deletions

View File

@ -40,12 +40,12 @@ public class ByteArrayEndPoint extends AbstractEndPoint
static final Logger LOG = Log.getLogger(ByteArrayEndPoint.class);
public final static InetSocketAddress NOIP=new InetSocketAddress(0);
protected ByteBuffer _in;
protected ByteBuffer _out;
protected boolean _ishut;
protected boolean _oshut;
protected boolean _closed;
protected boolean _growOutput;
protected volatile ByteBuffer _in;
protected volatile ByteBuffer _out;
protected volatile boolean _ishut;
protected volatile boolean _oshut;
protected volatile boolean _closed;
protected volatile boolean _growOutput;
/* ------------------------------------------------------------ */

View File

@ -43,6 +43,8 @@ import org.hamcrest.Matchers;
import org.junit.Assert;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.TestWatcher;
import org.junit.runner.Description;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
import org.junit.runners.Parameterized.Parameters;
@ -55,6 +57,21 @@ import org.junit.runners.Parameterized.Parameters;
@RunWith(Parameterized.class)
public class GzipFilterContentLengthTest
{
@Rule
public final TestWatcher testName = new TestWatcher()
{
@Override
public void starting(Description description)
{
super.starting(description);
System.err.printf("Running %s.%s()%n",
description.getClassName(),
description.getMethodName());
}
};
/**
* These are the junit parameters for running this test.
* <p>