lifecycleLock.lock();
        try {
            if (stopped) {
                throw new IllegalStateException("server connector cannot be started as it is either stopping or has been stopped");
            }
            if (started) {
                throw new IllegalStateException("server connector cannot be started as it has already been started");
            }

        given:
        executer.noExtraLogging()
        executer.run()

        when:
        def out = executer.withArguments("--stop").run().normalizedOutput

        then:
        out == '''Stopping Daemon(s)
1 Daemon stopped
'''

        when:
        out = executer.withArguments("--stop").run().normalizedOutput

        then:
        out == """$DaemonMessages.NO_DAEMONS_RUNNING
"""
    }

        return result;
    }

    @Override
    public void stop() {
        LOGGER.debug("thread {}: stopping connection", Thread.currentThread().getId());
        delegate.stop();
    }

    @Override
    public String toString() {
        return delegate.toString();
    }

			// Reset at each "machine" token.
			// “The auto-login process searches the .netrc file for a machine token
			// that matches […]. Once a match is made, the subsequent .netrc tokens
			// are processed, stopping when the end of file is reached or another
			// machine or a default token is encountered.”
			switch f[i] {
			case "machine":
				l = netrcLine{machine: f[i+1]}
			case "default":
				break
			case "login":

				if rerr == nil {
					daemon.SdNotify(false, daemon.SdNotifyReady)
				}
				shutdownLogIf(context.Background(), rerr)
				exit(stop && rerr == nil)
			case serviceStop:
				logger.Info("Stopping on service signal")
				daemon.SdNotify(false, daemon.SdNotifyStopping)
				exit(stopProcess())
			}
		}
	}

        manager.stop()

        then:
        noExceptionThrown()
        1 * client1.stop() >> { throw new ExecException("FAILED!") }
        1 * client2.stop()
    }

    def "stopping a failed client removes the client"() {
        def client1 = Mock(WorkerDaemonClient)
        def client2 = Mock(WorkerDaemonClient)
        starter.startDaemon(options) >>> [client1, client2]

        when:

// When called as seq(yield), seq calls yield(v) for each value v in the sequence,
// stopping early if yield returns false.
type Seq[V any] func(yield func(V) bool)

// Seq2 is an iterator over sequences of pairs of values, most commonly key-value pairs.
// When called as seq(yield), seq calls yield(k, v) for each pair (k, v) in the sequence,
// stopping early if yield returns false.
type Seq2[K, V any] func(yield func(K, V) bool)

        monitor = new Thread(new Runnable() {
            @Override
            void run() {
                try {
                    Thread.sleep(containerMaxAliveSeconds * 1000)
                    System.err.println("Stopping container because of timeout of ${containerMaxAliveSeconds}s")
                    stopContainer()
                } catch (InterruptedException ex) {
                    // nothing to do
                }
            }

{"Ticket":1105461453,"IssueData":"2015-09-15T00:00:00","IssueTime":"115","RPState":"CA","PlateExpiry":"200316","Make":"CHEV","BodyStyle":"PA","Color":"BK","Location":"GEORGIA ST/OLYMPIC","Route":"1FB70","Agency":1,"ViolationCode":"8069A","ViolationDescr":"NO STOPPING/STANDING","Fine":93,"Latitude":99999,"Longitude":99999} {"Ticket":1106226590,"IssueData":"2015-09-15T00:00:00","IssueTime":"19","RPState":"CA","PlateExpiry":"201507","Make":"CHEV","BodyStyle":"VN","Color":"GY","Location":"SAN PEDRO S/O BOYD","Ro...

      if (state != null) {
        state.transitionService(service, STARTING, RUNNING);
      }
    }

    @Override
    public void stopping(State from) {
      ServiceManagerState state = this.state.get();
      if (state != null) {
        state.transitionService(service, from, STOPPING);
      }
    }

    @Override
    public void terminated(State from) {
      ServiceManagerState state = this.state.get();