| 336 | TAtomic DistributionIsComplete; |
| 337 | |
| 338 | struct TTransferInfo { |
| 339 | int EnvId, HostId; |
| 340 | int Part; |
| 341 | int SenderComp, DstComp; |
| 342 | int Version; |
| 343 | |
| 344 | TTransferInfo() { |
| 345 | Zero(*this); |
| 346 | } |
| 347 | TTransferInfo(int envId, int hostId, int part, int senderComp, int dstComp, int version) |
| 348 | : EnvId(envId) |
| 349 | , HostId(hostId) |
| 350 | , Part(part) |
| 351 | , SenderComp(senderComp) |
| 352 | , DstComp(dstComp) |
| 353 | , Version(version) |
| 354 | { |
| 355 | } |
| 356 | }; |
| 357 | int QueryId; |
| 358 | THashMap<int, TTransferInfo> TransferInfos; |
| 359 | TAtomic ActiveReqCount; |