X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmsg%2Fasync%2Fdpdk%2Ftransfer.h;fp=src%2Fceph%2Fsrc%2Fmsg%2Fasync%2Fdpdk%2Ftransfer.h;h=599db5bd00bdf69ac086011cad4014a894a6f0c7;hb=812ff6ca9fcd3e629e49d4328905f33eee8ca3f5;hp=0000000000000000000000000000000000000000;hpb=15280273faafb77777eab341909a3f495cf248d9;p=stor4nfv.git diff --git a/src/ceph/src/msg/async/dpdk/transfer.h b/src/ceph/src/msg/async/dpdk/transfer.h new file mode 100644 index 0000000..599db5b --- /dev/null +++ b/src/ceph/src/msg/async/dpdk/transfer.h @@ -0,0 +1,64 @@ +/* + * This file is open source software, licensed to you under the terms + * of the Apache License, Version 2.0 (the "License"). See the NOTICE file + * distributed with this work for additional information regarding copyright + * ownership. You may not use this file except in compliance with the License. + * + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +/* + * Copyright (C) 2014 Cloudius Systems, Ltd. + */ + +#ifndef CEPH_TRANSFER_H_ +#define CEPH_TRANSFER_H_ + +// Helper functions for copying or moving multiple objects in an exception +// safe manner, then destroying the sources. +// +// To transfer, call transfer_pass1(allocator, &from, &to) on all object pairs, +// (this copies the object from @from to @to). If no exceptions are encountered, +// call transfer_pass2(allocator, &from, &to). This destroys the object at the +// origin. If exceptions were encountered, simply destroy all copied objects. +// +// As an optimization, if the objects are moveable without throwing (noexcept) +// transfer_pass1() simply moves the objects and destroys the source, and +// transfer_pass2() does nothing. + +#include +#include + +template +inline void transfer_pass1(Alloc& a, T* from, T* to, + typename std::enable_if::value>::type* = nullptr) { + a.construct(to, std::move(*from)); + a.destroy(from); +} + +template +inline void transfer_pass2(Alloc& a, T* from, T* to, + typename std::enable_if::value>::type* = nullptr) { +} + +template +inline void transfer_pass1(Alloc& a, T* from, T* to, + typename std::enable_if::value>::type* = nullptr) { + a.construct(to, *from); +} + +template +inline void transfer_pass2(Alloc& a, T* from, T* to, + typename std::enable_if::value>::type* = nullptr) { + a.destroy(from); +} + +#endif /* CEPH_TRANSFER_H_ */