github_mirrors/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2025-02-02 23:28:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

dev: implement custom backoff strategy for judge0

Browse Source
This commit is contained in:
KernelDeimos 2025-01-28 13:27:26 -05:00
parent 5718071c08
commit 4005e9667c
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/backend/src/modules/puterexec/Judge0Service.js
View File

@ -53,13 +53,29 @@ class Judge0Service extends BaseService {
const submission_done = new putility.libs.promise.TeePromise(); const submission_done = new putility.libs.promise.TeePromise();
(async () => { (async () => {
// Need to poll the submission until it's done // Need to poll the submission until it's done
let i = 0;
let poll_running = false;
let poll = setInterval(async () => { let poll = setInterval(async () => {
// Prevent overlapping polls
if ( poll_running ) return;
// Custom backoff strategy
let will_skip = false;
if ( i > 5 && i % 2 === 0 ) will_skip = true;
if ( i > 10 && i % 3 === 0 ) will_skip = true;
if ( i > 50 && i % 5 === 0 ) will_skip = true;
i++;
if ( will_skip ) return;
// Poll the submission
poll_running = true;
const submission = await this.client.get_submission(result.token); const submission = await this.client.get_submission(result.token);
if ( submission.status.id >= 3 ) { if ( submission.status.id >= 3 ) {
clearInterval(poll); clearInterval(poll);
// this.submissions_[result.id] = submission; // this.submissions_[result.id] = submission;
submission_done.resolve(submission); submission_done.resolve(submission);
} }
poll_running = false;
}); });
// Wait for the submission to be done // Wait for the submission to be done