---

Ajay Kannan · Ajay Kannan · commit 51f1a8ba7339 · 2015-09-29T18:14:15.000-07:00
yaml --- r: 6173 b: refs/heads/tswast-patch-1 c: 22a9e99 h: refs/heads/master i: 6171: cd23c67
diff --git a/[refs] b/[refs]
@@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
 refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
 refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
 refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
-refs/heads/tswast-patch-1: 1f617b77fd77d09f327b909d2302f2f4efc6e0a5
+refs/heads/tswast-patch-1: 22a9e9915c1ba5fae4e1d194bf0b92686d4ba7d4
 refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
diff --git a/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/DatastoreOptionsTest.java b/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/DatastoreOptionsTest.java
@@ -34,7 +34,7 @@
 public class DatastoreOptionsTest {
 
   private static final String PROJECT_ID = "project_id";
-  private static final int PORT = LocalGcdHelper.findOpenPort();
+  private static final int PORT = LocalGcdHelper.findAvailablePort(LocalGcdHelper.DEFAULT_PORT);
   private DatastoreRpcFactory datastoreRpcFactory;
   private DatastoreRpc datastoreRpc;
   private DatastoreOptions.Builder options;
diff --git a/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/DatastoreTest.java b/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/DatastoreTest.java
@@ -101,7 +101,7 @@ public class DatastoreTest {
   private Datastore datastore;
 
   private static LocalGcdHelper gcdHelper;
-  private static final int PORT = LocalGcdHelper.findOpenPort();
+  private static final int PORT = LocalGcdHelper.findAvailablePort(LocalGcdHelper.DEFAULT_PORT);
 
   @BeforeClass
   public static void beforeClass() throws IOException, InterruptedException {
diff --git a/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelper.java b/branches/tswast-patch-1/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/LocalGcdHelper.java
@@ -72,7 +72,7 @@ public class LocalGcdHelper {
   private final int port;
 
   public static final String DEFAULT_PROJECT_ID = "projectid1";
-  private static final int DEFAULT_PORT = 8080;
+  public static final int DEFAULT_PORT = 8080;
   private static final String GCD_VERSION = "v1beta2";
   private static final String GCD_BUILD = "rev1-2.1.2b";
   private static final String GCD_BASENAME = "gcd-" + GCD_VERSION + "-" + GCD_BUILD;
@@ -96,15 +96,12 @@ public class LocalGcdHelper {
     }
   }
 
-  public static int findOpenPort() {
-    int port;
-    try (ServerSocket temp_socket = new ServerSocket(0)) {
-      port = temp_socket.getLocalPort();
-      temp_socket.close();
+  public static int findAvailablePort(int defaultPort) {
+    try (ServerSocket tempSocket = new ServerSocket(0)) {
+      return tempSocket.getLocalPort();
     } catch (IOException e) {
-      port = DEFAULT_PORT;
+      return defaultPort;
     }
-    return port;
   }
 
   private static Path installedGcdPath() {
@@ -491,8 +488,8 @@ public static void main(String... args) throws IOException, InterruptedException
     if (args.length == 1) {
       switch (args[0]) {
         case "START":
-          if (!isActive(DEFAULT_PROJECT_ID, DEFAULT_PORT)) {
-            LocalGcdHelper helper = start(DEFAULT_PROJECT_ID, DEFAULT_PORT);
+          if (!isActive(DEFAULT_PROJECT_ID, findAvailablePort(DEFAULT_PORT))) {
+            LocalGcdHelper helper = start(DEFAULT_PROJECT_ID, findAvailablePort(DEFAULT_PORT));
             try (FileWriter writer = new FileWriter(".local_gcd_helper")) {
               writer.write(helper.gcdPath.toAbsolutePath().toString());
             }
