char *resolve_addrs(const char *orig_str)
{
char *new_str;
- char *tok, *p, *port_str, *saveptr = NULL;
+ char *tok, *port_str, *saveptr = NULL;
int len, pos;
char *buf = strdup(orig_str);
len = BUF_SIZE;
new_str = (char *)malloc(len);
- p = new_str;
pos = 0;
tok = strtok_r(buf, ",", &saveptr);
int librados::RadosClient::operate_read(IoCtxImpl& io, const object_t& oid,
::ObjectOperation *o, bufferlist *pbl)
{
- utime_t ut = ceph_clock_now(cct);
-
/* can't write to a snapshot */
if (io.snap_seq != CEPH_NOSNAP)
return -EINVAL;
int librados::RadosClient::tmap_get(IoCtxImpl& io, const object_t& oid, bufferlist& bl)
{
- utime_t ut = ceph_clock_now(cct);
-
/* can't write to a snapshot */
if (io.snap_seq != CEPH_NOSNAP)
return -EROFS;
const char *cls, const char *method,
bufferlist& inbl, bufferlist& outbl)
{
- utime_t ut = ceph_clock_now(cct);
-
Mutex mylock("RadosClient::exec::mylock");
Cond cond;
bool done;
int librados::RadosClient::watch(IoCtxImpl& io, const object_t& oid, uint64_t ver,
uint64_t *cookie, librados::WatchCtx *ctx)
{
- utime_t ut = ceph_clock_now(cct);
-
::ObjectOperation rd;
Mutex mylock("RadosClient::watch::mylock");
Cond cond;
int librados::RadosClient::_notify_ack(IoCtxImpl& io, const object_t& oid,
uint64_t notify_id, uint64_t ver)
{
- utime_t ut = ceph_clock_now(cct);
-
Mutex mylock("RadosClient::watch::mylock");
Cond cond;
eversion_t objver;
int librados::RadosClient::unwatch(IoCtxImpl& io, const object_t& oid, uint64_t cookie)
{
- utime_t ut = ceph_clock_now(cct);
bufferlist inbl, outbl;
Mutex mylock("RadosClient::watch::mylock");
int librados::RadosClient::notify(IoCtxImpl& io, const object_t& oid, uint64_t ver, bufferlist& bl)
{
- utime_t ut = ceph_clock_now(cct);
bufferlist inbl, outbl;
Mutex mylock("RadosClient::notify::mylock");