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

update: remove WINDOW_SIZE

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-27 04:14:12 +08:00
parent 6a7f246562
commit 01171f5de3
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/db/snapshotSchedule.ts
View File

@ -6,7 +6,6 @@ import { MINUTE } from "$std/datetime/constants.ts";
import { redis } from "lib/db/redis.ts"; import { redis } from "lib/db/redis.ts";
import { Redis } from "ioredis"; import { Redis } from "ioredis";
const WINDOW_SIZE = 2880;
const REDIS_KEY = "cvsa:snapshot_window_counts"; const REDIS_KEY = "cvsa:snapshot_window_counts";
function getCurrentWindowIndex(): number { function getCurrentWindowIndex(): number {
@ -38,7 +37,7 @@ 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);
if (offset >= 0 && offset < WINDOW_SIZE) { if (offset >= 0) {
await redisClient.hset(REDIS_KEY, offset.toString(), Number(row.count)); await redisClient.hset(REDIS_KEY, offset.toString(), Number(row.count));
} }
} }
@ -217,8 +216,9 @@ export async function adjustSnapshotTime(
const initialOffset = currentWindow + Math.max(targetOffset, 0); const initialOffset = currentWindow + Math.max(targetOffset, 0);
let timePerIteration = 0; let timePerIteration = 0;
const MAX_ITERATIONS = 2880;
const t = performance.now(); const t = performance.now();
for (let i = initialOffset; i < WINDOW_SIZE; i++) { for (let i = initialOffset; i < MAX_ITERATIONS; i++) {
const offset = i; const offset = i;
const count = await getWindowCount(redisClient, offset); const count = await getWindowCount(redisClient, offset);
@ -246,8 +246,8 @@ export async function adjustSnapshotTime(
} }
} }
const elapsed = performance.now() - t; const elapsed = performance.now() - t;
timePerIteration = elapsed / WINDOW_SIZE; timePerIteration = elapsed / MAX_ITERATIONS;
logger.log(`${timePerIteration.toFixed(3)}ms * ${WINDOW_SIZE} iterations`, "perf", "fn:adjustSnapshotTime"); logger.log(`${timePerIteration.toFixed(3)}ms * ${MAX_ITERATIONS} iterations`, "perf", "fn:adjustSnapshotTime");
return expectedStartTime; return expectedStartTime;
} }