1.测试，完善，+日志

chenluhua1980

2026-01-06 18f05a37d19e0e20db266a4e32e8263847e94a76

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
// SampleBuffer.h
#pragma once
#include "../core/DataTypes.h"
#include <deque>
#include <vector>
#include <shared_mutex>
#include <chrono>
 
enum class RetainMode {
    ByCount,        // °´Ñù±¾ÊýÉÏÏÞ
    ByRollingAge,   // °´¹ö¶¯Ê±¼ä´°¿Ú£¨maxAge£©
    ByAbsoluteRange // °´¾ø¶Ôʱ¼ä¶Î [absFrom, absTo]
};
 
struct RetentionPolicy {
    RetainMode mode = RetainMode::ByCount;
    size_t maxSamples = 100000;                         // ByCount ÓÃ
    std::chrono::milliseconds maxAge{ std::chrono::hours(1) }; // ByRollingAge ÓÃ
    int64_t absFrom = 0;                                // ByAbsoluteRange ÓÃ
    int64_t absTo = 0;                                // ByAbsoluteRange Óã¨absTo>=absFrom ÓÐЧ£©
};
 
class SampleBuffer {
public:
    explicit SampleBuffer(RetentionPolicy policy = {}) : policy_(policy) {}
 
    // Ð´£º°´Ê±¼ä´ÁµÝÔöÍÆÈ루ÂÒÐò»á±»¼òµ¥¾ÀÕýΪ·ÇµÝ¼õ£©
    void push(int64_t ts_ms, double v);
 
    // ¶Á£º°´¡°tsExclusive Ö®ºó¡±µÄÐÂÊý¾Ý
    std::vector<Sample> getSince(int64_t tsExclusive, size_t maxCount = 4096) const;
 
    // ¶Á£º°´Çø¼ä [from, to]£¨°üº¬±ß½ç£©
    std::vector<Sample> getRange(int64_t from_ts, int64_t to_ts, size_t maxCount = 4096) const;
 
    // ²éѯ / Î¬»¤
    size_t size() const;
    bool   empty() const;
    int64_t latestTs() const;
    void clear();
 
    // ÅäÖÃ
    void setPolicy(const RetentionPolicy& p);
    RetentionPolicy getPolicy() const;
 
    int64_t earliestTs() const;  // ÎÞÊý¾Ýʱ·µ»Ø 0
 
private:
    void pruneUnlocked(int64_t ref_now_ms);       // °´²ßÂÔÇåÀí
    size_t lowerBoundIndex(int64_t tsExclusive) const; // ¶þ·Ö£ºµÚÒ»¸ö > tsExclusive
    size_t lowerBoundInclusive(int64_t tsInclusive) const; // µÚÒ»¸ö >= tsInclusive
    size_t upperBoundInclusive(int64_t tsInclusive) const; // ×îºóÒ»¸ö <= tsInclusive µÄÏÂÒ»¸öλÖÃ
 
    mutable std::shared_mutex mtx_;
    std::deque<Sample> data_;
    RetentionPolicy policy_;
};