NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Exceptions Namespace Reference

Classes

class  AccessNonLockedResourceException
 This exception is raised, in case a request tries to access a resource via the storage handler without having locked it before. More...
 
class  ExecutionNodeNotFoundException
 This exception indicates, that a lookup for an execution node in the global execution plan failed. More...
 
class  QueryUndeploymentException
 this exception indicates an error during the undeployment of a query More...
 
class  ResourceLockingException
 
class  RpcException
 This exception indicates the failure of an rpc. More...
 
class  RPCQueryUndeploymentException
 This exception indicates that an rpc to undeploy a query from a worker has failed. More...
 
class  StorageHandlerAcquireResourcesException
 
class  ErrorListener
 This is an error interceptor suitable for signals and exceptions. More...
 
class  NotImplementedException
 
class  RequestExecutionException
 This is the base class for exceptions thrown during the execution of coordinator side requests which indicate an error that possibly require a rollback or other kinds of specific error handling. More...
 
class  RuntimeException
 Exception to be used to report errors and stacktraces This is meant to be used for NES-related errors, wrap std exceptions with their own stacktrace, etc.. More...
 

Functions

void invokeErrorHandlers (int signal, std::string &&stacktrace)
 calls to this function will pass the signal to all system-wide error listeners More...
 
void invokeErrorHandlers (std::shared_ptr< std::exception > exception, std::string &&stacktrace)
 calls to this function will pass an exception to all system-wide error listeners More...
 
void invokeErrorHandlers (const std::string &buffer, std::string &&stacktrace)
 calls to this function will create a RuntimeException that is passed to all system-wide error listeners More...
 
void installGlobalErrorListener (std::shared_ptr< ErrorListener > const &listener)
 make an error listener system-wide More...
 
void removeGlobalErrorListener (const std::shared_ptr< ErrorListener > &listener)
 remove an error listener system-wide More...
 

Function Documentation

◆ installGlobalErrorListener()

void NES::Exceptions::installGlobalErrorListener ( std::shared_ptr< ErrorListener > const &  listener)

make an error listener system-wide

Parameters
listenerthe error listener to make system-wide

References NES_TRACE.

Referenced by main(), NES::Testing::BaseUnitTest::SetUp(), and NES::NesCoordinator::startCoordinator().

Here is the caller graph for this function:

◆ invokeErrorHandlers() [1/3]

void NES::Exceptions::invokeErrorHandlers ( const std::string &  buffer,
std::string &&  stacktrace 
)

calls to this function will create a RuntimeException that is passed to all system-wide error listeners

Parameters
bufferthe message of the exception
stacktracethe stacktrace of where the error was raised

References invokeErrorHandlers(), backward::details::move(), and NES_TRACE.

Here is the call graph for this function:

◆ invokeErrorHandlers() [2/3]

void NES::Exceptions::invokeErrorHandlers ( int  signal,
std::string &&  stacktrace 
)

calls to this function will pass the signal to all system-wide error listeners

Parameters
signalwhich indicates the error
stacktracethe stacktrace of where the error was raised

References NES::Logger::getInstance().

Referenced by invokeErrorHandlers(), NES::Runtime::detail::nesErrorHandler(), NES::Runtime::detail::nesTerminateHandler(), and NES::Runtime::detail::nesUnexpectedException().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ invokeErrorHandlers() [3/3]

void NES::Exceptions::invokeErrorHandlers ( std::shared_ptr< std::exception >  exception,
std::string &&  stacktrace 
)

calls to this function will pass an exception to all system-wide error listeners

Parameters
exceptionwhich indicates the error
stacktracethe stacktrace of where the error was raised

References NES::Logger::getInstance().

Here is the call graph for this function:

◆ removeGlobalErrorListener()

void NES::Exceptions::removeGlobalErrorListener ( const std::shared_ptr< ErrorListener > &  listener)

remove an error listener system-wide

Parameters
listenerthe error listener to remove system-wide

References NES_TRACE.

Referenced by NES::Testing::BaseUnitTest::TearDown().

Here is the caller graph for this function: