[ 
https://issues.apache.org/jira/browse/GEODE-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15555984#comment-15555984
 ] 

ASF subversion and git services commented on GEODE-1926:
--------------------------------------------------------

Commit fbbdb824b824bd169aaff7a6898b104e25e7069b in incubator-geode's branch 
refs/heads/develop from [~nnag]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-geode.git;h=fbbdb82 ]

Revert "GEODE-1926"

        * Precehckin completion pending
This reverts commit 7b88c6cf7ad96675f81a138b2d03f8f3375168cf.


> 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
>
> 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.4#6332)

Reply via email to