关于tsdb插入相同时间戳数据及检索的建议

因为项目需要在tsdb中保存多条相同时间戳的数据，但是在您的项目中发现从FlashDBv2.0.0开始不再支持相同时间戳的数据保存；项目中使用时间检索数据通过fdb_tsl_iter_by_time实现，在此函数中会通过查找时间戳所在分区，随后通过调用search_start_tsl_addr函数查找分区中时间戳的具体位置，search_start_tsl_addr对相同时间戳进行查找时可能会错过查找位置的之前的数据，所以在为了项目需要，所以对查找部分做了在以下修改

```
static int search_start_tsl_addr(fdb_tsdb_t db, int start, int end, fdb_time_t from, fdb_time_t to)
{
    struct fdb_tsl tsl;
    while (true) {
        tsl.addr.index = start + FDB_ALIGN((end - start) / 2, LOG_IDX_DATA_SIZE);
        read_tsl(db, &tsl);
        if (tsl.time < from) {
            start = tsl.addr.index + LOG_IDX_DATA_SIZE;
        } else if (tsl.time > from) {
            end = tsl.addr.index - LOG_IDX_DATA_SIZE;
        } else {
            while(from <= to && tsl.time >= from) { //正序检索
                tsl.addr.index -= LOG_IDX_DATA_SIZE;
                read_tsl(db, &tsl);
            }
            while(from > to && tsl.time <= from) { //倒叙检索
                tsl.addr.index += LOG_IDX_DATA_SIZE;
                read_tsl(db, &tsl);
            }

return (from <= to)? tsl.addr.index + LOG_IDX_DATA_SIZE : tsl.addr.index - LOG_IDX_DATA_SIZE;
            // return tsl.addr.index;
        }

if (start > end) {
            if (from > to) {
                tsl.addr.index = start;
                read_tsl(db, &tsl);
                if (tsl.time > from) {
                    start -= LOG_IDX_DATA_SIZE;
                }
            }
            break;
        }
    }
    return start;
}```

GVP 朱天龙 (Armink)/FlashDB

内容风险标识

评论 (2)

GVP朱天龙 (Armink)/FlashDB

内容风险标识