From fd71e3600f689413e66ebc932a7b71fae52b9712 Mon Sep 17 00:00:00 2001
From: Pawel Piech <pawel.piech@windriver.com>
Date: Tue, 26 Feb 2008 21:19:09 +0000
Subject: [PATCH] [220446] Converted request monitor excercises to use the
 request monitor.

---
 .../build_preprocess.xml                      | 27 ++++---
 .../dsf/requestmonitor/Async2Plus2.java       |  4 +
 .../dsf/requestmonitor/AsyncHelloWorld.java   | 30 ++++----
 .../dsf/requestmonitor/AsyncQuicksort.java    | 75 ++++++++++---------
 4 files changed, 73 insertions(+), 63 deletions(-)
 rename plugins/org.eclipse.dd.examples.dsf/{src => src_preprocess}/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java (93%)
 rename plugins/org.eclipse.dd.examples.dsf/{src => src_preprocess}/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java (62%)

diff --git a/plugins/org.eclipse.dd.examples.dsf/build_preprocess.xml b/plugins/org.eclipse.dd.examples.dsf/build_preprocess.xml
index eec661b4c5a..8805fb7203c 100644
--- a/plugins/org.eclipse.dd.examples.dsf/build_preprocess.xml
+++ b/plugins/org.eclipse.dd.examples.dsf/build_preprocess.xml
@@ -8,24 +8,25 @@
  
  	 Contributors:
     	 IBM Corporation - initial API and implementation
+         Wind River Systems - adopted to use with DSF
 
      EclipseCon    
-     Debug Tutorial Exercises
+     DSF Tutorial Exercises
      ====================================================================== -->
 <project name="EclipseCon" default="generateAll">
 	<description>
-            Debug Tutorial Exercises
+            DSF Tutorial Exercises
     </description>
 
-	<taskdef name="preprocess" classname="org.eclipse.dd.examples.ant.tasks.PreProcessor" classpath="../bin" />
-	<property name="workspace" location="c:\eclipse-dev\dev-3.4" />
+	<taskdef name="preprocess" classname="org.eclipse.dd.examples.ant.tasks.PreProcessor" classpath="bin" />
+	<property name="$workspace" location="c:\eclipse-dev\dev-3.4" />
 	<property name="srcBase" location="${workspace}/org.eclipse.dd.examples.dsf/src_preprocess" />
 	<property name="destBase" location="${workspace}/org.eclipse.dd.examples.dsf/src" />
 
 	<!-- ================================= 
           target: generateAll              
          ================================= -->
-	<target name="generateAll" description="--> Debug Tutorial Exercises">
+	<target name="generateAll" description="--> DSF Tutorial Exercises">
 		
     <!-- = = = = = = = = = = = = = = = = =
           macrodef: process          
@@ -34,17 +35,19 @@
         <attribute name="packagedir"/>
     	<attribute name="symbols"/>
         <sequential>
-            <delete dir="@{destBase}/${packagedir}/excercise"/>
-            <delete dir="@{destBase}/${packagedir}/answer"/>
-            <mkdir dir="@{destBase}/${packagedir}/excercise"/>
-            <mkdir dir="@{destBase}/${packagedir}/answer"/>
-        	<preprocess destdir="@{destBase}/${packagedir}/excercise" symbols="@{symbols}">
-        		<fileset dir="@{destBase}/${packagedir}"/>
+            <delete dir="src/@{packagedir}"/>
+            <mkdir dir="src/@{packagedir}"/>
+            <mkdir dir="src/@{packagedir}/answers"/>
+        	<preprocess destdir="src/@{packagedir}" symbols="excercises">
+        		<fileset dir="src_preprocess/@{packagedir}"/>
+        	</preprocess>
+        	<preprocess destdir="src/@{packagedir}/answers" symbols="answers">
+        		<fileset dir="src_preprocess/@{packagedir}"/>
         	</preprocess>
         </sequential>
     </macrodef>
 
