Lines Matching refs:readptr
421 TSReadPointer *readptr; in tuplestore_clear() local
439 readptr = state->readptrs; in tuplestore_clear()
440 for (i = 0; i < state->readptrcount; readptr++, i++) in tuplestore_clear()
442 readptr->eof_reached = false; in tuplestore_clear()
443 readptr->current = 0; in tuplestore_clear()
475 TSReadPointer *readptr; in tuplestore_select_read_pointer() local
484 readptr = &state->readptrs[ptr]; in tuplestore_select_read_pointer()
510 if (readptr->eof_reached) in tuplestore_select_read_pointer()
523 readptr->file, in tuplestore_select_read_pointer()
524 readptr->offset, in tuplestore_select_read_pointer()
767 TSReadPointer *readptr; in tuplestore_puttuple_common() local
780 readptr = state->readptrs; in tuplestore_puttuple_common()
781 for (i = 0; i < state->readptrcount; readptr++, i++) in tuplestore_puttuple_common()
783 if (readptr->eof_reached && i != state->activeptr) in tuplestore_puttuple_common()
785 readptr->eof_reached = false; in tuplestore_puttuple_common()
786 readptr->current = state->memtupcount; in tuplestore_puttuple_common()
841 readptr = state->readptrs; in tuplestore_puttuple_common()
842 for (i = 0; i < state->readptrcount; readptr++, i++) in tuplestore_puttuple_common()
844 if (readptr->eof_reached && i != state->activeptr) in tuplestore_puttuple_common()
846 readptr->eof_reached = false; in tuplestore_puttuple_common()
848 &readptr->file, in tuplestore_puttuple_common()
849 &readptr->offset); in tuplestore_puttuple_common()
875 readptr = state->readptrs; in tuplestore_puttuple_common()
876 for (i = 0; i < state->readptrcount; readptr++, i++) in tuplestore_puttuple_common()
878 if (readptr->eof_reached && i != state->activeptr) in tuplestore_puttuple_common()
880 readptr->eof_reached = false; in tuplestore_puttuple_common()
881 readptr->file = state->writepos_file; in tuplestore_puttuple_common()
882 readptr->offset = state->writepos_offset; in tuplestore_puttuple_common()
906 TSReadPointer *readptr = &state->readptrs[state->activeptr]; in tuplestore_gettuple() local
910 Assert(forward || (readptr->eflags & EXEC_FLAG_BACKWARD)); in tuplestore_gettuple()
918 if (readptr->eof_reached) in tuplestore_gettuple()
920 if (readptr->current < state->memtupcount) in tuplestore_gettuple()
923 return state->memtuples[readptr->current++]; in tuplestore_gettuple()
925 readptr->eof_reached = true; in tuplestore_gettuple()
934 if (readptr->eof_reached) in tuplestore_gettuple()
936 readptr->current = state->memtupcount; in tuplestore_gettuple()
937 readptr->eof_reached = false; in tuplestore_gettuple()
941 if (readptr->current <= state->memtupdeleted) in tuplestore_gettuple()
946 readptr->current--; /* last returned tuple */ in tuplestore_gettuple()
948 if (readptr->current <= state->memtupdeleted) in tuplestore_gettuple()
953 return state->memtuples[readptr->current - 1]; in tuplestore_gettuple()
959 if (readptr->eof_reached && forward) in tuplestore_gettuple()
967 if (!readptr->eof_reached) in tuplestore_gettuple()
969 readptr->file, readptr->offset, in tuplestore_gettuple()
988 readptr->eof_reached = true; in tuplestore_gettuple()
1006 readptr->eof_reached = false; in tuplestore_gettuple()
1012 if (readptr->eof_reached) in tuplestore_gettuple()
1014 readptr->eof_reached = false; in tuplestore_gettuple()
1137 TSReadPointer *readptr = &state->readptrs[state->activeptr]; in tuplestore_skiptuples() local
1139 Assert(forward || (readptr->eflags & EXEC_FLAG_BACKWARD)); in tuplestore_skiptuples()
1149 if (readptr->eof_reached) in tuplestore_skiptuples()
1151 if (state->memtupcount - readptr->current >= ntuples) in tuplestore_skiptuples()
1153 readptr->current += ntuples; in tuplestore_skiptuples()
1156 readptr->current = state->memtupcount; in tuplestore_skiptuples()
1157 readptr->eof_reached = true; in tuplestore_skiptuples()
1162 if (readptr->eof_reached) in tuplestore_skiptuples()
1164 readptr->current = state->memtupcount; in tuplestore_skiptuples()
1165 readptr->eof_reached = false; in tuplestore_skiptuples()
1168 if (readptr->current - state->memtupdeleted > ntuples) in tuplestore_skiptuples()
1170 readptr->current -= ntuples; in tuplestore_skiptuples()
1174 readptr->current = state->memtupdeleted; in tuplestore_skiptuples()
1212 TSReadPointer *readptr = state->readptrs; in dumptuples() local
1215 for (j = 0; j < state->readptrcount; readptr++, j++) in dumptuples()
1217 if (i == readptr->current && !readptr->eof_reached) in dumptuples()
1219 &readptr->file, &readptr->offset); in dumptuples()
1235 TSReadPointer *readptr = &state->readptrs[state->activeptr]; in tuplestore_rescan() local
1237 Assert(readptr->eflags & EXEC_FLAG_REWIND); in tuplestore_rescan()
1243 readptr->eof_reached = false; in tuplestore_rescan()
1244 readptr->current = 0; in tuplestore_rescan()
1247 readptr->eof_reached = false; in tuplestore_rescan()
1248 readptr->file = 0; in tuplestore_rescan()
1249 readptr->offset = 0L; in tuplestore_rescan()
1252 readptr->eof_reached = false; in tuplestore_rescan()