summaryrefslogtreecommitdiffstats
path: root/gluster/swift
diff options
context:
space:
mode:
Diffstat (limited to 'gluster/swift')
-rw-r--r--gluster/swift/account/utils.py71
-rw-r--r--gluster/swift/common/DiskDir.py16
-rw-r--r--gluster/swift/common/constraints.py5
-rw-r--r--gluster/swift/common/utils.py6
4 files changed, 94 insertions, 4 deletions
diff --git a/gluster/swift/account/utils.py b/gluster/swift/account/utils.py
new file mode 100644
index 0000000..99fe5ea
--- /dev/null
+++ b/gluster/swift/account/utils.py
@@ -0,0 +1,71 @@
+# Copyright (c) 2016 Red Hat, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+# implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from swift.account.utils import FakeAccountBroker, get_response_headers
+from swift.common.swob import HTTPOk, HTTPNoContent
+from swift.common.utils import json
+from xml.sax import saxutils
+
+
+def account_listing_response(account, req, response_content_type, broker=None,
+ limit='', marker='', end_marker='', prefix='',
+ delimiter=''):
+ """
+ This is an exact copy of swift.account.utis.account_listing_response()
+ except for one difference i.e this method passes response_content_type
+ to broker.list_containers_iter() method.
+ """
+ if broker is None:
+ broker = FakeAccountBroker()
+
+ resp_headers = get_response_headers(broker)
+
+ account_list = broker.list_containers_iter(limit, marker, end_marker,
+ prefix, delimiter,
+ response_content_type)
+ if response_content_type == 'application/json':
+ data = []
+ for (name, object_count, bytes_used, is_subdir) in account_list:
+ if is_subdir:
+ data.append({'subdir': name})
+ else:
+ data.append({'name': name, 'count': object_count,
+ 'bytes': bytes_used})
+ account_list = json.dumps(data)
+ elif response_content_type.endswith('/xml'):
+ output_list = ['<?xml version="1.0" encoding="UTF-8"?>',
+ '<account name=%s>' % saxutils.quoteattr(account)]
+ for (name, object_count, bytes_used, is_subdir) in account_list:
+ if is_subdir:
+ output_list.append(
+ '<subdir name=%s />' % saxutils.quoteattr(name))
+ else:
+ item = '<container><name>%s</name><count>%s</count>' \
+ '<bytes>%s</bytes></container>' % \
+ (saxutils.escape(name), object_count, bytes_used)
+ output_list.append(item)
+ output_list.append('</account>')
+ account_list = '\n'.join(output_list)
+ else:
+ if not account_list:
+ resp = HTTPNoContent(request=req, headers=resp_headers)
+ resp.content_type = response_content_type
+ resp.charset = 'utf-8'
+ return resp
+ account_list = '\n'.join(r[0] for r in account_list) + '\n'
+ ret = HTTPOk(body=account_list, request=req, headers=resp_headers)
+ ret.content_type = response_content_type
+ ret.charset = 'utf-8'
+ return ret
diff --git a/gluster/swift/common/DiskDir.py b/gluster/swift/common/DiskDir.py
index e8dba35..31b923a 100644
--- a/gluster/swift/common/DiskDir.py
+++ b/gluster/swift/common/DiskDir.py
@@ -696,7 +696,7 @@ class DiskAccount(DiskCommon):
return containers
def list_containers_iter(self, limit, marker, end_marker,
- prefix, delimiter):
+ prefix, delimiter, response_content_type=None):
"""
Return tuple of name, object_count, bytes_used, 0(is_subdir).
Used by account server.
@@ -709,6 +709,7 @@ class DiskAccount(DiskCommon):
if containers:
containers.sort()
else:
+ # No containers in account, return empty list
return account_list
if containers and end_marker:
@@ -737,6 +738,19 @@ class DiskAccount(DiskCommon):
containers = filter_delimiter(containers, delimiter, prefix,
marker)
+ if response_content_type == 'text/plain':
+ # The client is only asking for a plain list of containers and NOT
+ # asking for any extended information about container such as
+ # bytes used or object count.
+ for container in containers:
+ # When response_content_type == 'text/plain', Swift will only
+ # consume the name of the container (first element of tuple).
+ # Refer: swift.account.utils.account_listing_response()
+ account_list.append((container, 0, 0, 0))
+ if len(account_list) >= limit:
+ break
+ return account_list
+
count = 0
for cont in containers:
list_item = []
diff --git a/gluster/swift/common/constraints.py b/gluster/swift/common/constraints.py
index 7979b43..98e2a27 100644
--- a/gluster/swift/common/constraints.py
+++ b/gluster/swift/common/constraints.py
@@ -97,3 +97,8 @@ __Ring = _ring.Ring
# Replace the original Ring class
_ring.Ring = ring.Ring
+
+# Monkey patch account_listing_response
+import swift.account.utils
+from gluster.swift.account.utils import account_listing_response as gf_als
+swift.account.utils.account_listing_response = gf_als
diff --git a/gluster/swift/common/utils.py b/gluster/swift/common/utils.py
index ded2f0b..8958717 100644
--- a/gluster/swift/common/utils.py
+++ b/gluster/swift/common/utils.py
@@ -375,7 +375,6 @@ def get_account_details(acc_path):
Return container_list and container_count.
"""
container_list = []
- container_count = 0
if do_isdir(acc_path):
for name in do_listdir(acc_path):
@@ -383,11 +382,12 @@ def get_account_details(acc_path):
or name.lower() == ASYNCDIR \
or name.lower() == TRASHCAN \
or not do_isdir(os.path.join(acc_path, name)):
+ # Do not include .async_pending, .trashcan and all
+ # non-directories in containers list
continue
- container_count += 1
container_list.append(name)
- return container_list, container_count
+ return container_list, len(container_list)
def _read_for_etag(fp):