+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2016 SUSE LINUX GmbH
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation. See file COPYING.
- *
- */
-
-#ifndef CEPH_RBD_MIRROR_IMAGEDELETER_H
-#define CEPH_RBD_MIRROR_IMAGEDELETER_H
-
-#include "common/Mutex.h"
-#include "common/Cond.h"
-#include "common/Thread.h"
-#include "common/Timer.h"
-#include "types.h"
-
-#include <deque>
-#include <vector>
-#include <atomic>
-
-class AdminSocketHook;
-class ContextWQ;
-namespace librbd { struct ImageCtx; }
-
-namespace rbd {
-namespace mirror {
-
-template <typename> class ServiceDaemon;
-
-/**
- * Manage deletion of non-primary images.
- */
-template <typename ImageCtxT = librbd::ImageCtx>
-class ImageDeleter {
-public:
- static const int EISPRM = 1000;
-
- ImageDeleter(ContextWQ *work_queue, SafeTimer *timer, Mutex *timer_lock,
- ServiceDaemon<librbd::ImageCtx>* service_daemon);
- ~ImageDeleter();
- ImageDeleter(const ImageDeleter&) = delete;
- ImageDeleter& operator=(const ImageDeleter&) = delete;
-
- void schedule_image_delete(RadosRef local_rados,
- int64_t local_pool_id,
- const std::string& global_image_id,
- bool ignore_orphaned);
- void wait_for_scheduled_deletion(int64_t local_pool_id,
- const std::string &global_image_id,
- Context *ctx,
- bool notify_on_failed_retry=true);
- void cancel_waiter(int64_t local_pool_id,
- const std::string &global_image_id);
-
- void print_status(Formatter *f, std::stringstream *ss);
-
- // for testing purposes
- std::vector<std::string> get_delete_queue_items();
- std::vector<std::pair<std::string, int> > get_failed_queue_items();
- void set_failed_timer_interval(double interval);
-
-private:
-
- class ImageDeleterThread : public Thread {
- ImageDeleter *m_image_deleter;
- public:
- ImageDeleterThread(ImageDeleter *image_deleter) :
- m_image_deleter(image_deleter) {}
- void *entry() override {
- m_image_deleter->run();
- return 0;
- }
- };
-
- struct DeleteInfo {
- RadosRef local_rados;
- int64_t local_pool_id;
- std::string global_image_id;
- bool ignore_orphaned;
- int error_code = 0;
- int retries = 0;
- bool notify_on_failed_retry = true;
- Context *on_delete = nullptr;
-
- DeleteInfo(RadosRef local_rados, int64_t local_pool_id,
- const std::string& global_image_id,
- bool ignore_orphaned)
- : local_rados(local_rados), local_pool_id(local_pool_id),
- global_image_id(global_image_id), ignore_orphaned(ignore_orphaned) {
- }
-
- bool match(int64_t local_pool_id, const std::string &global_image_id) {
- return (this->local_pool_id == local_pool_id &&
- this->global_image_id == global_image_id);
- }
- void notify(int r);
- void to_string(std::stringstream& ss);
- void print_status(Formatter *f, std::stringstream *ss,
- bool print_failure_info=false);
- };
-
- std::atomic<unsigned> m_running { 1 };
-
- ContextWQ *m_work_queue;
- ServiceDaemon<librbd::ImageCtx>* m_service_daemon;
-
- std::deque<std::unique_ptr<DeleteInfo> > m_delete_queue;
- Mutex m_delete_lock;
- Cond m_delete_queue_cond;
-
- unique_ptr<DeleteInfo> m_active_delete;
-
- ImageDeleterThread m_image_deleter_thread;
-
- std::deque<std::unique_ptr<DeleteInfo>> m_failed_queue;
- double m_failed_interval;
- SafeTimer *m_failed_timer;
- Mutex *m_failed_timer_lock;
-
- AdminSocketHook *m_asok_hook;
-
- void run();
- bool process_image_delete();
- int image_has_snapshots_and_children(librados::IoCtx *ioctx,
- std::string& image_id,
- bool *has_snapshots);
-
- void complete_active_delete(int r);
- void enqueue_failed_delete(int error_code);
- void retry_failed_deletions();
-
- unique_ptr<DeleteInfo> const*
- find_delete_info(int64_t local_pool_id, const std::string &global_image_id);
-
-};
-
-} // namespace mirror
-} // namespace rbd
-
-extern template class rbd::mirror::ImageDeleter<librbd::ImageCtx>;
-
-#endif // CEPH_RBD_MIRROR_IMAGEDELETER_H