WW-4900 Fixes BackgroundProcessTest via synchronization

Author: yasserzamani

core/src/test/java/org/apache/struts2/interceptor/BackgroundProcessTest.java

@@ -18,6 +18,7 @@
  */
 package org.apache.struts2.interceptor;
 
+import com.mockobjects.servlet.MockHttpServletRequest;
 import com.opensymphony.xwork2.ActionContext;
 import com.opensymphony.xwork2.mock.MockActionInvocation;
 import org.apache.struts2.StrutsInternalTestCase;
@@ -26,28 +27,45 @@
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
+import java.util.concurrent.Callable;
+import java.util.concurrent.Semaphore;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Test case for BackgroundProcessTest.
  */
 public class BackgroundProcessTest extends StrutsInternalTestCase {
 
     public void testSerializeDeserialize() throws Exception {
-        MockActionInvocation invocation = new MockActionInvocation();
-        invocation.setResultCode("BackgroundProcessTest.testSerializeDeserialize");
+        final NotSerializableException expectedException = new NotSerializableException(new MockHttpServletRequest());
+        final Semaphore lock = new Semaphore(1);
+        lock.acquire();
+        MockActionInvocationWithActionInvoker invocation = new MockActionInvocationWithActionInvoker(new Callable<String>() {
+            @Override
+            public String call() throws Exception {
+                lock.release();
+                throw expectedException;
+            }
+        });
         invocation.setInvocationContext(ActionContext.getContext());
 
         BackgroundProcess bp = new BackgroundProcess("BackgroundProcessTest.testSerializeDeserialize", invocation
                 , Thread.MIN_PRIORITY);
+        if(!lock.tryAcquire(1500L, TimeUnit.MILLISECONDS)) {
+            lock.release();
+            fail("background thread did not release lock on timeout");
+        }
+        lock.release();
 
-        bp.exception = new Exception();
+        bp.result = "BackgroundProcessTest.testSerializeDeserialize";
         bp.done = true;
+        Thread.sleep(1000);//give a chance to background thread to set exception
+        assertEquals(expectedException, bp.exception);
 
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         ObjectOutputStream oos = new ObjectOutputStream(baos);
         oos.writeObject(bp);
         oos.close();
-        assertTrue("should have serialized data", baos.size() > 0);
         byte b[] = baos.toByteArray();
         baos.close();
 
@@ -62,4 +80,25 @@ public void testSerializeDeserialize() throws Exception {
         assertEquals(bp.result, deserializedBp.result);
         assertEquals(bp.done, deserializedBp.done);
     }
+
+
+    private class MockActionInvocationWithActionInvoker extends MockActionInvocation {
+        private Callable<String> actionInvoker;
+
+        MockActionInvocationWithActionInvoker(Callable<String> actionInvoker){
+            this.actionInvoker = actionInvoker;
+        }
+
+        @Override
+        public String invokeActionOnly() throws Exception {
+            return actionInvoker.call();
+        }
+    }
+
+    private class NotSerializableException extends Exception {
+        private MockHttpServletRequest notSerializableField;
+        NotSerializableException(MockHttpServletRequest notSerializableField) {
+            this.notSerializableField = notSerializableField;
+        }
+    }
 }