Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • 在各种查询 Executor 的初始化方法中
  • 调用StorageEngine.mergeLock
    • 根据每个查询涉及的序列,获得这些序列所属的所有StorageGroupProcessor,按照StorageGroupProcessor的name的字母序排序
    • 对于每个查询涉及的 StorageGroupProcessor
      • 对 insertLock 加读锁,对 compactionMergeLock 加读锁
    • 对每个涉及的序列所在的 StorageGroupProsessor
      • 对 insertLock 加读锁,对 compactionMergeLock 加读锁
      • 选择待查的 筛选待查的 TsFileResource 列表列表,对于待查的每个 TsFileResource
        • 对 TsFileLock 加读锁
      • 释放 insertLock 和 compactionMergeLock 的读锁
  • 调用StorageEngine.mergeUnlock,对每个涉及的序列所在的 StorageGroupProsessor
    • 释放 insertLock 和 compactionMergeLock 的读锁
  • 直到查询结束,释放所有 TsFileLock 的读锁

...