Searched refs:p_rs (Results 1 – 3 of 3) sorted by relevance
96 static void *getNextRecord (RecordStream *p_rs, size_t *p_outRecordLen) in getNextRecord() argument100 record_end = getEndOfRecord (p_rs->unconsumed, p_rs->read_end); in getNextRecord()104 record_start = p_rs->unconsumed + HEADER_SIZE; in getNextRecord()105 p_rs->unconsumed = record_end; in getNextRecord()128 int record_stream_get_next (RecordStream *p_rs, void ** p_outRecord, in record_stream_get_next() argument136 ret = getNextRecord (p_rs, p_outRecordLen); in record_stream_get_next()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()[all …]
33 extern void record_stream_free(RecordStream *p_rs);35 extern int record_stream_get_next (RecordStream *p_rs, void ** p_outRecord,