[jira] [Issue Comment Deleted] (IGNITE-3727) Support local listeners async execution for IgniteMessage.send

["Dmitriy Govorukhin (JIRA)" <ji...@apache.org>]

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

Dmitriy Govorukhin updated IGNITE-3727:
---------------------------------------
    Comment: was deleted

(was: There are case, when starting exchange between nodes, and stop kernel exchange manager,
you may get assert exception, if exchange was not complete and kernal stop cleanup reference. 

GridDhtPartitionsExchangeFuture

1047 onDone(...){
......

1089 cctx.exchange().onExchangeDone(this, err); (cleanUp this)>>>>
......
}

>>>>>>>
for (GridDhtPartitionsExchangeFuture fut : cctx.exchange().exchangeFutures()) {
if (exchId.topologyVersion().compareTo(fut.exchangeId().topologyVersion()) < 0)
continue;

skipped++;

if (skipped > 10)
fut.cleanUp();
<<<<<<<<<

after that can happend asyc action, witch fail because on previous line was cleanup

I think that we can move cleanUp code to end of onDone(...).
)

> Support local listeners async execution for IgniteMessage.send
> --------------------------------------------------------------
>
>                 Key: IGNITE-3727
>                 URL: https://issues.apache.org/jira/browse/IGNITE-3727
>             Project: Ignite
>          Issue Type: Task
>          Components: messaging
>    Affects Versions: 1.7
>         Environment: windows 7
>            Reporter: Yujue Li
>            Assignee: Dmitriy Govorukhin
>             Fix For: 1.8
>
>
> ignite.message() method not support async mode,withAsync() is invalid.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)