(handler *workerThread, worker *worker)
| 108 | func (handler *workerThread) drain() {} |
| 109 | |
| 110 | func setupWorkerScript(handler *workerThread, worker *worker) { |
| 111 | metrics.StartWorker(worker.name) |
| 112 | |
| 113 | // Create a dummy request to set up the worker |
| 114 | fc, err := newDummyContext( |
| 115 | filepath.Base(worker.fileName), |
| 116 | worker.requestOptions..., |
| 117 | ) |
| 118 | if err != nil { |
| 119 | panic(err) |
| 120 | } |
| 121 | |
| 122 | ctx := context.WithValue(globalCtx, contextKey, fc) |
| 123 | |
| 124 | fc.worker = worker |
| 125 | handler.dummyFrankenPHPContext = fc |
| 126 | handler.dummyContext = ctx |
| 127 | handler.isBootingScript = true |
| 128 | handler.requestCount = 0 |
| 129 | |
| 130 | if globalLogger.Enabled(ctx, slog.LevelDebug) { |
| 131 | globalLogger.LogAttrs(ctx, slog.LevelDebug, "starting", slog.String("worker", worker.name), slog.Int("thread", handler.thread.threadIndex)) |
| 132 | } |
| 133 | } |
| 134 | |
| 135 | func tearDownWorkerScript(handler *workerThread, exitStatus int) { |
| 136 | worker := handler.worker |
no test coverage detected