librados::IoCtxImpl::IoCtxImpl() :
ref_cnt(0), client(NULL), poolid(0), assert_ver(0), last_objver(0),
notify_timeout(30), aio_write_list_lock("librados::IoCtxImpl::aio_write_list_lock"),
- aio_write_seq(0), lock(NULL), objecter(NULL)
+ aio_write_seq(0), objecter(NULL)
{
}
librados::IoCtxImpl::IoCtxImpl(RadosClient *c, Objecter *objecter,
- Mutex *client_lock, int poolid,
+ int poolid,
const char *pool_name, snapid_t s)
: ref_cnt(0), client(c), poolid(poolid), pool_name(pool_name), snap_seq(s),
assert_ver(0), notify_timeout(c->cct->_conf->client_notify_timeout),
oloc(poolid),
aio_write_list_lock("librados::IoCtxImpl::aio_write_list_lock"),
- aio_write_seq(0), lock(client_lock), objecter(objecter)
+ aio_write_seq(0), objecter(objecter)
{
}
xlist<AioCompletionImpl*> aio_write_list;
map<ceph_tid_t, std::list<AioCompletionImpl*> > aio_write_waiters;
- Mutex *lock;
Objecter *objecter;
IoCtxImpl();
- IoCtxImpl(RadosClient *c, Objecter *objecter, Mutex *client_lock,
+ IoCtxImpl(RadosClient *c, Objecter *objecter,
int poolid, const char *pool_name, snapid_t s);
void dup(const IoCtxImpl& rhs) {
last_objver = rhs.last_objver;
notify_timeout = rhs.notify_timeout;
oloc = rhs.oloc;
- lock = rhs.lock;
objecter = rhs.objecter;
}
}
}
- *io = new librados::IoCtxImpl(this, objecter, &lock, poolid, name,
- CEPH_NOSNAP);
+ *io = new librados::IoCtxImpl(this, objecter, poolid, name, CEPH_NOSNAP);
return 0;
}