if(down_handler == null) { if(observer != null) { if(observer.down(evt, down_queue.size()) == false) { return; } } int type=evt.getType(); if(type == Event.ACK || type == Event.START || type == Event.STOP) { if(handleSpecialDownEvent(evt) == false) return; } down(evt); return; } try { down_queue.add(evt); } catch(Exception e) { if(log.isWarnEnabled()) log.warn("exception: " + e); } }
if (down_handler == null) { if (observer != null) { if (observer.down(evt, down_queue.size()) == false) { return; } } int type = evt.getType(); if (type == Event.ACK || type == Event.START || type == Event.STOP) { if (handleSpecialDownEvent(evt) == false) { return; } } down(evt); return; } try { down_queue.add(evt); } catch (Exception e) { if (log.isWarnEnabled()) { log.warn("exception: " + e); } } }
    protected void receiveDownEvent(Event evt) {        if(down_handler == null) {            if(observer != null) {                                    // call debugger hook (if installed)                if(observer.down(evt, down_queue.size()) == false) {  // false means discard event                    return;                }            }            int type=evt.getType();            if(type == Event.ACK || type == Event.START || type == Event.STOP) {                if(handleSpecialDownEvent(evt) == false)                    return;            }            down(evt);            return;        }        try {            down_queue.add(evt);        }        catch(Exception e) {            if(log.isWarnEnabled()) log.warn("exception: " + e);        }    }