Searched refs:p_rs (Results 1 – 3 of 3) sorted by relevance
100 record_end = getEndOfRecord (p_rs->unconsumed, p_rs->read_end); in getNextRecord()105 p_rs->unconsumed = record_end; in getNextRecord()144 if (p_rs->unconsumed == p_rs->buffer in record_stream_get_next()145 && p_rs->read_end == p_rs->buffer_end in record_stream_get_next()154 if (p_rs->unconsumed != p_rs->buffer) { in record_stream_get_next()158 toMove = p_rs->read_end - p_rs->unconsumed; in record_stream_get_next()160 memmove(p_rs->buffer, p_rs->unconsumed, toMove); in record_stream_get_next()163 p_rs->read_end = p_rs->buffer + toMove; in record_stream_get_next()164 p_rs->unconsumed = p_rs->buffer; in record_stream_get_next()167 countRead = read (p_rs->fd, p_rs->read_end, p_rs->buffer_end - p_rs->read_end); in record_stream_get_next()[all …]
33 extern void record_stream_free(RecordStream *p_rs);35 extern int record_stream_get_next (RecordStream *p_rs, void ** p_outRecord,