(iterNum int, t RowNumber, d int)
| 1082 | } |
| 1083 | |
| 1084 | func (j *JoinIterator) seek(iterNum int, t RowNumber, d int) error { |
| 1085 | var err error |
| 1086 | t = TruncateRowNumber(d, t) |
| 1087 | if j.peeks[iterNum] == nil || CompareRowNumbers(d, j.peeks[iterNum].RowNumber, t) == -1 { |
| 1088 | |
| 1089 | // Release peek if present |
| 1090 | // These results have been collected but never returned upstream, |
| 1091 | // so we know it is safe to release them. |
| 1092 | if j.peeks[iterNum] != nil { |
| 1093 | j.peeks[iterNum].Release() |
| 1094 | } |
| 1095 | |
| 1096 | j.peeks[iterNum], err = j.iters[iterNum].SeekTo(t, d) |
| 1097 | if err != nil { |
| 1098 | return err |
| 1099 | } |
| 1100 | } |
| 1101 | return nil |
| 1102 | } |
| 1103 | |
| 1104 | func (j *JoinIterator) seekAll(t RowNumber, d int) error { |
| 1105 | var err error |
no test coverage detected