---

Ajay Kannan · Ajay Kannan · commit d9f2176cfead · 2015-10-23T10:41:39.000-07:00
yaml --- r: 2313 b: refs/heads/update-datastore c: 494511c h: refs/heads/master i: 2311: d44dea5
diff --git a/[refs] b/[refs]
@@ -5,7 +5,7 @@ refs/heads/gh-pages: 4e0561bb4504bf647db669a14417b2b2c87ba45d
 refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3
 refs/heads/pubsub-alpha: 1a0e970f265af871e02274085b9662b3fe29058b
 refs/heads/resource-manager: ebf4adc5ee835cd2086c4ac5b4e78d01a5a005a7
-refs/heads/update-datastore: 9b3e6896c48ff1146a36d4c4ee4bcf941b641442
+refs/heads/update-datastore: 494511c54dfd9ff09e4748c2847d32fda8483880
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
 refs/tags/v0.0.10: 207ebd2a3472fddee69fe1298eb90429e3306efd
 refs/tags/v0.0.11: ffbfba48a6426ff63c08ff2117e58681f251fbf2
diff --git a/branches/update-datastore/gcloud-java-datastore/src/main/java/com/google/gcloud/datastore/testing/LocalGcdHelper.java b/branches/update-datastore/gcloud-java-datastore/src/main/java/com/google/gcloud/datastore/testing/LocalGcdHelper.java
@@ -524,7 +524,7 @@ private static void extractFile(ZipInputStream zipIn, File filePath) throws IOEx
     }
   }
 
-  public static String sendQuitRequest(int port) {
+  public static boolean sendQuitRequest(int port) {
     StringBuilder result = new StringBuilder();
     try {
       URL url = new URL("http", "localhost", port, "/_ah/admin/quit");
@@ -543,7 +543,7 @@ public static String sendQuitRequest(int port) {
     } catch (IOException ignore) {
       // ignore
     }
-    return result.toString();
+    return result.toString().startsWith("Shutting down local server");
   }
 
   public void stop() throws IOException, InterruptedException {
diff --git a/branches/update-datastore/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelperTest.java b/branches/update-datastore/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelperTest.java
@@ -50,9 +50,16 @@ public void testFindAvailablePort() {
   @Test
   public void testSendQuitRequest() throws IOException, InterruptedException {
     LocalGcdHelper gcdHelper = LocalGcdHelper.start(PROJECT_ID, PORT);
-    assertTrue(LocalGcdHelper.sendQuitRequest(PORT).startsWith("Shutting down local server"));
+    assertTrue(LocalGcdHelper.sendQuitRequest(PORT));
+    long timeoutMillis = 30000;
+    long startTime = System.currentTimeMillis();
+    boolean datastoreActive = LocalGcdHelper.isActive(PROJECT_ID, PORT);
+    while (datastoreActive && System.currentTimeMillis() - startTime < timeoutMillis) {
+      datastoreActive = LocalGcdHelper.isActive(PROJECT_ID, PORT);
+    }
+    assertFalse(datastoreActive);
+    assertFalse(LocalGcdHelper.sendQuitRequest(PORT));
     gcdHelper.stop();
-    assertTrue(LocalGcdHelper.sendQuitRequest(PORT).isEmpty()); // shouldn't error
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -524,7 +524,7 @@ private static void extractFile(ZipInputStream zipIn, File filePath) throws IOEx`
`524`	`524`	`}`
`525`	`525`	`}`
`526`	`526`
`527`		`- public static String sendQuitRequest(int port) {`
	`527`	`+ public static boolean sendQuitRequest(int port) {`
`528`	`528`	`StringBuilder result = new StringBuilder();`
`529`	`529`	`try {`
`530`	`530`	`URL url = new URL("http", "localhost", port, "/_ah/admin/quit");`
`@@ -543,7 +543,7 @@ public static String sendQuitRequest(int port) {`
`543`	`543`	`} catch (IOException ignore) {`
`544`	`544`	`// ignore`
`545`	`545`	`}`
`546`		`- return result.toString();`
	`546`	`+ return result.toString().startsWith("Shutting down local server");`
`547`	`547`	`}`
`548`	`548`
`549`	`549`	`public void stop() throws IOException, InterruptedException {`