static void rcvDeleteSet ( CommsServerByteBuffer request , Conversation conversation , int requestNumber , boolean allocatedFromBufferPool , boolean partOfExchange ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "rcvDeleteSet" , new Object [ ] { request , conversation , "" + requestNumber } ) ; ServerLinkLevelState linkState = ( ServerLinkLevelState ) conversation . getLinkLevelAttachment ( ) ; final boolean optimizedTx = CommsUtils . requiresOptimizedTransaction ( conversation ) ; short connectionObjectId = request . getShort ( ) ; // BIT16 ConnectionObjectId short consumerObjectId = request . getShort ( ) ; // BIT16 ConsumerSessionId int transactionId = request . getSITransactionId ( connectionObjectId , linkState , optimizedTx ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) { SibTr . debug ( tc , "connectionObjectId" , connectionObjectId ) ; SibTr . debug ( tc , "consumerObjectId" , consumerObjectId ) ; SibTr . debug ( tc , "transactionId" , transactionId ) ; } SIMessageHandle [ ] siMsgHandles = request . getSIMessageHandles ( ) ; CATMainConsumer mainConsumer = ( CATMainConsumer ) ( ( ConversationState ) conversation . getAttachment ( ) ) . getObject ( consumerObjectId ) ; // If the transaction id is not null then retrieve the // transaction object from the table in the link level mainConsumer . deleteSet ( requestNumber , siMsgHandles , transactionId , partOfExchange ) ; // f187521.2.1, F219476.2 request . release ( allocatedFromBufferPool ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "rcvDeleteSet" ) ; }
Deletes a set of messages that are currently locked by the server .