48     RecordStream *ret;  in record_stream_new()  local
52     ret = (RecordStream *)calloc(1, sizeof(RecordStream));  in record_stream_new()
54     ret->fd = fd;  in record_stream_new()
55     ret->maxRecordLen = maxRecordLen;  in record_stream_new()
56     ret->buffer = (unsigned char *)malloc (maxRecordLen + HEADER_SIZE);  in record_stream_new()
58     ret->unconsumed = ret->buffer;  in record_stream_new()
59     ret->read_end = ret->buffer;  in record_stream_new()
60     ret->buffer_end = ret->buffer + maxRecordLen + HEADER_SIZE;  in record_stream_new()
62     return ret;  in record_stream_new()
131     void *ret;  in record_stream_get_next()  local
136     ret = getNextRecord (p_rs, p_outRecordLen);  in record_stream_get_next()
138     if (ret != NULL) {  in record_stream_get_next()
139         *p_outRecord = ret;  in record_stream_get_next()
177     ret = getNextRecord (p_rs, p_outRecordLen);  in record_stream_get_next()
179     if (ret == NULL) {  in record_stream_get_next()
185     *p_outRecord = ret;          in record_stream_get_next()