char *_path = opt_str(path)
with nogil:
ret = rados_conf_read_file(self.cluster, _path)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error calling conf_read_file")
def conf_parse_argv(self, args):
char *_var = var
with nogil:
ret = rados_conf_parse_env(self.cluster, _var)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error calling conf_parse_env")
@requires(('option', str_type))
ret_buf = <char *>realloc_chk(ret_buf, length)
with nogil:
ret = rados_conf_get(self.cluster, _option, ret_buf, length)
- if (ret == 0):
+ if ret == 0:
return decode_cstr(ret_buf)
- elif (ret == -errno.ENAMETOOLONG):
+ elif ret == -errno.ENAMETOOLONG:
length = length * 2
- elif (ret == -errno.ENOENT):
+ elif ret == -errno.ENOENT:
return None
else:
raise make_ex(ret, "error calling conf_get")
with nogil:
ret = rados_conf_set(self.cluster, _option, _val)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error calling conf_set")
def ping_monitor(self, mon_id):
# for now and remove it later
with nogil:
ret = rados_connect(self.cluster)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error connecting to the cluster")
self.state = "connected"
with nogil:
ret = rados_pool_lookup(self.cluster, _pool_name)
- if (ret >= 0):
+ if ret >= 0:
return True
- elif (ret == -errno.ENOENT):
+ elif ret == -errno.ENOENT:
return False
else:
raise make_ex(ret, "error looking up pool '%s'" % pool_name)
with nogil:
ret = rados_pool_lookup(self.cluster, _pool_name)
- if (ret >= 0):
+ if ret >= 0:
return int(ret)
- elif (ret == -errno.ENOENT):
+ elif ret == -errno.ENOENT:
return None
else:
raise make_ex(ret, "error looking up pool '%s'" % pool_name)
with nogil:
ret = rados_omap_get_next(self.ctx, &key_, &val_, &len_)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error iterating over the omap")
if key_ == NULL:
raise StopIteration()
with nogil:
ret = rados_getxattrs_next(self.it, &name_, &val_, &len_)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "error iterating over the extended attributes \
in '%s'" % self.oid)
if name_ == NULL:
with nogil:
ret = rados_ioctx_snap_list(ioctx.io, self.snaps, num_snaps)
- if (ret >= 0):
+ if ret >= 0:
self.max_snap = ret
break
- elif (ret != -errno.ERANGE):
+ elif ret != -errno.ERANGE:
raise make_ex(ret, "error calling rados_snap_list for \
ioctx '%s'" % self.ioctx.name)
num_snaps = num_snaps * 2
:raises: :class:`Error`, StopIteration
:returns: Snap - next snapshot
"""
- if (self.cur_snap >= self.max_snap):
+ if self.cur_snap >= self.max_snap:
raise StopIteration
cdef:
name = <char *>realloc_chk(name, name_len)
with nogil:
ret = rados_ioctx_snap_get_name(self.ioctx.io, snap_id, name, name_len)
- if (ret == 0):
+ if ret == 0:
break
- elif (ret != -errno.ERANGE):
+ elif ret != -errno.ERANGE:
raise make_ex(ret, "rados_snap_get_name error")
else:
name_len = name_len * 2
with nogil:
ret = rados_ioctx_snap_get_stamp(self.ioctx.io, self.snap_id, &snap_time)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "rados_ioctx_snap_get_stamp error")
return datetime.fromtimestamp(snap_time)
ret_buf = <char *>realloc_chk(ret_buf, ret_length)
with nogil:
ret = rados_getxattr(self.io, _key, _xattr_name, ret_buf, ret_length)
- if (ret == -errno.ERANGE):
+ if ret == -errno.ERANGE:
ret_length *= 2
elif ret < 0:
raise make_ex(ret, "Failed to get xattr %r" % xattr_name)
with nogil:
ret = rados_ioctx_snap_create(self.io, _snap_name)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "Failed to create snap %s" % snap_name)
@requires(('snap_name', str_type))
with nogil:
ret = rados_ioctx_snap_remove(self.io, _snap_name)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "Failed to remove snap %s" % snap_name)
@requires(('snap_name', str_type))
with nogil:
ret = rados_ioctx_snap_lookup(self.io, _snap_name, &snap_id)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "Failed to lookup snap %s" % snap_name)
return Snap(self, snap_name, int(snap_id))
with nogil:
ret = rados_ioctx_snap_rollback(self.io, _oid, _snap_name)
- if (ret != 0):
+ if ret != 0:
raise make_ex(ret, "Failed to rollback %s" % oid)
def get_last_version(self):