313     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
314     allData.clear();  in TEST()
315     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11));  in TEST()
317     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
329     allData.clear();  in TEST()
330     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 23));  in TEST()
331     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
344     allData.clear();  in TEST()
345     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs + 1, 36));  in TEST()
346     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
390     vector<shared_ptr<LogEvent>> allData;  in TEST_P()  local
391     allData.clear();  in TEST_P()
392     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 10, 2));  in TEST_P()
393     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST_P()
438     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
439     allData.clear();  in TEST()
440     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 3, 11));  in TEST()
442     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
454     allData.clear();  in TEST()
455     allData.push_back(CreateTwoValueLogEvent(tagId, bucket3StartTimeNs + 1, 4, 23));  in TEST()
456     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
461     allData.clear();  in TEST()
462     allData.push_back(CreateTwoValueLogEvent(tagId, bucket4StartTimeNs + 1, 3, 36));  in TEST()
463     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
489     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
490     allData.clear();  in TEST()
491     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11));  in TEST()
493     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
504     allData.clear();  in TEST()
506     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 10));  in TEST()
507     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
517     allData.clear();  in TEST()
518     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs + 1, 36));  in TEST()
519     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
542     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
543     allData.clear();  in TEST()
544     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11));  in TEST()
546     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
557     allData.clear();  in TEST()
559     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 10));  in TEST()
560     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
568     allData.clear();  in TEST()
569     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs + 1, 36));  in TEST()
570     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
629     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
630     allData.clear();  in TEST()
631     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 110));  in TEST()
632     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
741     vector<shared_ptr<LogEvent>> allData;  in TEST_P()  local
742     allData.clear();  in TEST_P()
743     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 100));  in TEST_P()
745     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST_P()
761     allData.clear();  in TEST_P()
762     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 150));  in TEST_P()
763     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST_P()
787     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
788     allData.clear();  in TEST()
789     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 100));  in TEST()
791     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1104     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1106     allData.clear();  in TEST()
1107     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 11));  in TEST()
1109     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1121     allData.clear();  in TEST()
1122     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 23));  in TEST()
1123     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
1138     allData.clear();  in TEST()
1139     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket6StartTimeNs + 1, 36));  in TEST()
1140     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket6StartTimeNs);  in TEST()
1219     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1220     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 110));  in TEST()
1221     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1305     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1306     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 50, 140));  in TEST()
1307     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 50);  in TEST()
1320     allData.clear();  in TEST()
1321     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 160));  in TEST()
1322     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
1707     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1709     allData.clear();  in TEST()
1710     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4));  in TEST()
1711     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11));  in TEST()
1713     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1773     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1775     allData.clear();  in TEST()
1776     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4));  in TEST()
1777     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11));  in TEST()
1779     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1800     allData.clear();  in TEST()
1801     allData.push_back(CreateTwoValueLogEvent(tagId, bucket4StartTimeNs + 1, 2, 5));  in TEST()
1802     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
1813     allData.clear();  in TEST()
1814     allData.push_back(CreateTwoValueLogEvent(tagId, bucket5StartTimeNs + 1, 2, 13));  in TEST()
1815     allData.push_back(CreateTwoValueLogEvent(tagId, bucket5StartTimeNs + 1, 1, 5));  in TEST()
1816     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket5StartTimeNs);  in TEST()
1865     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1866     allData.clear();  in TEST()
1867     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 2, 4));  in TEST()
1868     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 11));  in TEST()
1869     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
1893     allData.clear();  in TEST()
1894     allData.push_back(CreateTwoValueLogEvent(tagId, bucket4StartTimeNs + 1, 2, 5));  in TEST()
1895     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
1907     allData.clear();  in TEST()
1908     allData.push_back(CreateTwoValueLogEvent(tagId, bucket5StartTimeNs + 1, 2, 14));  in TEST()
1909     allData.push_back(CreateTwoValueLogEvent(tagId, bucket5StartTimeNs + 1, 1, 14));  in TEST()
1910     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket5StartTimeNs);  in TEST()
1915     allData.clear();  in TEST()
1916     allData.push_back(CreateTwoValueLogEvent(tagId, bucket6StartTimeNs + 1, 1, 19));  in TEST()
1917     allData.push_back(CreateTwoValueLogEvent(tagId, bucket6StartTimeNs + 1, 2, 20));  in TEST()
1918     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket6StartTimeNs);  in TEST()
1979     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
1980     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucket2StartTimeNs);  in TEST()
2165     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2166     allData.clear();  in TEST()
2167     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110));  in TEST()
2168     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs);  in TEST()
2176     allData.clear();  in TEST()
2177     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140));  in TEST()
2178     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2245     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2246     allData.clear();  in TEST()
2247     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1, 10));  in TEST()
2248     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2307     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2308     allData.clear();  in TEST()
2309     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110));  in TEST()
2310     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucketStartTimeNs);  in TEST()
2316     allData.clear();  in TEST()
2317     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140));  in TEST()
2318     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2384     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2385     allData.clear();  in TEST()
2386     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 110));  in TEST()
2387     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs);  in TEST()
2393     allData.clear();  in TEST()
2394     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 140));  in TEST()
2395     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucket2StartTimeNs);  in TEST()
2446     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2447     allData.clear();  in TEST()
2448     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 110));  in TEST()
2449     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2457     allData.clear();  in TEST()
2458     allData.push_back(CreateNoValuesLogEvent(tagId, bucket3StartTimeNs + 1));  in TEST()
2459     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
2467     allData.clear();  in TEST()
2468     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs + 1, 150));  in TEST()
2469     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
2476     allData.clear();  in TEST()
2477     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket5StartTimeNs + 1, 170));  in TEST()
2478     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket5StartTimeNs);  in TEST()
2547     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2548     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 120));  in TEST()
2549     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2605     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2606     allData.clear();  in TEST()
2607     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2641     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2642     allData.clear();  in TEST()
2643     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 2));  in TEST()
2644     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2709     vector<shared_ptr<LogEvent>> allData;  in TEST_P()  local
2710     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs + 1, 4));  in TEST_P()
2712     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucket3StartTimeNs + 1);  in TEST_P()
2754     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2755     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 4));  in TEST()
2756     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
2786     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2787     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10));  in TEST()
2788     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs + 30);  in TEST()
2790     allData.clear();  in TEST()
2791     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20));  in TEST()
2792     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2816     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2817     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 30, 10));  in TEST()
2818     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs + 30);  in TEST()
2820     allData.clear();  in TEST()
2821     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20));  in TEST()
2822     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2907     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2908     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 10));  in TEST()
2909     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
2951     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2952     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 3, 10));  in TEST()
2953     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucketStartTimeNs + 3);  in TEST()
2955     allData.clear();  in TEST()
2956     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 20));  in TEST()
2957     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_FAIL, bucket2StartTimeNs);  in TEST()
2962     allData.clear();  in TEST()
2963     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 30));  in TEST()
2964     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
2990     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
2991     allData.clear();  in TEST()
2992     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, tagId, 2, 2));  in TEST()
2993     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
3056     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3057     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 10));  in TEST()
3058     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 30);  in TEST()
3107     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3108     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 110));  in TEST()
3109     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
3139     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3140     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30));  in TEST()
3141     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
3161     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3162     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30));  in TEST()
3163     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
3195     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3196     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 30, 30));  in TEST()
3197     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
3284     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3285     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 15));  in TEST()
3286     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
3347     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3348     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 15));  in TEST()
3349     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
3351     allData.clear();  in TEST()
3352     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs - 100, 20));  in TEST()
3355     valueProducer->accumulateEvents(allData, bucket2StartTimeNs - 100, bucket2StartTimeNs - 100);  in TEST()
3690     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
3691     allData.clear();  in TEST()
3692     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 3));  in TEST()
3693     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
4688     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
4689     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 1 /*uid*/, 10));  in TEST()
4690     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 2 /*uid*/, 15));  in TEST()
4691     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
5720     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
5721     allData.push_back(  in TEST()
5723     allData.push_back(  in TEST()
5725     allData.push_back(  in TEST()
5727     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
5934     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
5935     allData.clear();  in TEST()
5936     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 11));  in TEST()
5937     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
6099     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6100     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs, 11));  in TEST()
6101     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
6112     allData.clear();  in TEST()
6113     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 15));  in TEST()
6114     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6305     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6306     allData.push_back(  in TEST()
6308     allData.push_back(  in TEST()
6310     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 1);  in TEST()
6494     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6495     allData.clear();  in TEST()
6496     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 1 /*uid*/, 21, 21));  in TEST()
6497     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 2 /*uid*/, 20, 5));  in TEST()
6498     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
6562     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6565     allData.clear();  in TEST()
6566     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
6567     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
6575     allData.clear();  in TEST()
6576     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 15));  in TEST()
6577     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6616     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6617     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + delayNs, 10));  in TEST()
6618     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
6631     allData.clear();  in TEST()
6632     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 10));  in TEST()
6633     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6686     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6687     allData.clear();  in TEST()
6688     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 30));  in TEST()
6689     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6789     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6790     allData.clear();  in TEST()
6791     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket1LatePullNs, 10));  in TEST()
6792     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket1LatePullNs);  in TEST()
6804     allData.clear();  in TEST()
6805     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2LatePullNs, 25));  in TEST()
6806     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2LatePullNs);  in TEST()
6821     allData.clear();  in TEST()
6822     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs, 40));  in TEST()
6823     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
6855     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6858     allData.clear();  in TEST()
6859     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
6860     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
6868     allData.clear();  in TEST()
6869     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 15));  in TEST()
6870     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6879     allData.clear();  in TEST()
6880     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs, 20));  in TEST()
6881     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
6908     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6911     allData.clear();  in TEST()
6912     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
6913     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
6922     allData.clear();  in TEST()
6923     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 15));  in TEST()
6924     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
6931     allData.clear();  in TEST()
6932     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket4StartTimeNs, 20));  in TEST()
6933     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket4StartTimeNs);  in TEST()
6969     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
6972     allData.clear();  in TEST()
6973     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
6974     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
7026     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7029     allData.clear();  in TEST()
7030     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
7031     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
7084     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7087     allData.clear();  in TEST()
7088     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
7089     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
7097     allData.clear();  in TEST()
7098     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket3StartTimeNs, 15));  in TEST()
7099     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs);  in TEST()
7155     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7158     allData.clear();  in TEST()
7159     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
7160     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
7213     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7216     allData.clear();  in TEST()
7217     allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + pullDelayNs, 10));  in TEST()
7218     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS,  in TEST()
7396     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7397     allData.clear();  in TEST()
7398     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 1 /*uid*/, 10, 5));  in TEST()
7399     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 1 /*uid*/, 11, 7));  in TEST()
7400     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 2 /*uid*/, 8, 5));  in TEST()
7401     allData.push_back(CreateThreeValueLogEvent(tagId, bucket2StartTimeNs + 1, 2 /*uid*/, 9, 7));  in TEST()
7402     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
7477     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7478     allData.clear();  in TEST()
7479     allData.push_back(makeRepeatedUidLogEvent(tagId, bucket2StartTimeNs + 1, {1, 10}, 5, {5, 7}));  in TEST()
7480     allData.push_back(makeRepeatedUidLogEvent(tagId, bucket2StartTimeNs + 1, {2, 10}, 5, {7, 5}));  in TEST()
7481     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()
7777     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
7778     allData.clear();  in TEST()
7779     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 15, 30));  in TEST()
7780     allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs, 20, 40));  in TEST()
7781     valueProducer->onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs);  in TEST()