| 98 | ColSize = colSize; |
| 99 | } |
| 100 | void Transfer(int iter, int srcRank, int dstRank, int sl, int rangeBeg, int rangeFin) { |
| 101 | while (iter >= Iterations.ysize()) { |
| 102 | TMergeIteration& res = Iterations.emplace_back(); |
| 103 | res.Init(ColSize); |
| 104 | } |
| 105 | int id = RankReceiveCount[dstRank]++; |
| 106 | MaxRankReceiveCount = Max(MaxRankReceiveCount, id + 1); |
| 107 | Y_ASSERT(id < 64); |
| 108 | Iterations[iter].Transfer(srcRank, dstRank, sl, rangeBeg, rangeFin, id); |
| 109 | } |
| 110 | }; |
| 111 | |
| 112 | struct TSRTransfer { |
no test coverage detected