Thank you for clarification. All Single Message will have same exchange ID because single messages are issued in one round of ExchangeFuture (one complete round of exchange is to be finished before next will start).
Exchange ID on non coordinator nodes is filled in single messages (GridDhtPartitionsSingleMessage) from GridDhtPartitionsExchangeFuture#exchangeId field. Value of exchange ID is the same in all nodes and content of exchange future is determined by original event caused this exchange (e.g. node left, node joined, node failed) for current topology version. чт, 4 мая 2017 г. в 11:32, ALEKSEY KUZNETSOV <alkuznetsov...@gmail.com>: > I know this. > But the question was as follows. > Imagine, remaining set contains 2 nodes. It implies that both nodes had > sent two GridDhtPartitionsSingleMessage with the same exchangeId. > So, how could it possible 2 messages from different nodes has got equal > exchangeId. > > ср, 3 мая 2017 г. в 19:23, Dmitry Pavlov <dpavlov....@gmail.com>: > > > Hi, Aleksey, > > > > empty remaining set > > > > > (org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture#remaining) > > is the mandatory condition of sendAllPartitions() to be activated. > > > > When coordinator receives single partition message ( > > GridDhtPartitionsSingleMessage), it removes one node from remaining set. > > The same is true for node left message. > > > > Best Regards, > > Dmitry Pavlov > > > > ср, 3 мая 2017 г. в 19:10, ALEKSEY KUZNETSOV <alkuznetsov...@gmail.com>: > > > > > Hi, Igntrs! When processing single partitions message in > > > GridDhtPartitionsExchangeFuture#processMessage() then , coordinator > could > > > answer with GridDhtPartitionsFullMessage > > > from sendAllPartitions. > > > But the field GridDhtPartitionsExchangeFuture#remaining must be empty > in > > > this case. > > > > > > I wounder, how could it be empty in case if "remaining" held 2 nodes, > or > > > more ? > > > > > > > > > -- > > > > > > *Best Regards,* > > > > > > *Kuznetsov Aleksey* > > > > > > -- > > *Best Regards,* > > *Kuznetsov Aleksey* >