-	<process packagedir="${srcBase}/org/eclipse/dd/examples/dsf/requestmonitor" symbols="request_monitors_ex1"/>
+	<process packagedir="org/eclipse/dd/examples/dsf/requestmonitor" symbols="answers"/>
 	</target>
 
 </project>
diff --git a/plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java
similarity index 93%
rename from plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java
rename to plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java
index 6fa56cb19c4..e7146eb2ae5 100644
--- a/plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java
+++ b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/Async2Plus2.java
@@ -8,7 +8,11 @@
  * Contributors:
  *     Wind River Systems - initial API and implementation
  *******************************************************************************/
+//#ifdef excercises
 package org.eclipse.dd.examples.dsf.requestmonitor;
+//#else
+//#package org.eclipse.dd.examples.dsf.requestmonitor.answers;
+//#endif
 
 import java.util.concurrent.Executor;
 
diff --git a/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncHelloWorld.java b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncHelloWorld.java
index b7c10afb29e..b2272f97533 100644
--- a/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncHelloWorld.java
+++ b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncHelloWorld.java
@@ -8,10 +8,10 @@
  * Contributors:
  *     Wind River Systems - initial API and implementation
  *******************************************************************************/
-//#ifdef request_monitors_ex1
-//#package org.eclipse.dd.examples.dsf.requestmonitor.excercise;
+//#ifdef excercises
+package org.eclipse.dd.examples.dsf.requestmonitor;
 //#else
-package org.eclipse.dd.examples.dsf.requestmonitor.answer;
+//#package org.eclipse.dd.examples.dsf.requestmonitor.answers;
 //#endif
 
 import java.util.concurrent.Executor;
@@ -37,23 +37,21 @@ public class AsyncHelloWorld {
 
     static void asyncHelloWorld(RequestMonitor rm) {
         System.out.println("Hello world");
-        //#ifdef request_monitors_ex1
-//#     // TODO: Request Monitors Exercise 1 - Call a second async. 
-//#     // "Hello world 2" method.   
-//#     rm.done();
+        //#ifdef excercises
+        // TODO Exercise 1: - Call the second async. "Hello world 2" method.   
+        rm.done();
         //#else
-        RequestMonitor rm2 = new RequestMonitor(ImmediateExecutor.getInstance(), rm);
-        asyncHelloWorld2(rm2);
+//#        RequestMonitor rm2 = new RequestMonitor(ImmediateExecutor.getInstance(), rm);
+//#        asyncHelloWorld2(rm2);
         //#endif
     }
     
-    //#ifdef request_monitors_ex1
-//# // TODO: Request Monitors Exercise 1 - Add a second async.
-//# // "Hello world 2" method.   
+    //#ifdef excercises
+    // TODO: Exercise 1 - Add a second async. "Hello world 2" method.   
     //#else
-    static void asyncHelloWorld2(RequestMonitor rm) {
-        System.out.println("Hello world 2");
-        rm.done();
-    }
+//#    static void asyncHelloWorld2(RequestMonitor rm) {
+//#        System.out.println("Hello world 2");
+//#        rm.done();
+//#    }
     //#endif
 }
diff --git a/plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java
similarity index 62%
rename from plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java
rename to plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java
index df18735f3ff..21f861e6a87 100644
--- a/plugins/org.eclipse.dd.examples.dsf/src/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java
+++ b/plugins/org.eclipse.dd.examples.dsf/src_preprocess/org/eclipse/dd/examples/dsf/requestmonitor/AsyncQuicksort.java
@@ -8,13 +8,19 @@
  * Contributors:
  *     Wind River Systems - initial API and implementation
  *******************************************************************************/
+//#ifdef excercises
 package org.eclipse.dd.examples.dsf.requestmonitor;
+//#else
+//#package org.eclipse.dd.examples.dsf.requestmonitor.answers;
+//#endif
 
 import java.util.Arrays;
 import java.util.concurrent.Executor;
 
 import org.eclipse.dd.dsf.concurrent.CountingRequestMonitor;
+//#ifdef answers
 import org.eclipse.dd.dsf.concurrent.DataRequestMonitor;
