Weishen/Hydro
2
0 Fork 0
mirror of https://gitcode.com/gh_mirrors/hy/Hydro.git synced 2026-10-17 17:36:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

vjudge: prevent race cond

Browse Source
This commit is contained in:
undefined committed 2021-06-21 18:04:49 +08:00
1 parent 577e100ca6
commit ce3cdc645c
2 files changed
+17 -11
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

packages/vjudge/package.json
+1 -1
View File
@@ -1,6 +1,6 @@
{
"name": "@hydrooj/vjudge",
"version": "1.0.4",
"version": "1.0.5",
"description": "Submit problems to remote oj",
"main": "package.json",
"repository": "https://github.com/hydro-dev/Hydro.git",
packages/vjudge/src/model.ts
+16 -10
View File
@@ -13,6 +13,7 @@ import { BasicProvider, IBasicProvider, RemoteAccount } from './interface';
const coll = db.collection('vjudge');
const Pool = {};
const logger = new Logger('vjudge');
const syncing = {};
class Service {
api: IBasicProvider;
@@ -37,17 +38,22 @@ class Service {
while (pids.length) {
logger.info(`${domainId}: Syncing page ${page}`);
for (const pid of pids) {
if (await ProblemModel.get(domainId, pid)) continue;
const res = await this.api.getProblem(pid);
if (!res) continue;
const id = await ProblemModel.add(domainId, pid, res.title, res.content, 1, res.tag, false);
for (const key in res.files) {
await ProblemModel.addAdditionalFile(domainId, id, key, res.files[key]);
if (syncing[`${domainId}/${pid}`] || await ProblemModel.get(domainId, pid)) continue;
syncing[`${domainId}/${pid}`] = true;
try {
const res = await this.api.getProblem(pid);
if (!res) continue;
const id = await ProblemModel.add(domainId, pid, res.title, res.content, 1, res.tag, false);
for (const key in res.files) {
await ProblemModel.addAdditionalFile(domainId, id, key, res.files[key]);
}
for (const key in res.data) {
await ProblemModel.addTestdata(domainId, id, key, res.data[key]);
}
logger.info(`${domainId}: problem ${id} sync done`);
} finally {
delete syncing[`${domainId}/${pid}`];
}
for (const key in res.data) {
await ProblemModel.addTestdata(domainId, id, key, res.data[key]);
}
logger.info(`${domainId}: problem ${id} sync done`);
await sleep(5000);
}
page++;