greenplumn CException 源码

greenplumn CException 代码

文件路径：/src/backend/gporca/libgpos/src/error/CException.cpp

//---------------------------------------------------------------------------
//	Greenplum Database
//	Copyright (C) 2008 - 2010 Greenplum, Inc.
//
//	@filename:
//		CException.cpp
//
//	@doc:
//		Implements simplified exception handling.
//---------------------------------------------------------------------------

#include "gpos/error/CException.h"

#include "gpos/common/clibwrapper.h"
#include "gpos/error/CErrorContext.h"
#include "gpos/task/CTask.h"

using namespace gpos;

const CHAR *CException::m_severity[] = {"INVALID", "ERROR", "WARNING", "NOTICE",
										"TRACE"};


// invalid exception
const CException CException::m_invalid_exception(CException::ExmaInvalid,
												 CException::ExmiInvalid);

// standard SQL error codes
const CException::ErrCodeElem CException::m_errcode[] = {
	{ExmiSQLDefault, "XX000"},					 // internal error
	{ExmiSQLNotNullViolation, "23502"},			 // not null violation
	{ExmiSQLCheckConstraintViolation, "23514"},	 // check constraint violation
	{ExmiSQLMaxOneRow, "P0003"},				 // max one row
	{ExmiSQLTest, "XXXXX"}						 // test sql state
};


//---------------------------------------------------------------------------
//	@function:
//		CException::CException
//
//	@doc:
//		Constructor for exception record; given the situation in which
//		exceptions are raised, init all elements, do not allocate any memory
//		dynamically
//
//---------------------------------------------------------------------------
CException::CException(ULONG major, ULONG minor, const CHAR *filename,
					   ULONG line)
	: m_major(major),
	  m_minor(minor),
	  m_filename(const_cast<CHAR *>(filename)),
	  m_line(line)
{
	m_sql_state = GetSQLState(major, minor);
}

//---------------------------------------------------------------------------
//	@function:
//		CException::CException
//
//	@doc:
//		Constructor for exception record; this version typically stored
//		in lookup structures etc.
//
//---------------------------------------------------------------------------
CException::CException(ULONG major, ULONG minor)
	: m_major(major), m_minor(minor), m_filename(nullptr), m_line(0)
{
	m_sql_state = GetSQLState(major, minor);
}


//---------------------------------------------------------------------------
//	@function:
//		CException::Raise
//
//	@doc:
//		Actual point where an exception is thrown; encapsulated in a function
//		(a) to facilitate debugging, i.e. function to set a breakpoint
//		(b) to allow for additional debugging tools such as stack dumps etc.
//			at a later point in time
//
//---------------------------------------------------------------------------
void
CException::Raise(const CHAR *filename, ULONG line, ULONG major, ULONG minor,
				  ...)
{
	// manufacture actual exception object
	CException exc(major, minor, filename, line);

	// during bootstrap there's no context object otherwise, record
	// all details in the context object
	if (nullptr != ITask::Self())
	{
		CErrorContext *err_ctxt = CTask::Self()->ConvertErrCtxt();

		VA_LIST va_list;
		VA_START(va_list, minor);

		err_ctxt->Record(exc, va_list);

		VA_END(va_list);

		err_ctxt->Serialize();
	}

	Raise(exc);
}


//---------------------------------------------------------------------------
//	@function:
//		CException::Reraise
//
//	@doc:
//		Throw/rethrow interface to reraise an already caught exc;
//		Wrapper that asserts there is a pending error;
//
//---------------------------------------------------------------------------
void
CException::Reraise(CException exc, BOOL propagate)
{
	if (nullptr != ITask::Self())
	{
		CErrorContext *err_ctxt = CTask::Self()->ConvertErrCtxt();
		GPOS_ASSERT(err_ctxt->IsPending());

		err_ctxt->SetRethrow();

		// serialize registered objects when current task propagates
		// an exception thrown by a child task
		if (propagate)
		{
			err_ctxt->GetStackDescriptor()->BackTrace();
			err_ctxt->Serialize();
		}
	}

	Raise(exc);
}


//---------------------------------------------------------------------------
//	@function:
//		CException::Raise
//
//	@doc:
//		Throw/rethrow interface
//
//---------------------------------------------------------------------------
void
CException::Raise(CException exc)
{
#ifdef GPOS_DEBUG
	if (nullptr != ITask::Self())
	{
		IErrorContext *err_ctxt = ITask::Self()->GetErrCtxt();
		GPOS_ASSERT_IMP(err_ctxt->IsPending(),
						err_ctxt->GetException() == exc &&
							"Rethrow inconsistent with current error context");
	}
#endif	// GPOS_DEBUG

	throw exc;
}

//---------------------------------------------------------------------------
//	@function:
//		CException::GetSQLState
//
//	@doc:
//		Get sql state code for exception
//
//---------------------------------------------------------------------------
const CHAR *
CException::GetSQLState(ULONG major, ULONG minor)
{
	const CHAR *sql_state = m_errcode[0].m_sql_state;
	if (ExmaSQL == major)
	{
		ULONG sql_states = GPOS_ARRAY_SIZE(m_errcode);
		for (ULONG ul = 0; ul < sql_states; ul++)
		{
			ErrCodeElem errcode = m_errcode[ul];
			if (minor == errcode.m_exception_num)
			{
				sql_state = errcode.m_sql_state;
				break;
			}
		}
	}

	return sql_state;
}

// EOF

相关信息

greenplumn 源码目录

相关文章

greenplumn CAutoExceptionStack 源码

greenplumn CAutoTrace 源码

greenplumn CErrorContext 源码

greenplumn CErrorHandlerStandard 源码

greenplumn CLogger 源码

greenplumn CLoggerStream 源码

greenplumn CLoggerSyslog 源码

greenplumn CMessage 源码

greenplumn CMessageRepository 源码

greenplumn CMessageTable 源码