445446447448449450451452453454455
ByteBuffer buf = (ByteBuffer) req.getMessage(); if (buf.remaining() == 0) { // pop and fire event writeRequestQueue.poll(); buf.reset(); if (!buf.hasRemaining()) { session.increaseWrittenMessages(); }
468469470471472473474475476477478
key.interestOps(key.interestOps() & (~SelectionKey.OP_WRITE)); // pop and fire event writeRequestQueue.poll(); buf.reset(); if (!buf.hasRemaining()) { session.increaseWrittenMessages(); }
480481482483484485486487488489490
{ writeRequestQueue.pop(); } session.increaseWrittenWriteRequests(); buf.reset(); ( ( DatagramFilterChain ) session.getFilterChain() ).messageSent( session, req ); continue; } SelectionKey key = session.getSelectionKey();
516517518519520521522523524525526
writeRequestQueue.pop(); } session.increaseWrittenBytes( writtenBytes ); session.increaseWrittenWriteRequests(); buf.reset(); ( ( DatagramFilterChain ) session.getFilterChain() ).messageSent( session, req ); } } }
492493494495496497498499500501502
writeRequestQueue.pop(); } session.increaseWrittenWriteRequests(); buf.reset(); ( ( SocketFilterChain ) session.getFilterChain() ).messageSent( session, req ); continue; } int writtenBytes = ch.write( buf.buf() );
465466467468469470471472473474475
502503504505506507508509510511512
writeRequestQueue.pop(); } session.increaseWrittenMessages(); buf.reset(); session.getFilterChain().fireMessageSent( session, req ); continue; } if( key.isWritable() )
508509510511512513514515516517518
{ writeRequestQueue.pop(); } session.increaseWrittenMessages(); buf.reset(); ( ( DatagramFilterChain ) session.getFilterChain() ).fireMessageSent( session, req ); continue; } SelectionKey key = session.getSelectionKey();
550551552553554555556557558559560
writeRequestQueue.pop(); } session.increaseWrittenBytes( writtenBytes ); session.increaseWrittenMessages(); buf.reset(); session.getFilterChain().fireMessageSent( session, req ); } } }