[GitHub] [geode] boglesby commented on pull request #7422: GEODE-10105: when stopping gw sender, for pending events set possible…

[GitBox]

boglesby commented on pull request #7422:
URL: https://github.com/apache/geode/pull/7422#issuecomment-1072685643


   In the current product, when a remote receiver is stopped, any events that 
have not been acked are not set possibleDuplicate.
   
   In this case, the events in batch 7 are not set possibleDuplicate:
   ```
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.processQueue about to dispatch batchId=7
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.processQueue done dispatch batchId=7; 
success=true
   AckReaderThread for : Event Processor for GatewaySender_ny_4: 
AckReaderThread.run null ack
   AckReaderThread for : Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.handleException resetLastPeekedEvents=true
   
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.processQueue about to dispatch batchId=8
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.resetBatchId about to reset batchId=8
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.processQueue done dispatch batchId=8; 
success=false
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.handleUnSuccessfulBatchDispatch about to 
setPossibleDuplicate eventsSize=100
   Event Processor for GatewaySender_ny_4: 
GatewaySenderEventImpl.setPossibleDuplicate queueKey=5684; 
possibleDuplicate=true; this.possibleDuplicate=false
   Event Processor for GatewaySender_ny_4: 
GatewaySenderEventImpl.setPossibleDuplicate queueKey=11015; 
possibleDuplicate=true; this.possibleDuplicate=false
   ...
   Event Processor for GatewaySender_ny_4: 
GatewaySenderEventImpl.setPossibleDuplicate queueKey=6927; 
possibleDuplicate=true; this.possibleDuplicate=false
   Event Processor for GatewaySender_ny_4: 
GatewaySenderEventImpl.setPossibleDuplicate queueKey=13162; 
possibleDuplicate=true; this.possibleDuplicate=false
   Event Processor for GatewaySender_ny_4: 
AbstractGatewaySenderEventProcessor.handleUnSuccessfulBatchDispatch done 
setPossibleDuplicate eventsSize=100
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscr...@geode.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org