c->_get();
}
- void finish(int r) {
+ void finish(int r) override {
rados_callback_t cb_complete = c->callback_complete;
void *cb_complete_arg = c->callback_complete_arg;
if (cb_complete)
c->get();
}
- void finish(int r) {
+ void finish(int r) override {
c->lock.Lock();
c->rval = r;
c->complete = true;
: ioctx(io), oid(o), ctx(c), ctx2(c2), internal(inter) {
ioctx->get();
}
- ~WatchInfo() {
+ ~WatchInfo() override {
ioctx->put();
if (internal) {
delete ctx;
time_t *pmtime;
ceph::real_time mtime;
C_aio_stat_Ack(AioCompletionImpl *_c, time_t *pm);
- void finish(int r);
+ void finish(int r) override;
};
struct C_aio_stat2_Ack : public Context {
struct timespec *pts;
ceph::real_time mtime;
C_aio_stat2_Ack(AioCompletionImpl *_c, struct timespec *pts);
- void finish(int r);
+ void finish(int r) override;
};
struct C_aio_Complete : public Context {
#endif
AioCompletionImpl *c;
explicit C_aio_Complete(AioCompletionImpl *_c);
- void finish(int r);
+ void finish(int r) override;
};
int aio_read(const object_t oid, AioCompletionImpl *c,
explicit C_PoolAsync_Safe(PoolAsyncCompletionImpl *_c) : c(_c) {
c->get();
}
- ~C_PoolAsync_Safe() {
+ ~C_PoolAsync_Safe() override {
c->put();
}
- void finish(int r) {
+ void finish(int r) override {
c->lock.Lock();
c->rval = r;
c->done = true;
uint64_t instance_id;
bool _dispatch(Message *m);
- bool ms_dispatch(Message *m);
+ bool ms_dispatch(Message *m) override;
- bool ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer, bool force_new);
- void ms_handle_connect(Connection *con);
- bool ms_handle_reset(Connection *con);
- void ms_handle_remote_reset(Connection *con);
- bool ms_handle_refused(Connection *con);
+ bool ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer, bool force_new) override;
+ void ms_handle_connect(Connection *con) override;
+ bool ms_handle_reset(Connection *con) override;
+ void ms_handle_remote_reset(Connection *con) override;
+ bool ms_handle_refused(Connection *con) override;
Objecter *objecter;
Finisher finisher;
explicit RadosClient(CephContext *cct_);
- ~RadosClient();
+ ~RadosClient() override;
int ping_monitor(string mon_id, string *result);
int connect();
void shutdown();
librados::AioCompletionImpl *userCompletion = 0,
int n = 1);
/// destructor
- virtual ~CompletionData();
+ ~CompletionData() override;
/// complete method
void complete(int r);
/// striper to be used to handle the write completion
std::vector<bufferlist>* resultbl,
int n);
/// destructor
- virtual ~ReadCompletionData();
+ ~ReadCompletionData() override;
/// complete method for when reading is over
void complete_read(int r);
/// complete method for when object is unlocked
librados::AioCompletionImpl *userCompletion,
int n);
/// destructor
- virtual ~WriteCompletionData();
+ ~WriteCompletionData() override;
/// complete method for when writing is over
void complete_write(int r);
/// complete method for when object is unlocked
const std::string& soid,
uint64_t size);
/// destructor
- virtual ~TruncateCompletionData();
+ ~TruncateCompletionData() override;
/// striper to be used
libradosstriper::RadosStriperImpl *m_striper;
/// striped object concerned by the truncate operation