summaryrefslogtreecommitdiffstats
path: root/ufo
diff options
context:
space:
mode:
authorPeter Portante <peter.portante@redhat.com>2012-11-14 15:43:56 -0500
committerVijay Bellur <vbellur@redhat.com>2012-12-11 04:53:53 -0800
commit0c9f4d12a3b724afd61f60fed5e131335579ae5a (patch)
treea6b82d5cd4a053b3f3e61f88fd062c27cfbd3b01 /ufo
parent29c23f20a6213affb646c322b7219a0f7c5c3dfc (diff)
object-storage: unit tests to 100% cover utils
Change-Id: I2d540e16cc3d420b9bb88e6857e9795d56e34529 BUG: 884327 Signed-off-by: Peter Portante <peter.portante@redhat.com> Reviewed-on: http://review.gluster.org/4225 Reviewed-by: Kaleb KEITHLEY <kkeithle@redhat.com> Reviewed-by: Mohammed Junaid <junaid@redhat.com> Tested-by: Gluster Build System <jenkins@build.gluster.com>
Diffstat (limited to 'ufo')
-rw-r--r--ufo/test/unit/common/test_utils.py158
1 files changed, 146 insertions, 12 deletions
diff --git a/ufo/test/unit/common/test_utils.py b/ufo/test/unit/common/test_utils.py
index 446939963d6..dd89bd5e4ef 100644
--- a/ufo/test/unit/common/test_utils.py
+++ b/ufo/test/unit/common/test_utils.py
@@ -34,7 +34,9 @@ from gluster.swift.common import utils
#
_xattrs = {}
_xattr_op_cnt = defaultdict(int)
-_xattr_err = {}
+_xattr_set_err = {}
+_xattr_get_err = {}
+_xattr_rem_err = {}
def _xkey(path, key):
return "%s:%s" % (path, key)
@@ -42,9 +44,9 @@ def _xkey(path, key):
def _setxattr(path, key, value):
_xattr_op_cnt['set'] += 1
xkey = _xkey(path, key)
- if xkey in _xattr_err:
+ if xkey in _xattr_set_err:
e = IOError()
- e.errno = _xattr_err[xkey]
+ e.errno = _xattr_set_err[xkey]
raise e
global _xattrs
_xattrs[xkey] = value
@@ -52,9 +54,9 @@ def _setxattr(path, key, value):
def _getxattr(path, key):
_xattr_op_cnt['get'] += 1
xkey = _xkey(path, key)
- if xkey in _xattr_err:
+ if xkey in _xattr_get_err:
e = IOError()
- e.errno = _xattr_err[xkey]
+ e.errno = _xattr_get_err[xkey]
raise e
global _xattrs
if xkey in _xattrs:
@@ -68,9 +70,9 @@ def _getxattr(path, key):
def _removexattr(path, key):
_xattr_op_cnt['remove'] += 1
xkey = _xkey(path, key)
- if xkey in _xattr_err:
+ if xkey in _xattr_rem_err:
e = IOError()
- e.errno = _xattr_err[xkey]
+ e.errno = _xattr_rem_err[xkey]
raise e
global _xattrs
if xkey in _xattrs:
@@ -85,8 +87,10 @@ def _initxattr():
_xattrs = {}
global _xattr_op_cnt
_xattr_op_cnt = defaultdict(int)
- global _xattr_err
- _xattr_err = {}
+ global _xattr_set_err, _xattr_get_err, _xattr_rem_err
+ _xattr_set_err = {}
+ _xattr_get_err = {}
+ _xattr_rem_err = {}
# Save the current methods
global _xattr_set; _xattr_set = xattr.set
@@ -141,7 +145,7 @@ class TestUtils(unittest.TestCase):
path = "/tmp/foo/w"
orig_d = { 'bar' : 'foo' }
xkey = _xkey(path, utils.METADATA_KEY)
- _xattr_err[xkey] = errno.EOPNOTSUPP
+ _xattr_set_err[xkey] = errno.EOPNOTSUPP
try:
utils.write_metadata(path, orig_d)
except IOError as e:
@@ -182,7 +186,7 @@ class TestUtils(unittest.TestCase):
path = "/tmp/foo/c"
xkey = _xkey(path, utils.METADATA_KEY)
_xattrs[xkey] = pickle.dumps({ 'a': 'y' }, utils.PICKLE_PROTOCOL)
- _xattr_err[xkey] = errno.EOPNOTSUPP
+ _xattr_rem_err[xkey] = errno.EOPNOTSUPP
try:
utils.clean_metadata(path)
except IOError as e:
@@ -211,7 +215,7 @@ class TestUtils(unittest.TestCase):
expected_d = { 'a': 'y' }
xkey = _xkey(path, utils.METADATA_KEY)
_xattrs[xkey] = pickle.dumps(expected_d, utils.PICKLE_PROTOCOL)
- _xattr_err[xkey] = errno.EOPNOTSUPP
+ _xattr_get_err[xkey] = errno.EOPNOTSUPP
try:
res_d = utils.read_metadata(path)
except IOError as e:
@@ -847,3 +851,133 @@ class TestUtils(unittest.TestCase):
assert contents == ''
finally:
shutil.rmtree(td)
+
+ def test_check_user_xattr_bad_path(self):
+ assert False == utils.check_user_xattr("/tmp/foo/bar/check/user/xattr")
+
+ def test_check_user_xattr_bad_set(self):
+ td = tempfile.mkdtemp()
+ xkey = _xkey(td, 'user.test.key1')
+ _xattr_set_err[xkey] = errno.EOPNOTSUPP
+ try:
+ assert False == utils.check_user_xattr(td)
+ except IOError:
+ pass
+ else:
+ self.fail("Expected IOError")
+ finally:
+ shutil.rmtree(td)
+
+ def test_check_user_xattr_bad_remove(self):
+ td = tempfile.mkdtemp()
+ xkey = _xkey(td, 'user.test.key1')
+ _xattr_rem_err[xkey] = errno.EOPNOTSUPP
+ try:
+ utils.check_user_xattr(td)
+ except IOError:
+ self.fail("Unexpected IOError")
+ finally:
+ shutil.rmtree(td)
+
+ def test_check_user_xattr(self):
+ td = tempfile.mkdtemp()
+ try:
+ assert utils.check_user_xattr(td)
+ finally:
+ shutil.rmtree(td)
+
+ def test_validate_container_empty(self):
+ ret = utils.validate_container({})
+ assert ret == False
+
+ def test_validate_container_missing_keys(self):
+ ret = utils.validate_container({ 'foo': 'bar' })
+ assert ret == False
+
+ def test_validate_container_bad_type(self):
+ md = { utils.X_TYPE: ('bad', 0),
+ utils.X_TIMESTAMP: ('na', 0),
+ utils.X_PUT_TIMESTAMP: ('na', 0),
+ utils.X_OBJECTS_COUNT: ('na', 0),
+ utils.X_BYTES_USED: ('na', 0) }
+ ret = utils.validate_container(md)
+ assert ret == False
+
+ def test_validate_container_good_type(self):
+ md = { utils.X_TYPE: (utils.CONTAINER, 0),
+ utils.X_TIMESTAMP: ('na', 0),
+ utils.X_PUT_TIMESTAMP: ('na', 0),
+ utils.X_OBJECTS_COUNT: ('na', 0),
+ utils.X_BYTES_USED: ('na', 0) }
+ ret = utils.validate_container(md)
+ assert ret
+
+ def test_validate_account_empty(self):
+ ret = utils.validate_account({})
+ assert ret == False
+
+ def test_validate_account_missing_keys(self):
+ ret = utils.validate_account({ 'foo': 'bar' })
+ assert ret == False
+
+ def test_validate_account_bad_type(self):
+ md = { utils.X_TYPE: ('bad', 0),
+ utils.X_TIMESTAMP: ('na', 0),
+ utils.X_PUT_TIMESTAMP: ('na', 0),
+ utils.X_OBJECTS_COUNT: ('na', 0),
+ utils.X_BYTES_USED: ('na', 0),
+ utils.X_CONTAINER_COUNT: ('na', 0) }
+ ret = utils.validate_account(md)
+ assert ret == False
+
+ def test_validate_account_good_type(self):
+ md = { utils.X_TYPE: (utils.ACCOUNT, 0),
+ utils.X_TIMESTAMP: ('na', 0),
+ utils.X_PUT_TIMESTAMP: ('na', 0),
+ utils.X_OBJECTS_COUNT: ('na', 0),
+ utils.X_BYTES_USED: ('na', 0),
+ utils.X_CONTAINER_COUNT: ('na', 0) }
+ ret = utils.validate_account(md)
+ assert ret
+
+ def test_validate_object_empty(self):
+ ret = utils.validate_object({})
+ assert ret == False
+
+ def test_validate_object_missing_keys(self):
+ ret = utils.validate_object({ 'foo': 'bar' })
+ assert ret == False
+
+ def test_validate_object_bad_type(self):
+ md = { utils.X_TIMESTAMP: 'na',
+ utils.X_CONTENT_TYPE: 'na',
+ utils.X_ETAG: 'bad',
+ utils.X_CONTENT_LENGTH: 'na',
+ utils.X_TYPE: 'bad',
+ utils.X_OBJECT_TYPE: 'na' }
+ ret = utils.validate_object(md)
+ assert ret == False
+
+ def test_validate_object_good_type(self):
+ md = { utils.X_TIMESTAMP: 'na',
+ utils.X_CONTENT_TYPE: 'na',
+ utils.X_ETAG: 'bad',
+ utils.X_CONTENT_LENGTH: 'na',
+ utils.X_TYPE: utils.OBJECT,
+ utils.X_OBJECT_TYPE: 'na' }
+ ret = utils.validate_object(md)
+ assert ret
+
+ def test_is_marker_empty(self):
+ assert False == utils.is_marker(None)
+
+ def test_is_marker_missing(self):
+ assert False == utils.is_marker( { 'foo': 'bar' } )
+
+ def test_is_marker_not_marker(self):
+ md = { utils.X_OBJECT_TYPE: utils.DIR }
+ assert False == utils.is_marker(md)
+
+ def test_is_marker(self):
+ md = { utils.X_OBJECT_TYPE: utils.MARKER_DIR }
+ assert utils.is_marker(md)