List of fireExceptionCaught() Examples

Examples of fireExceptionCaught()

io.netty.channel.ChannelHandlerContext.fireExceptionCaught()
io.netty.channel.ChannelPipeline.fireExceptionCaught()
org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()
Fires a {@link IoHandler#exceptionCaught(IoSession,Throwable)} event. Most users don'tneed to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

                    session,
                    !session.getWriteRequestQueue().isEmpty(session) &&
                            !session.isWriteSuspended());
        } catch (Exception e) {
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
        }
    }
        
    private class Processor implements Runnable {
        public void run() {

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

            if (notified) {
                // Clear the DefaultIoFilterChain.CONNECT_FUTURE attribute
                // and call ConnectFuture.setException().
                scheduleRemove(session);
                IoFilterChain filterChain = session.getFilterChain(); 
                filterChain.fireExceptionCaught(e);
                wakeup();
            } else {
                ExceptionMonitor.getInstance().exceptionCaught(e);
                try {
                    destroy(session);

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

        try {
            destroy(session);
            return true;
        } catch (Exception e) {
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
        } finally {
            clearWriteRequestQueue(session);
            ((AbstractIoService) session.getService()).getListeners().fireSessionDestroyed(session);
        }
        return false;

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

            for (WriteRequest r: failedRequests) {
                session.decreaseScheduledBytesAndMessages(r);
                r.getFuture().setException(cause);
            }
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(cause);
        }
    }


    private void process() throws Exception {
        for (Iterator<T> i = selectedSessions(); i.hasNext();) {

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

        } catch (Throwable e) {
            if (e instanceof IOException) {
                scheduleRemove(session);
            }
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
        }
    }


    private void notifyIdleSessions(long currentTime) throws Exception {
        // process idle sessions

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

                        scheduleFlush(session);
                    }
                } catch (Exception e) {
                    scheduleRemove(session);
                    IoFilterChain filterChain = session.getFilterChain(); 
                    filterChain.fireExceptionCaught(e);
                }
                break;
            case CLOSED:
                // Skip if the channel is already closed.
                break;

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

                    return false;
                }
            } while (writtenBytes < maxWrittenBytes);
        } catch (Exception e) {
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
            return false;
        }


        return true;
    }

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

    public void updateTrafficControl(T session) {
      try {
            setInterestedInRead(session, !session.isReadSuspended());
        } catch (Exception e) {
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
        }
        try {
            setInterestedInWrite(
                    session,
                    !session.getWriteRequestQueue().isEmpty(session) &&

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

                    session,
                    !session.getWriteRequestQueue().isEmpty(session) &&
                            !session.isWriteSuspended());
        } catch (Exception e) {
            IoFilterChain filterChain = session.getFilterChain(); 
            filterChain.fireExceptionCaught(e);
        }
    }
        
    private class Processor implements Runnable {
        public void run() {

View Full Code Here

Examples of org.apache.mina.core.filterchain.IoFilterChain.fireExceptionCaught()

            if (notified) {
                // Clear the DefaultIoFilterChain.CONNECT_FUTURE attribute
                // and call ConnectFuture.setException().
                scheduleRemove(session);
                IoFilterChain filterChain = session.getFilterChain();
                filterChain.fireExceptionCaught(e);
                wakeup();
            } else {
                ExceptionMonitor.getInstance().exceptionCaught(e);
                try {
                    destroy(session);

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.