X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;ds=sidebyside;f=folly%2FScopeGuard.h;h=ad96afdc4c5a37a1a9944437d1b77a9b8daba591;hb=9b2f7afe192834fdc4abc5687abc072bede25cd6;hp=ae1bae672d22ee15603faee0aeeb43303034714d;hpb=27494a20393fa45072e7d526d358835f3abe312a;p=folly.git diff --git a/folly/ScopeGuard.h b/folly/ScopeGuard.h index ae1bae67..ad96afdc 100644 --- a/folly/ScopeGuard.h +++ b/folly/ScopeGuard.h @@ -1,5 +1,5 @@ /* - * Copyright 2012 Facebook, Inc. + * Copyright 2017 Facebook, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -14,20 +14,22 @@ * limitations under the License. */ -#ifndef FOLLY_SCOPEGUARD_H_ -#define FOLLY_SCOPEGUARD_H_ +#pragma once #include #include #include -#include +#include +#include -#include "folly/Preprocessor.h" +#include +#include +#include namespace folly { /** - * ScopeGuard is a general implementation of the "Initilization is + * ScopeGuard is a general implementation of the "Initialization is * Resource Acquisition" idiom. Basically, it guarantees that a function * is executed upon leaving the currrent scope unless otherwise told. * @@ -36,7 +38,8 @@ namespace folly { * a functor, or a void(*)() function pointer. * * - * Usage example: Add a friend to memory iff it is also added to the db. + * Usage example: Add a friend to memory if and only if it is also added + * to the db. * * void User::addFriend(User& newFriend) { * // add the friend to memory @@ -73,30 +76,69 @@ class ScopeGuardImplBase { dismissed_ = true; } + template + FOLLY_ALWAYS_INLINE static void runAndWarnAboutToCrashOnException( + T& function) noexcept { + try { + function(); + } catch (...) { + warnAboutToCrash(); + std::terminate(); + } + } + protected: - ScopeGuardImplBase() - : dismissed_(false) {} + ScopeGuardImplBase() noexcept : dismissed_(false) {} - ScopeGuardImplBase(ScopeGuardImplBase&& other) - : dismissed_(other.dismissed_) { - other.dismissed_ = true; + static ScopeGuardImplBase makeEmptyScopeGuard() noexcept { + return ScopeGuardImplBase{}; + } + + template + static const T& asConst(const T& t) noexcept { + return t; } bool dismissed_; + + private: + static void warnAboutToCrash() noexcept; }; -template +template class ScopeGuardImpl : public ScopeGuardImplBase { public: - explicit ScopeGuardImpl(const FunctionType& fn) - : function_(fn) {} + explicit ScopeGuardImpl(FunctionType& fn) noexcept( + std::is_nothrow_copy_constructible::value) + : ScopeGuardImpl( + asConst(fn), + makeFailsafe(std::is_nothrow_copy_constructible{}, + &fn)) {} - explicit ScopeGuardImpl(FunctionType&& fn) - : function_(std::move(fn)) {} + explicit ScopeGuardImpl(const FunctionType& fn) noexcept( + std::is_nothrow_copy_constructible::value) + : ScopeGuardImpl( + fn, + makeFailsafe(std::is_nothrow_copy_constructible{}, + &fn)) {} - ScopeGuardImpl(ScopeGuardImpl&& other) - : ScopeGuardImplBase(std::move(other)), - function_(std::move(other.function_)) { + explicit ScopeGuardImpl(FunctionType&& fn) noexcept( + std::is_nothrow_move_constructible::value) + : ScopeGuardImpl( + std::move_if_noexcept(fn), + makeFailsafe(std::is_nothrow_move_constructible{}, + &fn)) {} + + ScopeGuardImpl(ScopeGuardImpl&& other) noexcept( + std::is_nothrow_move_constructible::value) + : function_(std::move_if_noexcept(other.function_)) { + // If the above line attempts a copy and the copy throws, other is + // left owning the cleanup action and will execute it (or not) depending + // on the value of other.dismissed_. The following lines only execute + // if the move/copy succeeded, in which case *this assumes ownership of + // the cleanup action and dismisses other. + dismissed_ = other.dismissed_; + other.dismissed_ = true; } ~ScopeGuardImpl() noexcept { @@ -105,26 +147,37 @@ class ScopeGuardImpl : public ScopeGuardImplBase { } } -private: - void* operator new(size_t) = delete; + private: + static ScopeGuardImplBase makeFailsafe(std::true_type, const void*) noexcept { + return makeEmptyScopeGuard(); + } + + template + static auto makeFailsafe(std::false_type, Fn* fn) noexcept + -> ScopeGuardImpl { + return ScopeGuardImpl{std::ref(*fn)}; + } + + template + explicit ScopeGuardImpl(Fn&& fn, ScopeGuardImplBase&& failsafe) + : ScopeGuardImplBase{}, function_(std::forward(fn)) { + failsafe.dismiss(); + } + + void* operator new(std::size_t) = delete; void execute() noexcept { - try { - function_(); - } catch (const std::exception& ex) { - LOG(FATAL) << "ScopeGuard cleanup function threw a " << - typeid(ex).name() << "exception: " << ex.what(); - } catch (...) { - LOG(FATAL) << "ScopeGuard cleanup function threw a non-exception object"; - } + runAndWarnAboutToCrashOnException(function_); } FunctionType function_; }; -template +template ScopeGuardImpl::type> -makeGuard(FunctionType&& fn) { +makeGuard(FunctionType&& fn) noexcept( + std::is_nothrow_constructible::type, + FunctionType>::value) { return ScopeGuardImpl::type>( std::forward(fn)); } @@ -135,6 +188,85 @@ makeGuard(FunctionType&& fn) { typedef ScopeGuardImplBase&& ScopeGuard; namespace detail { + +#if defined(FOLLY_EXCEPTION_COUNT_USE_CXA_GET_GLOBALS) || \ + defined(FOLLY_EXCEPTION_COUNT_USE_GETPTD) || \ + defined(FOLLY_EXCEPTION_COUNT_USE_STD) + +/** + * ScopeGuard used for executing a function when leaving the current scope + * depending on the presence of a new uncaught exception. + * + * If the executeOnException template parameter is true, the function is + * executed if a new uncaught exception is present at the end of the scope. + * If the parameter is false, then the function is executed if no new uncaught + * exceptions are present at the end of the scope. + * + * Used to implement SCOPE_FAIL and SCOPE_SUCCESS below. + */ +template +class ScopeGuardForNewException { + public: + explicit ScopeGuardForNewException(const FunctionType& fn) + : function_(fn) { + } + + explicit ScopeGuardForNewException(FunctionType&& fn) + : function_(std::move(fn)) { + } + + ScopeGuardForNewException(ScopeGuardForNewException&& other) + : function_(std::move(other.function_)) + , exceptionCounter_(std::move(other.exceptionCounter_)) { + } + + ~ScopeGuardForNewException() noexcept(executeOnException) { + if (executeOnException == exceptionCounter_.isNewUncaughtException()) { + if (executeOnException) { + ScopeGuardImplBase::runAndWarnAboutToCrashOnException(function_); + } else { + function_(); + } + } + } + + private: + ScopeGuardForNewException(const ScopeGuardForNewException& other) = delete; + + void* operator new(std::size_t) = delete; + + FunctionType function_; + UncaughtExceptionCounter exceptionCounter_; +}; + +/** + * Internal use for the macro SCOPE_FAIL below + */ +enum class ScopeGuardOnFail {}; + +template +ScopeGuardForNewException::type, true> +operator+(detail::ScopeGuardOnFail, FunctionType&& fn) { + return + ScopeGuardForNewException::type, true>( + std::forward(fn)); +} + +/** + * Internal use for the macro SCOPE_SUCCESS below + */ +enum class ScopeGuardOnSuccess {}; + +template +ScopeGuardForNewException::type, false> +operator+(ScopeGuardOnSuccess, FunctionType&& fn) { + return + ScopeGuardForNewException::type, false>( + std::forward(fn)); +} + +#endif // native uncaught_exception() supported + /** * Internal use for the macro SCOPE_EXIT below */ @@ -152,6 +284,16 @@ operator+(detail::ScopeGuardOnExit, FunctionType&& fn) { #define SCOPE_EXIT \ auto FB_ANONYMOUS_VARIABLE(SCOPE_EXIT_STATE) \ - = ::folly::detail::ScopeGuardOnExit() + [&] + = ::folly::detail::ScopeGuardOnExit() + [&]() noexcept + +#if defined(FOLLY_EXCEPTION_COUNT_USE_CXA_GET_GLOBALS) || \ + defined(FOLLY_EXCEPTION_COUNT_USE_GETPTD) || \ + defined(FOLLY_EXCEPTION_COUNT_USE_STD) +#define SCOPE_FAIL \ + auto FB_ANONYMOUS_VARIABLE(SCOPE_FAIL_STATE) \ + = ::folly::detail::ScopeGuardOnFail() + [&]() noexcept -#endif // FOLLY_SCOPEGUARD_H_ +#define SCOPE_SUCCESS \ + auto FB_ANONYMOUS_VARIABLE(SCOPE_SUCCESS_STATE) \ + = ::folly::detail::ScopeGuardOnSuccess() + [&]() +#endif // native uncaught_exception() supported