ci: debugging

Author: xusd320

packages/next/src/build/swc/loaderWorkerPool.ts

@@ -24,7 +24,12 @@ export async function createOrScalePool(
 ) {
   while (true) {
     try {
+      console.log('[loaderWorkerPool] waiting for pool request')
       let poolOptions = await binding.recvPoolRequest()
+      console.log('[loaderWorkerPool] received pool request', {
+        ...poolOptions,
+        env: 'omitted',
+      })
       const { filename, concurrency, env, cwd } = poolOptions
       // Wildcard of "*" meaning to scale all of pools even with different poolId
       const workers =
@@ -59,7 +64,12 @@ export async function waitingForWorkerTermination(
 ) {
   while (true) {
     try {
+      console.log('[loaderWorkerPool] waiting for worker termination')
       const { filename, workerId } = await binding.recvWorkerTermination()
+      console.log('[loaderWorkerPool] received worker termination', {
+        filename,
+        workerId,
+      })
       const workers = loaderWorkers[filename]
       const workerIdx = workers.findIndex(
         (worker) => worker.threadId === workerId

turbopack/crates/turbopack-node/js/src/worker_threads/evaluate.ts

@@ -38,6 +38,7 @@ export const run = async (
         getValue = module.default
       }
       const value = await getValue(new TaskChannel(binding, taskId), ...args)
+      console.log(`[worker ${workerId}] sending end task message for ${taskId}`)
       await binding.sendTaskMessage(
         taskId,
         JSON.stringify({
@@ -46,25 +47,36 @@ export const run = async (
           duration: 0,
         })
       )
+      console.log(`[worker ${workerId}] sent end task message for ${taskId}`)
     } catch (err) {
+      console.log(
+        `[worker ${workerId}] sending error task message for ${taskId}`
+      )
       await binding.sendTaskMessage(
         taskId,
         JSON.stringify({
           type: 'error',
           ...structuredError(err as Error),
         })
       )
+      console.log(`[worker ${workerId}] sent error task message for ${taskId}`)
     }
     isRunning = false
     runningTask = undefined
   }
 
   const loop = async () => {
+    console.log(`[worker ${workerId}] waiting for worker request`)
     const taskId = await binding.recvWorkerRequest(workerData.poolId)
+    console.log(`[worker ${workerId}] received worker request ${taskId}`)
 
+    console.log(`[worker ${workerId}] notifying worker ack ${taskId}`)
     await binding.notifyWorkerAck(taskId, workerId)
+    console.log(`[worker ${workerId}] notified worker ack ${taskId}`)
 
+    console.log(`[worker ${workerId}] waiting for message in worker`)
     const msg_str = await binding.recvMessageInWorker(workerId)
+    console.log(`[worker ${workerId}] received message in worker`)
 
     const msg = JSON.parse(msg_str) as
       | {