Mercurial Hosting > luan
view src/org/eclipse/jetty/util/component/AbstractLifeCycle.java @ 997:7d28be82ab75
simplify Request
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 18 Oct 2016 22:43:17 -0600 |
parents | 5dfb10ec0ca5 |
children | 3fa54d9d19cd |
line wrap: on
line source
// // ======================================================================== // Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd. // ------------------------------------------------------------------------ // All rights reserved. This program and the accompanying materials // are made available under the terms of the Eclipse Public License v1.0 // and Apache License v2.0 which accompanies this distribution. // // The Eclipse Public License is available at // http://www.eclipse.org/legal/epl-v10.html // // The Apache License v2.0 is available at // http://www.opensource.org/licenses/apache2.0.php // // You may elect to redistribute this code under either of these licenses. // ======================================================================== // package org.eclipse.jetty.util.component; import java.util.concurrent.CopyOnWriteArrayList; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Basic implementation of the life cycle interface for components. * * */ public abstract class AbstractLifeCycle implements LifeCycle { private static final Logger LOG = LoggerFactory.getLogger(AbstractLifeCycle.class); public static final String STOPPED="STOPPED"; public static final String FAILED="FAILED"; public static final String STARTING="STARTING"; public static final String STARTED="STARTED"; public static final String STOPPING="STOPPING"; public static final String RUNNING="RUNNING"; private final Object _lock = new Object(); private final int __FAILED = -1, __STOPPED = 0, __STARTING = 1, __STARTED = 2, __STOPPING = 3; private volatile int _state = __STOPPED; protected void doStart() throws Exception { } protected void doStop() throws Exception { } public final void start() throws Exception { synchronized (_lock) { try { if (_state == __STARTED || _state == __STARTING) return; setStarting(); doStart(); setStarted(); } catch (Exception e) { setFailed(e); throw e; } catch (Error e) { setFailed(e); throw e; } } } public final void stop() throws Exception { synchronized (_lock) { try { if (_state == __STOPPING || _state == __STOPPED) return; setStopping(); doStop(); setStopped(); } catch (Exception e) { setFailed(e); throw e; } catch (Error e) { setFailed(e); throw e; } } } public boolean isRunning() { final int state = _state; return state == __STARTED || state == __STARTING; } public boolean isStarted() { return _state == __STARTED; } public boolean isStarting() { return _state == __STARTING; } public boolean isStopping() { return _state == __STOPPING; } public boolean isStopped() { return _state == __STOPPED; } public boolean isFailed() { return _state == __FAILED; } public String getState() { switch(_state) { case __FAILED: return FAILED; case __STARTING: return STARTING; case __STARTED: return STARTED; case __STOPPING: return STOPPING; case __STOPPED: return STOPPED; } return null; } public static String getState(LifeCycle lc) { if (lc.isStarting()) return STARTING; if (lc.isStarted()) return STARTED; if (lc.isStopping()) return STOPPING; if (lc.isStopped()) return STOPPED; return FAILED; } private void setStarted() { _state = __STARTED; LOG.debug(STARTED+" {}",this); } private void setStarting() { LOG.debug("starting {}",this); _state = __STARTING; } private void setStopping() { LOG.debug("stopping {}",this); _state = __STOPPING; } private void setStopped() { _state = __STOPPED; LOG.debug("{} {}",STOPPED,this); } private void setFailed(Throwable th) { _state = __FAILED; LOG.warn(FAILED+" " + this+": "+th,th); } }