commit a39cb61f9226909f13270569e8b31f31596fd34b

Author: Iyappan Srinivasan <iyappans@yahoo-inc.com>
Date:   Fri Jul 23 06:36:26 2010 +0000

    MAPREDUCE-1934 https://issues.apache.org/jira/secure/attachment/12449227/DistributedCacheTiming.patch


git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.20-security-patches@1077583 13f79535-47bb-0310-9956-ffa450edef68

src/test/system/java/org/apache/hadoop/mapred/TestDistributedCacheModifiedFile.java

@@ -98,10 +98,12 @@ public class TestDistributedCacheModifiedFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
     //Waiting for 5 seconds to make sure tasktrackers are ready 
     Thread.sleep(5000);
@@ -116,10 +118,12 @@ public class TestDistributedCacheModifiedFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
   }
 

src/test/system/java/org/apache/hadoop/mapred/TestDistributedCachePrivateFile.java

@@ -85,10 +85,12 @@ public class TestDistributedCachePrivateFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
 
     String input = "This will be the content of\n" + "distributed cache\n";
@@ -106,10 +108,12 @@ public class TestDistributedCachePrivateFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
   }
 

src/test/system/java/org/apache/hadoop/mapred/TestDistributedCacheUnModifiedFile.java

@@ -97,10 +97,12 @@ public class TestDistributedCacheUnModifiedFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
    
     //Waiting for 5 seconds to make sure tasktrackers are ready
@@ -121,10 +123,12 @@ public class TestDistributedCacheUnModifiedFile {
     //Stopping all TTs
     for (TTClient tt : tts) {
       tt.kill();
+      tt.waitForTTStop();
     }
     //Starting all TTs
     for (TTClient tt : tts) {
       tt.start();
+      tt.waitForTTStart();
     }
   }