NewLife
/
SmartOS
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

适配历史数据支持毫秒级生成历史数据

This commit is contained in:
LQF 2017-07-05 18:09:41 +08:00
parent 37d70753bd
commit 11cfe84b32
2 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
Message/HistoryStore.cpp
View File

@ -41,7 +41,7 @@ void HistoryStore::Set(void* data, int size)
Size = size; Size = size;
} }
bool HistoryStore::Open() bool HistoryStore::Open(bool UseThousand)
{ {
if (Opened) return true; if (Opened) return true;
@ -49,9 +49,16 @@ bool HistoryStore::Open()
_Report = 0; _Report = 0;
_Store = 0; _Store = 0;
int p;
// 定时生成历史数据 30s if(UseThousand)
int p = RenderPeriod * 1000; {
// 定时生成历史数据 30s
p = RenderPeriod * 1000;
}
else
{
p = RenderPeriod;
}
_task = Sys.AddTask(RenderTask, this, p, p, "历史数据"); _task = Sys.AddTask(RenderTask, this, p, p, "历史数据");
return Opened = true; return Opened = true;
@ -94,7 +101,7 @@ void HistoryStore::RenderTask(void* param)
void HistoryStore::Reader() void HistoryStore::Reader()
{ {
ds_printf("HistoryStore::Reader %d/%d/%d \r\n", Size, Cache.Position(), Cache.Length); //ds_printf("HistoryStore::Reader %d/%d/%d \r\n", Size, Cache.Position(), Cache.Length);
// 生成历史数据 // 生成历史数据
Buffer bs(Data, Size); Buffer bs(Data, Size);
@ -127,7 +134,7 @@ void HistoryStore::Report()
int len2 = n * (4 + Size); int len2 = n * (4 + Size);
if (len2 > len) len2 = len; if (len2 > len) len2 = len;
ds_printf("HistoryStore::Report %d/%d \r\n", len2, len); //ds_printf("HistoryStore::Report %d/%d \r\n", len2, len);
Process(len2, OnReport); Process(len2, OnReport);
} }

2
Message/HistoryStore.h
View File

@ -28,7 +28,7 @@ public:
void Set(void* data, int size); void Set(void* data, int size);
bool Open(); bool Open(bool UseThousand=true);
void Close(); void Close();
// 写入一条历史数据 // 写入一条历史数据