View Javadoc

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.websocket.mux;
20  
21  import org.eclipse.jetty.websocket.common.OpCode;
22  import org.eclipse.jetty.websocket.common.WebSocketFrame;
23  import org.eclipse.jetty.websocket.common.frames.DataFrame;
24  
25  public class MuxedFrame extends DataFrame
26  {
27      private long channelId = -1;
28  
29      public MuxedFrame()
30      {
31          super(OpCode.BINARY);
32      }
33  
34      public MuxedFrame(MuxedFrame frame)
35      {
36          super(frame);
37          this.channelId = frame.channelId;
38      }
39  
40      public long getChannelId()
41      {
42          return channelId;
43      }
44  
45      @Override
46      public void reset()
47      {
48          super.reset();
49          this.channelId = -1;
50      }
51  
52      public void setChannelId(long channelId)
53      {
54          this.channelId = channelId;
55      }
56  
57      @Override
58      public String toString()
59      {
60          StringBuilder b = new StringBuilder();
61          b.append(OpCode.name(getOpCode()));
62          b.append('[');
63          b.append("channel=").append(channelId);
64          b.append(",len=").append(getPayloadLength());
65          b.append(",fin=").append(isFin());
66          b.append(",rsv=");
67          b.append(isRsv1()?'1':'.');
68          b.append(isRsv2()?'1':'.');
69          b.append(isRsv3()?'1':'.');
70          b.append(']');
71          return b.toString();
72      }
73  
74      public void setOp(byte opcode)
75      {
76          // TODO Auto-generated method stub
77          
78      }
79  }