@ Override public void onSuccess ( Channel channel , final RiakMessage response ) { logger . debug ( "Operation onSuccess() channel: id:{} {}:{}" , channel . hashCode ( ) , remoteAddress , port ) ; consecutiveFailedOperations . set ( 0 ) ; final FutureOperation inProgress = inProgressMap . get ( channel ) ; // Especially with a streaming op, the close listener may trigger causing // a race. This check guards that. if ( inProgress != null ) { inProgress . setResponse ( response ) ; if ( inProgress . isDone ( ) ) { try { inProgressMap . remove ( channel ) ; returnConnection ( channel ) ; // return permit } finally { inProgress . setComplete ( ) ; } } } }
End ConnectionPool stuff