summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2014-01-16 22:17:28 +0000
committerGerrit Code Review <review@openstack.org>2014-01-16 22:17:28 +0000
commit9349aefefc1ab717dae1f2433f432718dfbb78c1 (patch)
tree115c219d5748f7bf178e19495b131e4e240829b2
parentbcc350d87eb976ab9b7144aa2c55fe1f1d62a4b1 (diff)
parentc69e4d8b9f7e68c3d90a5cfc0613491b677ab4dc (diff)
Merge "[hadoop-openstack] Added debug log on getObject method"2014.1.b2
-rw-r--r--hadoop-swiftfs/src/main/java/org/apache/hadoop/fs/swift/snative/SwiftNativeFileSystemStore.java13
1 files changed, 13 insertions, 0 deletions
diff --git a/hadoop-swiftfs/src/main/java/org/apache/hadoop/fs/swift/snative/SwiftNativeFileSystemStore.java b/hadoop-swiftfs/src/main/java/org/apache/hadoop/fs/swift/snative/SwiftNativeFileSystemStore.java
index be022d6..a379310 100644
--- a/hadoop-swiftfs/src/main/java/org/apache/hadoop/fs/swift/snative/SwiftNativeFileSystemStore.java
+++ b/hadoop-swiftfs/src/main/java/org/apache/hadoop/fs/swift/snative/SwiftNativeFileSystemStore.java
@@ -276,6 +276,9 @@ public class SwiftNativeFileSystemStore {
276 List<String> locations = getDataLocalEndpoints(path); 276 List<String> locations = getDataLocalEndpoints(path);
277 277
278 for (String url : locations) { 278 for (String url : locations) {
279 if (LOG.isDebugEnabled()) {
280 LOG.debug("Reading " + path + " from location: " + url);
281 }
279 try { 282 try {
280 return swiftRestClient.getData(new URI(url), 283 return swiftRestClient.getData(new URI(url),
281 SwiftRestClient.NEWEST); 284 SwiftRestClient.NEWEST);
@@ -285,6 +288,9 @@ public class SwiftNativeFileSystemStore {
285 } 288 }
286 } 289 }
287 290
291 if (LOG.isDebugEnabled()) {
292 LOG.debug("Reading " + path + " from proxy node");
293 }
288 return swiftRestClient.getData(toObjectPath(path), 294 return swiftRestClient.getData(toObjectPath(path),
289 SwiftRestClient.NEWEST); 295 SwiftRestClient.NEWEST);
290 } 296 }
@@ -368,6 +374,9 @@ public class SwiftNativeFileSystemStore {
368 List<String> locations = getDataLocalEndpoints(path); 374 List<String> locations = getDataLocalEndpoints(path);
369 375
370 for (String url : locations) { 376 for (String url : locations) {
377 if (LOG.isDebugEnabled()) {
378 LOG.debug("Reading " + path + " from location: " + url);
379 }
371 try { 380 try {
372 return swiftRestClient.getData(new URI(url), byteRangeStart, length); 381 return swiftRestClient.getData(new URI(url), byteRangeStart, length);
373 } catch (Exception e) { 382 } catch (Exception e) {
@@ -375,6 +384,10 @@ public class SwiftNativeFileSystemStore {
375 } 384 }
376 } 385 }
377 386
387 if (LOG.isDebugEnabled()) {
388 LOG.debug("Reading " + path + " from proxy node");
389 }
390
378 return swiftRestClient.getData( 391 return swiftRestClient.getData(
379 toObjectPath(path), byteRangeStart, length); 392 toObjectPath(path), byteRangeStart, length);
380 } 393 }