Package org.jboss.netty.buffer

Examples of org.jboss.netty.buffer.BigEndianHeapChannelBuffer.clear()

201
202
203
204
205
206
207
208
209
210
211
      protected void channelIdle(ChannelHandlerContext ctx, IdleState state,
            long lastActivityTimeMillis) throws Exception {

         BigEndianHeapChannelBuffer buf = new BigEndianHeapChannelBuffer(provider.encodeEchoRequest());
         channel.write(buf);
         buf.clear();
        
         super.channelIdle(ctx, state, lastActivityTimeMillis);
      }
     
      public ChannelHandler(Timer timer, int readerIdleTimeSeconds,
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
         case STARTED:
            builder = new OFMessageBuilder(in);
            log.info("WARP OUT: HELLO");
            BigEndianHeapChannelBuffer x = new BigEndianHeapChannelBuffer(provider.getHello(new ByteArrayOutputStream()).toByteArray());
            e.getChannel().write(x);
            x.clear();
            state = State.CONNECTED;
            log.info("OUTGOING Message: FEATURES_REQUEST");
            BigEndianHeapChannelBuffer y = new BigEndianHeapChannelBuffer(provider.getSwitchFeaturesRequest(new ByteArrayOutputStream()).toByteArray());
            e.getChannel().write(y);
            state = State.HANDSHAKED;
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
            }
            }
            log.info("WARP OUT: SET_CONFIG");
            BigEndianHeapChannelBuffer z = new BigEndianHeapChannelBuffer(provider.getSetSwitchConfig(new ByteArrayOutputStream()).toByteArray());
            e.getChannel().write(z);
            z.clear();
            log.info("WARP OUT: GET_CONFIG_REQUEST");
            BigEndianHeapChannelBuffer a = new BigEndianHeapChannelBuffer(provider.getSwitchConfigRequest(new ByteArrayOutputStream()).toByteArray());
            e.getChannel().write(a);
            state = State.CONFIG_READY;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.