alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: debug for adjusting snapshot time

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-24 04:08:34 +08:00
parent 20731c0530
commit 584a1be9f9
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/db/snapshotSchedule.ts
View File

@ -40,7 +40,6 @@ export async function refreshSnapshotWindowCounts(client: Client, redisClient: R
for (const row of result.rows) { for (const row of result.rows) {
const targetOffset = Math.floor((row.window_start.getTime() - startTime) / (5 * MINUTE)); const targetOffset = Math.floor((row.window_start.getTime() - startTime) / (5 * MINUTE));
const offset = (currentWindow + targetOffset); const offset = (currentWindow + targetOffset);
logger.debug(`window_start: ${row.window_start}, count: ${row.count}, offset: ${offset}`);
if (offset >= 0 && offset < WINDOW_SIZE) { if (offset >= 0 && offset < WINDOW_SIZE) {
await redisClient.hset(REDIS_KEY, offset.toString(), Number(row.count)); await redisClient.hset(REDIS_KEY, offset.toString(), Number(row.count));
} }
@ -188,6 +187,7 @@ export async function adjustSnapshotTime(
for (let i = 0; i < WINDOW_SIZE; i++) { for (let i = 0; i < WINDOW_SIZE; i++) {
const offset = (currentWindow + targetOffset + i) % WINDOW_SIZE; const offset = (currentWindow + targetOffset + i) % WINDOW_SIZE;
const count = await getWindowCount(redisClient, offset); const count = await getWindowCount(redisClient, offset);
logger.debug(`offset: ${offset}, count: ${count}, expectedStartTime: ${expectedStartTime}`);
if (count < allowedCounts) { if (count < allowedCounts) {
// 找到可用窗口，更新计数 // 找到可用窗口，更新计数