Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
   *
   * Copyright 1997-2010 Oracle and/or its affiliates. All rights reserved.
   *
   * Oracle and Java are registered trademarks of Oracle and/or its affiliates.
   * Other names may be trademarks of their respective owners.
   *
   * The contents of this file are subject to the terms of either the GNU
  * General Public License Version 2 only ("GPL") or the Common
  * Development and Distribution License("CDDL") (collectively, the
  * "License"). You may not use this file except in compliance with the
  * License. You can obtain a copy of the License at
  * http://www.netbeans.org/cddl-gplv2.html
  * or nbbuild/licenses/CDDL-GPL-2-CP. See the License for the
  * specific language governing permissions and limitations under the
  * License.  When distributing the software, include this License Header
  * Notice in each file and include the License file at
  * nbbuild/licenses/CDDL-GPL-2-CP.  Oracle designates this
  * particular file as subject to the "Classpath" exception as provided
  * by Oracle in the GPL Version 2 section of the License file that
  * accompanied this code. If applicable, add the following below the
  * License Header, with the fields enclosed by brackets [] replaced by
  * your own identifying information:
  * "Portions Copyrighted [year] [name of copyright owner]"
  *
  * Contributor(s):
  * The Original Software is NetBeans. The Initial Developer of the Original
  * Software is Sun Microsystems, Inc. Portions Copyright 1997-2006 Sun
  * Microsystems, Inc. All Rights Reserved.
  *
  * If you wish your version of this file to be governed by only the CDDL
  * or only the GPL Version 2, indicate your decision by adding
  * "[Contributor] elects to include this software in this distribution
  * under the [CDDL or GPL Version 2] license." If you do not indicate a
  * single choice of license, a recipient has the option to distribute
  * your version of this file under either the CDDL, the GPL Version 2 or
  * to extend the choice of license to its licensees as provided above.
  * However, if you add GPL Version 2 code and therefore, elected the GPL
  * Version 2 license, then the option applies only if the new code is
  * made subject to such option by the copyright holder.
  */
 package org.netbeans.modules.netserver.websocket;
 
 
 

