#include "SharedException.h"

Public Member Functions
void	store (std::exception_ptr ex_ptr)

void	store_current ()

template<typename T , typename... Args>
void	store (Args &&...args)

void	throw_if_stored_exception ()

Private Attributes
std::thread::id const	ownerThread_ {std::this_thread::get_id()}

std::atomic< bool >	cachedExceptionStored_ {false}

std::exception_ptr	cachedException_ {}

Detailed Description

Definition at line 18 of file SharedException.h.

Member Function Documentation

void art::SharedException::store ( std::exception_ptr ex_ptr )

inline

Definition at line 21 of file SharedException.h.

References cachedException_, and cachedExceptionStored_.

Referenced by art::EventProcessor::finishEventAsync(), art::EventProcessor::processEventAsync(), store(), and store_current().

     {
       bool expected = false;
       if (cachedExceptionStored_.compare_exchange_strong(expected, true)) {
         // Put the exception where the main thread can get at it.
         cachedException_ = std::move(ex_ptr);
       }
     }

template<typename T , typename... Args>

void art::SharedException::store ( Args &&... args )

inline

Definition at line 38 of file SharedException.h.

References store().

     {
       store(std::make_exception_ptr(T{std::forward<Args>(args)...}));
     }

void art::SharedException::store_current ( )

inline

Definition at line 31 of file SharedException.h.

References store().

Referenced by art::EventProcessor::finishEventAsync(), art::EventProcessor::processAllEventsAsync(), and art::EventProcessor::processEventAsync().

     {
       store(std::current_exception());
     }

void art::SharedException::throw_if_stored_exception ( )

inline

Definition at line 44 of file SharedException.h.

References cachedException_, cachedExceptionStored_, and ownerThread_.

Referenced by art::EventProcessor::process().

     {
       assert(std::this_thread::get_id() == ownerThread_);
       if (cachedExceptionStored_.load()) {
         std::rethrow_exception(cachedException_);
       }
     }