failure = FailureType.Timeout;
        }
    }

    /**
     * Creates a response to return to the client for an expected request received after a failure.
     */
    public ResponseProducer alreadyFailed(String requestMethod, String path, String context) {
        switch (failure) {
            case UnexpectedRequest:

            }

            if (state.isFailed()) {
                // Broken in another thread
                System.out.println(String.format("[%d] failure in another thread", id));
                return state.alreadyFailed(exchange.getRequestMethod(), path, describeCurrentState());
            }

            if (waitingFor == 0) {
                System.out.println(String.format("[%d] signalling all requests ready", id));

func TestWalkError(t *testing.T) {
	initOverlay(t, "{}")

	alreadyCalled := false
	err := Walk("foo", func(path string, info fs.FileInfo, err error) error {
		if alreadyCalled {
			t.Fatal("expected walk function to be called exactly once, but it was called more than once")
		}
		alreadyCalled = true
		return errors.New("returned from function")
	})
	if !alreadyCalled {