Searched refs:p_rs (Results 1 – 3 of 3) sorted by relevance
95 static void *getNextRecord (RecordStream *p_rs, size_t *p_outRecordLen) in getNextRecord() argument99 record_end = getEndOfRecord (p_rs->unconsumed, p_rs->read_end); in getNextRecord()103 record_start = p_rs->unconsumed + HEADER_SIZE; in getNextRecord()104 p_rs->unconsumed = record_end; in getNextRecord()127 int record_stream_get_next (RecordStream *p_rs, void ** p_outRecord, in record_stream_get_next() argument135 ret = getNextRecord (p_rs, p_outRecordLen); in record_stream_get_next()143 if (p_rs->unconsumed == p_rs->buffer in record_stream_get_next()144 && p_rs->read_end == p_rs->buffer_end in record_stream_get_next()153 if (p_rs->unconsumed != p_rs->buffer) { in record_stream_get_next()157 toMove = p_rs->read_end - p_rs->unconsumed; in record_stream_get_next()[all …]
32 extern void record_stream_free(RecordStream *p_rs);34 extern int record_stream_get_next (RecordStream *p_rs, void ** p_outRecord,
45 RecordStream *p_rs; member