Mercurial Hosting > luan
diff src/org/eclipse/jetty/util/component/AbstractLifeCycle.java @ 847:5dfb10ec0ca5
remove LifeCycle.Listener
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Mon, 19 Sep 2016 16:11:15 -0600 |
parents | 8e9db0bbf4f9 |
children | 3fa54d9d19cd |
line wrap: on
line diff
--- a/src/org/eclipse/jetty/util/component/AbstractLifeCycle.java Mon Sep 19 15:02:49 2016 -0600 +++ b/src/org/eclipse/jetty/util/component/AbstractLifeCycle.java Mon Sep 19 16:11:15 2016 -0600 @@ -30,188 +30,158 @@ */ 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 final CopyOnWriteArrayList<LifeCycle.Listener> _listeners=new CopyOnWriteArrayList<LifeCycle.Listener>(); + 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 doStart() throws Exception - { - } - - protected void doStop() 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 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 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 isRunning() + { + final int state = _state; + + return state == __STARTED || state == __STARTING; + } - public boolean isStopping() - { - return _state == __STOPPING; - } - - public boolean isStopped() - { - return _state == __STOPPED; - } + public boolean isStarted() + { + return _state == __STARTED; + } - public boolean isFailed() - { - return _state == __FAILED; - } - - public void addLifeCycleListener(LifeCycle.Listener listener) - { - _listeners.add(listener); - } + public boolean isStarting() + { + return _state == __STARTING; + } - public void removeLifeCycleListener(LifeCycle.Listener listener) - { - _listeners.remove(listener); - } - - 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; - } + public boolean isStopping() + { + return _state == __STOPPING; + } + + public boolean isStopped() + { + return _state == __STOPPED; + } + + public boolean isFailed() + { + return _state == __FAILED; + } - private void setStarted() - { - _state = __STARTED; - LOG.debug(STARTED+" {}",this); - for (Listener listener : _listeners) - listener.lifeCycleStarted(this); - } - - private void setStarting() - { - LOG.debug("starting {}",this); - _state = __STARTING; - for (Listener listener : _listeners) - listener.lifeCycleStarting(this); - } - - private void setStopping() - { - LOG.debug("stopping {}",this); - _state = __STOPPING; - for (Listener listener : _listeners) - listener.lifeCycleStopping(this); - } + 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 setStopped() - { - _state = __STOPPED; - LOG.debug("{} {}",STOPPED,this); - for (Listener listener : _listeners) - listener.lifeCycleStopped(this); - } + private void setStarted() + { + _state = __STARTED; + LOG.debug(STARTED+" {}",this); + } + + private void setStarting() + { + LOG.debug("starting {}",this); + _state = __STARTING; + } - private void setFailed(Throwable th) - { - _state = __FAILED; - LOG.warn(FAILED+" " + this+": "+th,th); - for (Listener listener : _listeners) - listener.lifeCycleFailure(this,th); - } + private void setStopping() + { + LOG.debug("stopping {}",this); + _state = __STOPPING; + } - public static abstract class AbstractLifeCycleListener implements LifeCycle.Listener - { - public void lifeCycleFailure(LifeCycle event, Throwable cause) {} - public void lifeCycleStarted(LifeCycle event) {} - public void lifeCycleStarting(LifeCycle event) {} - public void lifeCycleStopped(LifeCycle event) {} - public void lifeCycleStopping(LifeCycle event) {} - } + private void setStopped() + { + _state = __STOPPED; + LOG.debug("{} {}",STOPPED,this); + } + + private void setFailed(Throwable th) + { + _state = __FAILED; + LOG.warn(FAILED+" " + this+": "+th,th); + } + }