diff --git a/src/frontend-syzoj/daemonRouter.ts b/src/frontend-syzoj/daemonRouter.ts index e9f76f0..0a1795f 100644 --- a/src/frontend-syzoj/daemonRouter.ts +++ b/src/frontend-syzoj/daemonRouter.ts @@ -26,7 +26,7 @@ taskRouter.put('/task', async (req, res) => { return res.sendStatus(400); } try { - winston.info("Got task: " + JSON.stringify(req.body)); + winston.info("Got task: " + JSON.stringify(req.body.content.taskId)); const task = req.body as JudgeTask; let extraData: Buffer = null; if (task.extraFileLocation != null) { diff --git a/src/frontend-syzoj/rmq.ts b/src/frontend-syzoj/rmq.ts index be04f8b..7aff05f 100644 --- a/src/frontend-syzoj/rmq.ts +++ b/src/frontend-syzoj/rmq.ts @@ -34,7 +34,7 @@ async function newChannel(): Promise { } export function pushTask(task: any) { - winston.info("Got task", task); + winston.info("Got task, pushing to queue"); publicChannel.sendToQueue(rmqCommon.judgeQueueName, msgpack.encode(task), { priority: task.content.priority }); diff --git a/src/frontend-syzoj/socketio.ts b/src/frontend-syzoj/socketio.ts index bc4efc4..8c767c4 100644 --- a/src/frontend-syzoj/socketio.ts +++ b/src/frontend-syzoj/socketio.ts @@ -265,7 +265,7 @@ export function updateCompileStatus(taskId: string, result: CompilationResult) { } export function updateProgress(taskId: string, data: OverallResult) { - winston.verbose(`Updating progress for #${taskId}, data: ${JSON.stringify(data)}`); + winston.verbose(`Updating progress for #${taskId}`); currentJudgeList[taskId] = data; forAllClients(detailProgressNamespace, taskId, (client) => { diff --git a/src/rmq-common.ts b/src/rmq-common.ts index 6a53b97..0a030b1 100644 --- a/src/rmq-common.ts +++ b/src/rmq-common.ts @@ -39,7 +39,7 @@ export async function waitForTask(conn: amqp.Connection, queueName: string, p channel.prefetch(1); await channel.consume(queueName, (msg: amqp.Message) => { const data = msgpack.decode(msg.content) as T; - winston.verbose('Got task', data); + winston.verbose('Got task'); handle(data).then(async () => { channel.ack(msg);