Author(s):
ads
 
 abstract class AbstractWSHandler7<T extends SocketFrameworkextends AbstractWSHandler<T> 
     implements WebSocketChanelHandler 
 {
 
     protected static final String SALT = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";     // NOI18N
     
    
    
FIN bit is set and opcode is text ( equals 1 )
 
     protected static final byte FIRST_BYTE_MESSAGE = Integer.valueOf("10000001",     // NOI18N
             2).byteValue();
    
    
FIN bit is set and opcode is close connection ( equals 8 )
 
     protected static final byte CLOSE_CONNECTION_BYTE = Integer.valueOf("10001000",     // NOI18N
             2).byteValue();
    
    
FIN bit is set and opcode is binary ( equals 2 )
 
     protected static final byte FIRST_BYTE_BINARY = Integer.valueOf("10000010",     // NOI18N
             2).byteValue();
 
     /*
      * Message max length which is marked in the message with 126 code in the 
      * "Extended payload length" section 
      */
     protected static final int LENGTH_LEVEL  = 0x10000;  
     
     AbstractWSHandler7(T t){
         supert );
          = new RandomhashCode() );
     }
     
     /* (non-Javadoc)
     * @see org.netbeans.modules.web.common.websocket.WebSocketChanelHandler#read(java.nio.ByteBuffer)
     */
    @Override
    public void readByteBuffer byteBuffer ) throws IOException {
        SocketChannel socketChannel = (SocketChannelgetKey().channel();
        while (true) {
            byteBuffer.clear();
            byteBuffer.limit(1);
            int size = socketChannel.read(byteBuffer);
            if (size == -1) {
                close();
                return;
            }
            else if (size == 0) {
                return;
            }
            byteBuffer.flip();
            byte leadingByte = byteBuffer.get();
            if (leadingByte == ) {
                // connection close
                close();
                return;
            }
            else if (leadingByte == 
                    || leadingByte == )
            {
                if (!readFinalFramebyteBuffersocketChannelleadingByte)){
                    return;
                }
                else {
                    continue;
                }
            }
            else {
                // TODO : handle frame sequence, ping frame
            }
        }
    }
    @Override
    public byte[] createTextFrameString message ) {
        byte[] data = message.getBytes( Charset.forName.));
        int length = data.length;
        byte[] lengthBytes;
        if ( length< 126){
            lengthBytes =new byte[]{ (byte)length };
        }
        else if (length < ){
            lengthBytes = new byte[]{126, (byte)(length>>8), (byte)(length&0xFF)};
        }
        else {
            lengthBytes = new byte[9];
            lengthBytes[0] = 127;
            forint i =8; i>=1; i-- ){
                lengthBytes[i]=(byte)(length & 0xFF);
                length = length >>8;
            }
        }
        int startBytesCount;
        if ( isClient() ){
            startBytesCount = 5;
            lengthBytes[0]=(byte)(lengthBytes[0]|0x80);
        }
        else {
            startBytesCount = 1;
            
        }
        byte[] result = new byte[data.length+lengthBytes.length+startBytesCount];
        result[0] = ;
        System.arraycopy(lengthBytes, 0, result, 1, lengthBytes.length);
        /*
         *  Don't fill mask at all. XOR with 0 mask doesn't change the value
         *  XXX: data could be masked 
         */
        System.arraycopydata, 0 , resultlengthBytes.length+startBytesCountdata.length);
        return result;
    }
    
    protected byte[] maskbyte[] maskedMessage , boolean hasMask) {
        if (hasMask) {
            byte[] result = new byte[maskedMessage.length - 4];
            for (int i = 4; i < maskedMessage.lengthi++) {
                byte unsignedMask = (byte) (maskedMessage[i % 4] & 0xFF);
                result[i - 4] = (byte) (unsignedMask ^ maskedMessage[i]);
            }
            return result;
        }
        else {
            return maskedMessage;
        }
    }
    
    protected String generateAcceptKey(String key ){
        StringBuilder builder = new StringBuilderkey );
        builder.append();
        try {
            return DatatypeConverter.printBase64Binary( MessageDigest.getInstance(
                    "SHA").digest(builder.toString().getBytes(  // NOI18N
                            Charset.forName(.))));
        }
        catch (NoSuchAlgorithmException e) {
            ..log(.null , e);
            return null;
        } 
    }
    
    /*
     * Method could be used in {@link #createTextFrame(String)} for setting 
     * mask ( currently trivial static mask is used ) instead of {@link #isClient()}
     * method usage and for 16 bit sec-websocket key in initial WS client request   
     * 
     */
    protected Random getRandom(){
        return ;
    }
    
    private boolean readFinalFrameByteBuffer byteBuffer,
            SocketChannel socketChannelbyte leadingBytethrows IOException
    {
        int frameType = leadingByte == ? 1:2;
        byteBuffer.clear();
        byteBuffer.limit(1);
        int size ;
        do {
            size = socketChannel.read(byteBuffer);
            if ( size==-1 ){
                close( );
                return false;
            }
        }
        whilesize ==0 && !isStopped());
        if ( isStopped() ){
            close();
            return false;
        }
        byteBuffer.flip();
        byte masknLength = byteBuffer.get();
        boolean hasMask =masknLength<0; 
        if ( !verifyMask(hasMask) ){
            close();
            return false;
        }
        int length = masknLength&0x7F;
        if ( length <126 ){
            return readData(byteBuffersocketChannelframeTypelengthhasMask );
        }
        else if ( length ==126 ){
            byteBuffer.clear();
            byteBuffer.limit(2);
            do {
                size = socketChannel.read(byteBuffer);
                if (  size==-1 ){
                    close( );
                    return false;
                }
            }
            while(byteBuffer.position()<byteBuffer.limit() && !isStopped());
            if ( isStopped() ){
                close();
                return false;
            }
            byteBuffer.flip();
            length = byteBuffer.getShort()&0xFFFF;
            return readData(byteBuffersocketChannelframeTypelengthhasMask );
        }
        else if ( length ==127 ){
            byteBuffer.clear();
            byteBuffer.limit(8);
            do {
                size = socketChannel.read(byteBuffer);
                if (  size==-1 ){
                    close( );
                    return false;
                }
            }
            while(byteBuffer.position()<byteBuffer.limit() && !isStopped());
            if ( isStopped() ){
                close();
                return false;
            }
            byteBuffer.flip();
            long longLength = byteBuffer.getLong();
            return readData(byteBuffersocketChannelframeTypelongLength , 
                    hasMask);
        }
        return true;
    }
    private boolean readDataByteBuffer byteBuffer,
            SocketChannel socketChannelint frameTypeint length , 
            boolean hasMaskthrows IOException
    {
        byteBuffer.clear();
        int frameSize = hasMask?length +4:length;
        if ( frameSize <0 ){
            readData(byteBuffersocketChannelframeType, (long)lengthhasMask );
        }
        byte[] result = readDatabyteBuffersocketChannelframeSize);
        if ( result == null ){
            return false;
        }
        readDelegate(maskresulthasMask), frameType);
        
        return true;
    }
    private byte[] readDataByteBuffer byteBuffer,
            SocketChannel socketChannelint size ) throws IOException
    {
        int redBytes =0;
        byte[] result = new bytesize ];
        int fullBufferCount =0;
        if (size < byteBuffer.capacity()) {
            byteBuffer.limit(size);
        }
        whileredBytes <size && !isStopped()){
            int red = socketChannel.readbyteBuffer );
            if ( red == -1){
                close();
                return null;
            }
            if ( red ==0 ){
                continue;
            }
            redBytes += red;
            if (redBytes%byteBuffer.capacity() == 0){
                byteBuffer.flip();
                byteBuffer.getresult , fullBufferCount*byteBuffer.capacity(), 
                        byteBuffer.limit());
                fullBufferCount++;
                byteBuffer.clear();
                int resultRed = fullBufferCount*byteBuffer.capacity();
                if ( sizeresultRed<=byteBuffer.capacity()){
                    byteBuffer.limitsize -resultRed);
                }
            }
        }
        if ( isStopped() ){
            close();
            return null;
        }
        byteBuffer.flip();
        int savedBytes = byteBuffer.capacity()*fullBufferCount;
        byteBuffer.getresult , savedBytessize - savedBytes);
        return result;
    }
    
    private boolean readData(ByteBuffer byteBuffer,
            SocketChannel socketChannelint frameTypelong length , 
            boolean hasMask ) throws IOException
    {
        int shift = (int)(length>>32);
        if ( shift != 0 ){
            throw new RuntimeException("Data frame is too big. " +
                    "Cannot handle it. Implementation should be rewritten.");
        }
        else {
            readData(byteBuffersocketChannelframeType, (int)length , hasMask );
        }
        return true;
    }
    
    
XXX: method could be changed to method which generate random mask. In the latter case this mask should be applied on data in createTextFrame method

Returns:
    protected abstract boolean isClient();
    
    protected abstract void readDelegatebyte[] bytes , int dataType ) ;
    
    protected abstract boolean verifyMaskboolean hasMask ) throws IOException ;
    
    private Random myRandom;
    
New to GrepCode? Check out our FAQ X