[ 
https://issues.apache.org/jira/browse/GEODE-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

nabarun resolved GEODE-1926.
----------------------------
       Resolution: Fixed
    Fix Version/s: 1.2.0

> The function peekAhead function puts the queue key into peekedIDs even though 
> it was not in the batch to be dispatched 
> -----------------------------------------------------------------------------------------------------------------------
>
>                 Key: GEODE-1926
>                 URL: https://issues.apache.org/jira/browse/GEODE-1926
>             Project: Geode
>          Issue Type: Bug
>          Components: wan
>            Reporter: nabarun
>            Assignee: nabarun
>             Fix For: 1.2.0
>
>
> The function peekAhead peeks the serial sender queue and if its able to get 
> an object in the queue, returns the object to the peek function to be 
> dispatched and adds the key to the peekedIds list.
> The peek function tries to make a heap copy of the object returned , but 
> conflation may have kicked in the object may have been removed -  hence the 
> object will not be placed in the dispatch batch.
> However now the size of the peeked Ids and dispatched batch do not match, 
> hence when the remove thread starts removing the elements from the key using 
> the keys in peekedIds and using the size of the dispatched batch, there will 
> be lingering objects in the queue because the size of dispatched batch is 
> less than Ids that were peeked.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to