Page History

...

1. 如果是非空的写入线程
   • 在 StorageEngine 中检查SystemInfo是否为reject状态；如果是，则该写入线程循环sleep 100ms（等待flush线程释放内存，system置回正常状态）再进行写入；如果等待6000ms后仍为reject状态，抛出写入异常；50ms（等待flush线程释放内存，system置回正常状态）再进行写入；如果等待max_waiting_time_when_insert_blocked后仍为reject状态，抛出写入异常；
   • 进入对应的StorageGroupProcessor，获取 writeLock
   • 进入对应分区的 TsFileProcessor：（1）获取已有的可写入的顺序或乱序 TsFileProcessor（2）如果没有可写入的TsFileProcessor，创建新的 TsFileProcessor
     • 统计当前写入计划新增的内存占用，增加至TspInfo和SgInfo中：（1）新测点增加 chunk_metadata（2）TEXT 类型数据（3）TVList 中增加的 PrimitiveArray（4）flush内存
     • 如果 SGInfo 增量超过阈值（storage_group_size_report_threshold=16M）
       • 向SystemInfo进行上报（将当前 TsFileProcessor 传入）；
         synchronized(SystemInfo) {
         • 更新 SystemInfo 内存占用。
         • 如果 SystemInfo 内存占用 < 总写入内存 * flush_proportion，返回 true。
         • 如果 总写入内存 * flush_proportion ≤ SystemInfo 内存占用 < 总写入内存 * reject_proportion, 执行 选择Memtable提交flush流程，返回 true。
         • 如果 总写入内存 * reject_proportion ≤ SystemInfo 内存占用, SystemInfo 置为 reject 状态， 执行 选择Memtable提交flush流程，记返回值为 flag
           • 如果 flag = true 
             • 如果 SystemInfo 内存占用 < 总写入内存，则返回 true
             • 如果 SystemInfo 内存占用 ≥ 总写入内存，直接抛 写入Reject 异常
           • 如果 flag = false，则返回 false
             }
       • 判断 向SystemInfo上报 的返回结果
         • 如果返回 false，则该写入线程循环 sleep (50ms) ，检查 SystemInfo 的 reject 状态如果不 reject，执行正常写入。如果等待 reject或者该memtable被标记为shouldFlush，执行正常写入。如果等待 max_waiting_time_when_insert_blocked 后仍为reject状态，抛出写入异常
         • 如果返回 true，则执行正常写入
         • 如果捕获到 写入Reject 异常，reset SystemInfo，并继续向上抛
     • 检查 workingMemtable 的 shouldFlush，如果为true，提交 Flush 任务，并根据文件大小判断是否需要 close。
   • StorageGroupProsessor. 释放writeLock
2. 如果是空的写入线程
   • 进入对应的 StorageGroupProcessor，获取 writeLock
   • 获取对应分区的 TsFileProcessor：如果（其 workingMemtable 不为空且 shouldFlush 为 true），则提交 flush 任务；否则直接返回。
   • StorageGroupProsessor. 释放writeLock

...