---

Ajay Kannan · Ajay Kannan · commit 286899bcef2b · 2015-10-23T10:41:39.000-07:00
yaml --- r: 1087 b: refs/heads/master c: 494511c h: refs/heads/master i: 1085: ecf2f25 1083: d8112ed 1079: f9492ef 1071: 36124c8 1055: 28daa1e 1023: 4c88862 v: v3
diff --git a/[refs] b/[refs]
@@ -1,4 +1,4 @@
 ---
-refs/heads/master: 9b3e6896c48ff1146a36d4c4ee4bcf941b641442
+refs/heads/master: 494511c54dfd9ff09e4748c2847d32fda8483880
 refs/heads/travis: 0fa997e2fc9c6b61b2d91e6d163655aae67d44b6
 refs/heads/gh-pages: 5a10432ecc75f29812e33a8236c900379509fe99
diff --git a/trunk/gcloud-java-datastore/src/main/java/com/google/gcloud/datastore/testing/LocalGcdHelper.java b/trunk/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/trunk/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelperTest.java b/trunk/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 {`