From 2f32783bd60081b7798b73c58f9d973776dfd7b5 Mon Sep 17 00:00:00 2001
From: Dave Brosius <dbrosius@mebigfatguy.com>
Date: Sun, 4 May 2014 00:07:40 -0400
Subject: [PATCH] make sure zone info gets completely read

---
 .../org/apache/cassandra/locator/CloudstackSnitch.java   | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/java/org/apache/cassandra/locator/CloudstackSnitch.java b/src/java/org/apache/cassandra/locator/CloudstackSnitch.java
index 6d06556743..af26ef9533 100644
--- a/src/java/org/apache/cassandra/locator/CloudstackSnitch.java
+++ b/src/java/org/apache/cassandra/locator/CloudstackSnitch.java
@@ -17,9 +17,8 @@
  */
 package org.apache.cassandra.locator;
 
-import java.io.InputStream;
+import java.io.DataInputStream;
 import java.io.BufferedInputStream;
-import java.io.FilterInputStream;
 import java.io.BufferedReader;
 import java.io.FileReader;
 import java.io.IOException;
@@ -112,7 +111,7 @@ public class CloudstackSnitch extends AbstractNetworkTopologySnitch
     String csQueryMetadata(String url) throws ConfigurationException, IOException
     {
         HttpURLConnection conn = null;
-        BufferedInputStream is = null;
+        DataInputStream is = null;
 
         try {
             conn = (HttpURLConnection) new URL(url).openConnection();
@@ -127,8 +126,8 @@ public class CloudstackSnitch extends AbstractNetworkTopologySnitch
 
             int cl = conn.getContentLength();
             byte[] b = new byte[cl];
-            is = new BufferedInputStream(conn.getInputStream());
-            is.read(b, 0, cl);
+            is = new DataInputStream(new BufferedInputStream(conn.getInputStream()));
+            is.readFully(b);
             return new String(b, StandardCharsets.UTF_8);
         } finally {
             FileUtils.close(is);