X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibradosstriper%2FMultiAioCompletionImpl.cc;fp=src%2Fceph%2Fsrc%2Flibradosstriper%2FMultiAioCompletionImpl.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=7bb21bc0e0e3c04a040ce257a55a8e7d5f816990;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/libradosstriper/MultiAioCompletionImpl.cc b/src/ceph/src/libradosstriper/MultiAioCompletionImpl.cc deleted file mode 100644 index 7bb21bc..0000000 --- a/src/ceph/src/libradosstriper/MultiAioCompletionImpl.cc +++ /dev/null @@ -1,71 +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) 2014 Sebastien Ponce - * - * 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. - * - */ - -#include "common/dout.h" - -#include "libradosstriper/MultiAioCompletionImpl.h" - -void libradosstriper::MultiAioCompletionImpl::complete_request(ssize_t r) -{ - lock.Lock(); - if (rval >= 0) { - if (r < 0 && r != -EEXIST) - rval = r; - else if (r > 0) - rval += r; - } - assert(pending_complete); - int count = --pending_complete; - if (!count && !building) { - complete(); - } - put_unlock(); -} - -void libradosstriper::MultiAioCompletionImpl::safe_request(ssize_t r) -{ - lock.Lock(); - if (rval >= 0) { - if (r < 0 && r != -EEXIST) - rval = r; - } - assert(pending_safe); - int count = --pending_safe; - if (!count && !building) { - safe(); - } - put_unlock(); -} - -void libradosstriper::MultiAioCompletionImpl::finish_adding_requests() -{ - lock.Lock(); - assert(building); - building = false; - if (!pending_complete) - complete(); - if (!pending_safe) - safe(); - lock.Unlock(); -} - -void intrusive_ptr_add_ref(libradosstriper::MultiAioCompletionImpl* ptr) -{ - ptr->get(); -} - -void intrusive_ptr_release(libradosstriper::MultiAioCompletionImpl* ptr) -{ - ptr->put(); -}