- //We cannot write more than refTsLength values
- if (tsLength < refTsLength)
- tsBuffer[tsLength++] = value;
-
- if ((++processedLines) % 1000000 == 0)
- fprintf(stdout,"Processed %"PRIu64" lines\n", processedLines);
- }
-
- if (nbItems <= 0 || seriesCount < nbItems)
- {
- // flush last time-series if all conditions are met
- if (tsLength == refTsLength)