From b810ce6535d22adbabf667b785c473729157c964 Mon Sep 17 00:00:00 2001
From: Joakim Erdfelt <joakim.erdfelt@gmail.com>
Date: Fri, 1 Feb 2013 09:20:24 -0700
Subject: [PATCH] Adding synchronize for multi-threaded write concerns

---
 .../common/extensions/compress/FrameCompressionExtension.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/FrameCompressionExtension.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/FrameCompressionExtension.java
index 3a184cbe339..a548f20782a 100644
--- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/FrameCompressionExtension.java
+++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/FrameCompressionExtension.java
@@ -36,7 +36,7 @@ public class FrameCompressionExtension extends AbstractExtension
     private CompressionMethod method = new DeflateCompressionMethod();
 
     @Override
-    public void incomingFrame(Frame frame)
+    public synchronized void incomingFrame(Frame frame)
     {
         if (frame.getType().isControl() || !frame.isRsv1())
         {
@@ -84,7 +84,7 @@ public class FrameCompressionExtension extends AbstractExtension
     }
 
     @Override
-    public void outgoingFrame(Frame frame, WriteCallback callback)
+    public synchronized void outgoingFrame(Frame frame, WriteCallback callback)
     {
         if (frame.getType().isControl())
         {