184185186187188189190191192193194
FutureCallback shutdown = _shutdown.get(); if (shutdown!=null) { httpResponse.flushBuffer(); if (d==0) shutdown.succeeded(); } } // else onCompletion will handle it. } }
563564565566567568569570571
{ FutureCallback shutdown=new FutureCallback(false); _shutdown.compareAndSet(null,shutdown); shutdown=_shutdown.get(); if (_dispatchedStats.getCurrent()==0) shutdown.succeeded(); return shutdown; } }