X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrados%2FPoolAsyncCompletionImpl.h;fp=src%2Fceph%2Fsrc%2Flibrados%2FPoolAsyncCompletionImpl.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=e876db756fc85fdb8fbc023e8e89293f6d53d9d6;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/librados/PoolAsyncCompletionImpl.h b/src/ceph/src/librados/PoolAsyncCompletionImpl.h
deleted file mode 100644
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