frankenphp/thread-inactive.go

package frankenphp

import (
	"net/http"
)

// representation of a thread with no work assigned to it
// implements the threadHandler interface
// each inactive thread weighs around ~350KB
// keeping threads at 'inactive' will consume more memory, but allow a faster transition
type inactiveThread struct {
	thread *phpThread
}

func convertToInactiveThread(thread *phpThread) {
	thread.setHandler(&inactiveThread{thread: thread})
}

func (handler *inactiveThread) beforeScriptExecution() string {
	thread := handler.thread

	switch thread.state.get() {
	case stateTransitionRequested:
		return thread.transitionToNewHandler()
	case stateBooting, stateTransitionComplete:
		thread.state.set(stateInactive)

		// wait for external signal to start or shut down
		thread.state.markAsWaiting(true)
		thread.state.waitFor(stateTransitionRequested, stateShuttingDown)
		thread.state.markAsWaiting(false)
		return handler.beforeScriptExecution()
	case stateShuttingDown:
		// signal to stop
		return ""
	}
	panic("unexpected state: " + thread.state.name())
}

func (handler *inactiveThread) afterScriptExecution(exitStatus int) {
	panic("inactive threads should not execute scripts")
}

func (handler *inactiveThread) getActiveRequest() *http.Request {
	panic("inactive threads have no requests")
}

func (handler *inactiveThread) name() string {
	return "Inactive PHP Thread"
}