Examples of org.apache.mina.common.ByteBuffer.reset()

org.apache.mina.common.ByteBuffer.reset()
@see java.nio.Buffer#reset()

                ByteBuffer buf = (ByteBuffer) req.getMessage();
                if (buf.remaining() == 0) {
                    // pop and fire event
                    writeRequestQueue.poll();
    
                    buf.reset();
                    
                    if (!buf.hasRemaining()) {
                        session.increaseWrittenMessages();
                    }
                    session.getFilterChain().fireMessageSent(session, req);

View Full Code Here

                    return false;
                } else {
                    // pop and fire event
                    writeRequestQueue.poll();
    
                    buf.reset();
                    
                    if (!buf.hasRemaining()) {
                        session.increaseWrittenMessages();
                    }

View Full Code Here


                ByteBuffer buf = (ByteBuffer) req.getMessage();
                if (buf.remaining() == 0) {
                    writeRequestQueue.poll();


                    buf.reset();
                    
                    if (!buf.hasRemaining()) {
                        session.increaseWrittenMessages();
                    }

View Full Code Here

                ByteBuffer buf = (ByteBuffer) req.getMessage();
                if (buf.remaining() == 0) {
                    // pop and fire event
                    writeRequestQueue.poll();
        
                    buf.reset();
                    
                    if (!buf.hasRemaining()) {
                        session.increaseWrittenMessages();
                    }

View Full Code Here

                    key.interestOps(key.interestOps() & (~SelectionKey.OP_WRITE));
    
                    // pop and fire event
                    writeRequestQueue.poll();
    
                    buf.reset();
                    
                    if (!buf.hasRemaining()) {
                        session.increaseWrittenMessages();
                    }

View Full Code Here

                    writeRequestQueue.pop();
                }


                session.increaseWrittenMessages();


                buf.reset();
                session.getFilterChain().fireMessageSent( session, req );
                continue;
            }


            int writtenBytes = ch.write( buf.buf() );

View Full Code Here

                {
                    writeRequestQueue.pop();
                }


                session.increaseWrittenMessages();
                buf.reset();
                session.getFilterChain().fireMessageSent( session, req );
                continue;
            }


            SelectionKey key = session.getSelectionKey();

View Full Code Here

                    writeRequestQueue.pop();
                }


                session.increaseWrittenBytes( writtenBytes );
                session.increaseWrittenMessages();
                buf.reset();
                session.getFilterChain().fireMessageSent( session, req );
            }
        }
    }

View Full Code Here

                {
                    writeRequestQueue.pop();
                }


                session.increaseWrittenMessages();
                buf.reset();
                ( ( DatagramFilterChain ) session.getFilterChain() ).fireMessageSent( session, req );
                continue;
            }


            SelectionKey key = session.getSelectionKey();

View Full Code Here

                    writeRequestQueue.pop();
                }


                session.increaseWrittenBytes( writtenBytes );
                session.increaseWrittenMessages();
                buf.reset();
                session.getFilterChain().fireMessageSent( session, req );
            }
        }
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.