remove ceph code

[stor4nfv.git] / src / ceph / src / librados / PoolAsyncCompletionImpl.h

diff --git a/src/ceph/src/librados/PoolAsyncCompletionImpl.h b/src/ceph/src/librados/PoolAsyncCompletionImpl.h
deleted file mode 100644 (file)
index e876db7..0000000
--- a/src/ceph/src/librados/PoolAsyncCompletionImpl.h
+++ /dev/null
@@ -1,119 +0,0 @@
-// -*- 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) 2004-2012 Sage Weil <sage@newdream.net>
- *
- * 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_LIBRADOS_POOLASYNCCOMPLETIONIMPL_H
-#define CEPH_LIBRADOS_POOLASYNCCOMPLETIONIMPL_H
-
-#include "common/Cond.h"
-#include "common/Mutex.h"
-#include "include/Context.h"
-#include "include/rados/librados.h"
-#include "include/rados/librados.hpp"
-
-namespace librados {
-  struct PoolAsyncCompletionImpl {
-    Mutex lock;
-    Cond cond;
-    int ref, rval;
-    bool released;
-    bool done;
-
-    rados_callback_t callback;
-    void *callback_arg;
-
-    PoolAsyncCompletionImpl() : lock("PoolAsyncCompletionImpl lock"),
-                               ref(1), rval(0), released(false), done(false),
-                               callback(0), callback_arg(0) {}
-
-    int set_callback(void *cb_arg, rados_callback_t cb) {
-      lock.Lock();
-      callback = cb;
-      callback_arg = cb_arg;
-      lock.Unlock();
-      return 0;
-    }
-    int wait() {
-      lock.Lock();
-      while (!done)
-       cond.Wait(lock);
-      lock.Unlock();
-      return 0;
-    }
-    int is_complete() {
-      lock.Lock();
-      int r = done;
-      lock.Unlock();
-      return r;
-    }
-    int get_return_value() {
-      lock.Lock();
-      int r = rval;
-      lock.Unlock();
-      return r;
-    }
-    void get() {
-      lock.Lock();
-      assert(ref > 0);
-      ref++;
-      lock.Unlock();
-    }
-    void release() {
-      lock.Lock();
-      assert(!released);
-      released = true;
-      put_unlock();
-    }
-    void put() {
-      lock.Lock();
-      put_unlock();
-    }
-    void put_unlock() {
-      assert(ref > 0);
-      int n = --ref;
-      lock.Unlock();
-      if (!n)
-       delete this;
-    }
-  };
-
-  class C_PoolAsync_Safe : public Context {
-    PoolAsyncCompletionImpl *c;
-
-  public:
-    explicit C_PoolAsync_Safe(PoolAsyncCompletionImpl *_c) : c(_c) {
-      c->get();
-    }
-    ~C_PoolAsync_Safe() override {
-      c->put();
-    }
-  
-    void finish(int r) override {
-      c->lock.Lock();
-      c->rval = r;
-      c->done = true;
-      c->cond.Signal();
-
-      if (c->callback) {
-       rados_callback_t cb = c->callback;
-       void *cb_arg = c->callback_arg;
-       c->lock.Unlock();
-       cb(c, cb_arg);
-       c->lock.Lock();
-      }
-
-      c->lock.Unlock();
-    }
-  };
-}
-#endif