[teiid-commits] teiid SVN: r2008 - trunk/engine/src/main/java/org/teiid/dqp/internal/process.

[teiid-commits at lists.jboss.org]

Author: shawkins
Date: 2010-03-28 23:06:28 -0400 (Sun, 28 Mar 2010)
New Revision: 2008

Modified:
   trunk/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java
Log:
TEIID-1015 ensuring that suspend is called when the thread exits

Modified: trunk/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java
===================================================================
--- trunk/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java	2010-03-29 03:04:36 UTC (rev 2007)
+++ trunk/engine/src/main/java/org/teiid/dqp/internal/process/RequestWorkItem.java	2010-03-29 03:06:28 UTC (rev 2008)
@@ -224,7 +224,8 @@
         			this.processingException = new IllegalStateException("Request is already closed"); //$NON-NLS-1$
         		}
         		sendError();
-        	} 
+        	}
+        	suspend();
         }
     }
 
@@ -329,8 +330,6 @@
 	            } catch (XATransactionException e1) {
 	                LogManager.logWarning(LogConstants.CTX_DQP, e1, DQPPlugin.Util.getString("ProcessWorker.failed_rollback")); //$NON-NLS-1$           
 	            } 
-			} else {
-	        	suspend();
 			}
 		}