1 //
2 // ========================================================================
3 // Copyright (c) 1995-2013 Mort Bay Consulting Pty. Ltd.
4 // ------------------------------------------------------------------------
5 // All rights reserved. This program and the accompanying materials
6 // are made available under the terms of the Eclipse Public License v1.0
7 // and Apache License v2.0 which accompanies this distribution.
8 //
9 // The Eclipse Public License is available at
10 // http://www.eclipse.org/legal/epl-v10.html
11 //
12 // The Apache License v2.0 is available at
13 // http://www.opensource.org/licenses/apache2.0.php
14 //
15 // You may elect to redistribute this code under either of these licenses.
16 // ========================================================================
17 //
18
19 package org.eclipse.jetty.spdy.parser;
20
21 import java.nio.ByteBuffer;
22
23 public class UnknownControlFrameBodyParser extends ControlFrameBodyParser
24 {
25 private final ControlFrameParser controlFrameParser;
26 private State state = State.BODY;
27 private int remaining;
28
29 public UnknownControlFrameBodyParser(ControlFrameParser controlFrameParser)
30 {
31 this.controlFrameParser = controlFrameParser;
32 }
33
34 @Override
35 public boolean parse(ByteBuffer buffer)
36 {
37 switch (state)
38 {
39 case BODY:
40 {
41 remaining = controlFrameParser.getLength();
42 state = State.CONSUME;
43 // Fall down
44 }
45 case CONSUME:
46 {
47 int consume = Math.min(remaining, buffer.remaining());
48 buffer.position(buffer.position() + consume);
49 remaining -= consume;
50 if (remaining > 0)
51 return false;
52 reset();
53 return true;
54 }
55 default:
56 {
57 throw new IllegalStateException();
58 }
59 }
60 }
61
62 private void reset()
63 {
64 state = State.BODY;
65 remaining = 0;
66 }
67
68 private enum State
69 {
70 BODY, CONSUME
71 }
72 }