| 70 | TVector<TMergeRecord> Ops; |
| 71 | |
| 72 | void Init(int colSize) { |
| 73 | Ops.resize(colSize); |
| 74 | } |
| 75 | void Transfer(int srcRank, int dstRank, int sl, int rangeBeg, int rangeFin, int id) { |
| 76 | Y_ABORT_UNLESS(id < 64, "recv mask overflow"); |
| 77 | Ops[srcRank].OutList.push_back(TMergeRecord::TTransfer(dstRank, sl, rangeBeg, rangeFin, id)); |