Format with the blanks.

dota17 · dota17 · commit b907661dacda · 2020-07-22T16:29:33.000+08:00
diff --git a/src/main/java/org/java_websocket/extensions/permessage_deflate/PerMessageDeflateExtension.java b/src/main/java/org/java_websocket/extensions/permessage_deflate/PerMessageDeflateExtension.java
@@ -65,8 +65,7 @@ public boolean isServerNoContextTakeover()
      *
      * @param serverNoContextTakeover
      */
-    public void setServerNoContextTakeover(boolean serverNoContextTakeover)
-    {
+    public void setServerNoContextTakeover(boolean serverNoContextTakeover) {
         this.serverNoContextTakeover = serverNoContextTakeover;
     }
 
@@ -83,8 +82,7 @@ public boolean isClientNoContextTakeover()
      *
      * @param clientNoContextTakeover
      */
-    public void setClientNoContextTakeover(boolean clientNoContextTakeover)
-    {
+    public void setClientNoContextTakeover(boolean clientNoContextTakeover) {
         this.clientNoContextTakeover = clientNoContextTakeover;
     }
 
@@ -98,11 +96,11 @@ public void setClientNoContextTakeover(boolean clientNoContextTakeover)
     @Override
     public void decodeFrame(Framedata inputFrame) throws InvalidDataException {
         // Only DataFrames can be decompressed.
-        if(!(inputFrame instanceof DataFrame))
+        if (!(inputFrame instanceof DataFrame))
             return;
 
         // RSV1 bit must be set only for the first frame.
-        if(inputFrame.getOpcode() == Opcode.CONTINUOUS && inputFrame.isRSV1())
+        if (inputFrame.getOpcode() == Opcode.CONTINUOUS && inputFrame.isRSV1())
             throw new InvalidDataException(CloseFrame.POLICY_VALIDATION, "RSV1 bit can only be set for the first frame.");
 
         // Decompressed output buffer.
@@ -118,23 +116,23 @@ We can check the getRemaining() method to see whether the data we supplied has b
                 And if not, we just reset the inflater and decompress again.
                 Note that this behavior doesn't occur if the message is "first compressed and then fragmented".
              */
-            if(inflater.getRemaining() > 0){
+            if (inflater.getRemaining() > 0) {
                 inflater = new Inflater(true);
                 decompress(inputFrame.getPayloadData().array(), output);
             }
 
-            if(inputFrame.isFin()) {
+            if (inputFrame.isFin()) {
                 decompress(TAIL_BYTES, output);
                 // If context takeover is disabled, inflater can be reset.
-                if(clientNoContextTakeover)
+                if (clientNoContextTakeover)
                     inflater = new Inflater(true);
             }
         } catch (DataFormatException e) {
             throw new InvalidDataException(CloseFrame.POLICY_VALIDATION, e.getMessage());
         }
 
         // RSV1 bit must be cleared after decoding, so that other extensions don't throw an exception.
-        if(inputFrame.isRSV1())
+        if (inputFrame.isRSV1())
             ((DataFrame) inputFrame).setRSV1(false);
 
         // Set frames payload to the new decompressed data.
@@ -147,24 +145,24 @@ We can check the getRemaining() method to see whether the data we supplied has b
      * @param outputBuffer the output stream
      * @throws DataFormatException
      */
-    private void decompress(byte[] data, ByteArrayOutputStream outputBuffer) throws DataFormatException{
+    private void decompress(byte[] data, ByteArrayOutputStream outputBuffer) throws DataFormatException {
         inflater.setInput(data);
         byte[] buffer = new byte[BUFFER_SIZE];
 
         int bytesInflated;
-        while((bytesInflated = inflater.inflate(buffer)) > 0){
+        while ((bytesInflated = inflater.inflate(buffer)) > 0) {
             outputBuffer.write(buffer, 0, bytesInflated);
         }
     }
 
     @Override
     public void encodeFrame(Framedata inputFrame) {
         // Only DataFrames can be decompressed.
-        if(!(inputFrame instanceof DataFrame))
+        if (!(inputFrame instanceof DataFrame))
             return;
 
         // Only the first frame's RSV1 must be set.
-        if(!(inputFrame instanceof ContinuousFrame))
+        if (!(inputFrame instanceof ContinuousFrame))
             ((DataFrame) inputFrame).setRSV1(true);
 
         deflater.setInput(inputFrame.getPayloadData().array());
@@ -173,7 +171,7 @@ public void encodeFrame(Framedata inputFrame) {
         // Temporary buffer to hold compressed output.
         byte[] buffer = new byte[1024];
         int bytesCompressed;
-        while((bytesCompressed = deflater.deflate(buffer, 0, buffer.length, Deflater.SYNC_FLUSH)) > 0) {
+        while ((bytesCompressed = deflater.deflate(buffer, 0, buffer.length, Deflater.SYNC_FLUSH)) > 0) {
             output.write(buffer, 0, bytesCompressed);
         }
 
@@ -186,11 +184,11 @@ public void encodeFrame(Framedata inputFrame) {
             To simulate removal, we just pass 4 bytes less to the new payload
                 if the frame is final and outputBytes ends with 0x00 0x00 0xff 0xff.
         */
-        if(inputFrame.isFin()) {
-            if(endsWithTail(outputBytes))
+        if (inputFrame.isFin()) {
+            if (endsWithTail(outputBytes))
                 outputLength -= TAIL_BYTES.length;
 
-            if(serverNoContextTakeover) {
+            if (serverNoContextTakeover) {
                 deflater.end();
                 deflater = new Deflater(Deflater.DEFAULT_COMPRESSION, true);
             }
@@ -205,13 +203,13 @@ public void encodeFrame(Framedata inputFrame) {
      * @param data the bytes of data
      * @return true if the data is OK
      */
-    private boolean endsWithTail(byte[] data){
-        if(data.length < 4)
+    private boolean endsWithTail(byte[] data) {
+        if (data.length < 4)
             return false;
 
         int length = data.length;
-        for(int i = 0; i < TAIL_BYTES.length; i++){
-            if(TAIL_BYTES[i] != data[length - TAIL_BYTES.length + i])
+        for (int i = 0; i < TAIL_BYTES.length; i++) {
+            if (TAIL_BYTES[i] != data[length - TAIL_BYTES.length + i])
                 return false;
         }
 
@@ -221,15 +219,15 @@ private boolean endsWithTail(byte[] data){
     @Override
     public boolean acceptProvidedExtensionAsServer(String inputExtension) {
         String[] requestedExtensions = inputExtension.split(",");
-        for(String extension : requestedExtensions) {
+        for (String extension : requestedExtensions) {
             ExtensionRequestData extensionData = ExtensionRequestData.parseExtensionRequest(extension);
-            if(!EXTENSION_REGISTERED_NAME.equalsIgnoreCase(extensionData.getExtensionName()))
+            if (!EXTENSION_REGISTERED_NAME.equalsIgnoreCase(extensionData.getExtensionName()))
                 continue;
 
             // Holds parameters that peer client has sent.
             Map<String, String> headers = extensionData.getExtensionParameters();
             requestedParameters.putAll(headers);
-            if(requestedParameters.containsKey(CLIENT_NO_CONTEXT_TAKEOVER))
+            if (requestedParameters.containsKey(CLIENT_NO_CONTEXT_TAKEOVER))
                 clientNoContextTakeover = true;
 
             return true;
@@ -241,9 +239,9 @@ public boolean acceptProvidedExtensionAsServer(String inputExtension) {
     @Override
     public boolean acceptProvidedExtensionAsClient(String inputExtension) {
         String[] requestedExtensions = inputExtension.split(",");
-        for(String extension : requestedExtensions) {
+        for (String extension : requestedExtensions) {
             ExtensionRequestData extensionData = ExtensionRequestData.parseExtensionRequest(extension);
-            if(!EXTENSION_REGISTERED_NAME.equalsIgnoreCase(extensionData.getExtensionName()))
+            if (!EXTENSION_REGISTERED_NAME.equalsIgnoreCase(extensionData.getExtensionName()))
                 continue;
 
             // Holds parameters that are sent by the server, as a response to our initial extension request.
@@ -281,9 +279,9 @@ public IExtension copyInstance() {
      */
     @Override
     public void isFrameValid(Framedata inputFrame) throws InvalidDataException {
-        if((inputFrame instanceof TextFrame || inputFrame instanceof BinaryFrame) && !inputFrame.isRSV1())
+        if ((inputFrame instanceof TextFrame || inputFrame instanceof BinaryFrame) && !inputFrame.isRSV1())
             throw new InvalidFrameException("RSV1 bit must be set for DataFrames.");
-        if((inputFrame instanceof ContinuousFrame) && (inputFrame.isRSV1() || inputFrame.isRSV2() || inputFrame.isRSV3()))
+        if ((inputFrame instanceof ContinuousFrame) && (inputFrame.isRSV1() || inputFrame.isRSV2() || inputFrame.isRSV3()))
             throw new InvalidFrameException( "bad rsv RSV1: " + inputFrame.isRSV1() + " RSV2: " + inputFrame.isRSV2() + " RSV3: " + inputFrame.isRSV3() );
         super.isFrameValid(inputFrame);
     }