+//#endif
 import org.eclipse.dd.dsf.concurrent.ImmediateExecutor;
 import org.eclipse.dd.dsf.concurrent.RequestMonitor;
 
@@ -45,43 +51,42 @@ public class AsyncQuicksort {
     {
         if (right > left) {
             int pivot = left;
-            //#ifdef request_monitors_ex2
-//#         // TODO: Request Monitors Exercise 2 - Convert partition to an async. method.
-//#         int newPivot = partition(array, left, right, pivot);
-//#         int newPivot = getData();
-//#         printArray(array, left, right, newPivot);
-//#            
-//#         CountingRequestMonitor countingRm = new CountingRequestMonitor(fgExecutor, rm);
-//#         asyncQuicksort(array, left, newPivot - 1, countingRm);
-//#         asyncQuicksort(array, newPivot + 1, right, countingRm);
-//#         countingRm.setDoneCount(2);
-            //#else
-            asyncPartition(
-                array, left, right, pivot, 
-                new DataRequestMonitor<Integer>(fgExecutor, rm) {
-                    @Override
-                    protected void handleCompleted() {
-                        int newPivot = getData();
-                        printArray(array, left, right, newPivot);
-                        
-                        CountingRequestMonitor countingRm = new CountingRequestMonitor(fgExecutor, rm);
-                        asyncQuicksort(array, left, newPivot - 1, countingRm);
-                        asyncQuicksort(array, newPivot + 1, right, countingRm);
-                        countingRm.setDoneCount(2);
-                    }
-            });
-            //#endif
+         //#ifdef excercises
+         // TODO: Request Monitors Exercise 2 - Convert partition to an async. method.
+         int newPivot = partition(array, left, right, pivot);
+         printArray(array, left, right, newPivot);
+            
+         CountingRequestMonitor countingRm = new CountingRequestMonitor(fgExecutor, rm);
+         asyncQuicksort(array, left, newPivot - 1, countingRm);
+         asyncQuicksort(array, newPivot + 1, right, countingRm);
+         countingRm.setDoneCount(2);
+         //#else
+//#            asyncPartition(
+//#                array, left, right, pivot, 
+//#                new DataRequestMonitor<Integer>(fgExecutor, rm) {
+//#                    @Override
+//#                    protected void handleCompleted() {
+//#                        int newPivot = getData();
+//#                        printArray(array, left, right, newPivot);
+//#                       
+//#                        CountingRequestMonitor countingRm = new CountingRequestMonitor(fgExecutor, rm);
+//#                        asyncQuicksort(array, left, newPivot - 1, countingRm);
+//#                        asyncQuicksort(array, newPivot + 1, right, countingRm);
+//#                        countingRm.setDoneCount(2);
+//#                    }
+//#            });
+        //#endif
 
         } else {
             rm.done();
         }
     }
     
-    //#ifdef request_monitors_ex2
-//# // TODO: Request Monitors Exercise 2 - Convert partition to an async. method.
-//# static int partition(int[] array, int left, int right, int pivot)
+    //#ifdef excercises
+    // TODO Exercise 2 - Convert partition to an asynchronous method.
+    static int partition(int[] array, int left, int right, int pivot)
     //#else
-    static void asyncPartition(int[] array, int left, int right, int pivot, DataRequestMonitor<Integer> rm)
+//#    static void asyncPartition(int[] array, int left, int right, int pivot, DataRequestMonitor<Integer> rm)
     //#endif
     {
         int pivotValue = array[pivot];
@@ -99,12 +104,12 @@ public class AsyncQuicksort {
         array[right] = array[store];
         array[store] = pivotValue;
         
-        //#ifdef request_monitors_ex2
-//#     // TODO: Request Monitors Exercise 2 - Convert partition to an async. method.
-//#     return store;
+        //#ifdef excercises
+        // TODO: Request Monitors Exercise 2 - Convert partition to an async. method.
+        return store;
         //#else
-        rm.setData(store);
-        rm.done();
+//#        rm.setData(store);
+//#        rm.done();
         //#endif
     }