static void rcvUnlockAll ( CommsByteBuffer request , Conversation conversation , int requestNumber , boolean allocatedFromBufferPool , boolean partOfExchange ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "rcvUnlockAll" , new Object [ ] { request , conversation , "" + requestNumber , "" + allocatedFromBufferPool } ) ; short connectionObjectId = request . getShort ( ) ; // BIT16 ConnectionObjectId short consumerObjectId = request . getShort ( ) ; // BIT16 ConsumerSessionId if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( tc , "connectionObjectId" , connectionObjectId ) ; SibTr . debug ( tc , "consumerObjectId" , consumerObjectId ) ; } CATMainConsumer mainConsumer = ( CATMainConsumer ) ( ( ConversationState ) conversation . getAttachment ( ) ) . getObject ( consumerObjectId ) ; mainConsumer . unlockAll ( requestNumber ) ; request . release ( allocatedFromBufferPool ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "rcvUnlockAll" ) ; }
Unlocks all locked messages on the server .