private volatile int _writeCount = 1;
@Before
public void startManager() throws Exception
{
_writeCount = 1;
<BUG>_lastEndp = null;

_connector = ServerSocketChannel.open();</BUG>
_connector.socket().bind(null);
_threadPool.start();

private volatile int _writeCount = 1;
@Before
public void startManager() throws Exception
{
_writeCount = 1;
_lastEndPoint = null;
_lastEndPointLatch = new CountDownLatch(1);
_connector = ServerSocketChannel.open();
_connector.socket().bind(null);
_threadPool.start();
