public final void streamIsFlushed ( AOStream stream ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "streamIsFlushed" , stream ) ; // we schedule an asynchronous removal of the persistent data synchronized ( streamTable ) { String key = SIMPUtils . getRemoteGetKey ( stream . getRemoteMEUuid ( ) , stream . getGatheringTargetDestUuid ( ) ) ; StreamInfo sinfo = streamTable . get ( key ) ; if ( ( sinfo != null ) && sinfo . streamId . equals ( stream . streamId ) ) { RemovePersistentStream update = null ; synchronized ( sinfo ) { // synchronized since reading sinfo.item update = new RemovePersistentStream ( key , sinfo . streamId , sinfo . itemStream , sinfo . item ) ; } doEnqueueWork ( update ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "streamIsFlushed" ) ; }
Callback from a stream that it has been flushed