public void hiccup ( ) { // If termination is already under way do nothing. if ( state != State . ACTIVE ) { return ; } // We'll drop the pointer to the inpipe. From now on, the peer is // responsible for deallocating it. inpipe = null ; // Create new inpipe. if ( conflate ) { inpipe = new YPipeConflate <> ( ) ; } else { inpipe = new YPipe <> ( Config . MESSAGE_PIPE_GRANULARITY . getValue ( ) ) ; } inActive = true ; // Notify the peer about the hiccup. sendHiccup ( peer , inpipe ) ; }
in the peer .