Postgresql源码（118）elog/ereport报错跳转功能分析

news2024/11/23 21:11:46

1 日志接口

elog.c完成PG中日志的生产、记录工作，对外常用接口如下：

1.1 最常用的ereport和elog

ereport(ERROR,
			(errcode(ERRCODE_UNDEFINED_TABLE),
			 errmsg("relation \"%s\" does not exist",
			   relation->relname)));

elog(ERROR, "unexpected enrtype: %d", enrmd->enrtype);

其实都是在调用errstart和errfinish函数完成具体工作。

#define elog(elevel, ...)  \
	ereport(elevel, errmsg_internal(__VA_ARGS__))

#define ereport(elevel, ...)	\
	ereport_domain(elevel, TEXTDOMAIN, __VA_ARGS__)

#define ereport_domain(elevel, domain, ...)	\
	do { \
		pg_prevent_errno_in_scope(); \
		if (__builtin_constant_p(elevel) && (elevel) >= ERROR ? \
			errstart_cold(elevel, domain) : \
			errstart(elevel, domain)) \
			__VA_ARGS__, errfinish(__FILE__, __LINE__, __func__); \
		if (__builtin_constant_p(elevel) && (elevel) >= ERROR) \
			pg_unreachable(); \
	} while(0)

2 日志数据结构

  • 单条日志被抽象为ErrorData，记录了日志的全部信息。
  • elog.c提供了一个深度为5的stack来存放最多五层的ErrorData，大部分场景下，stack只会使用一层：
#define ERRORDATA_STACK_SIZE  5
static ErrorData errordata[ERRORDATA_STACK_SIZE];

在这里插入图片描述

3 日志的工作流程

每一条日志都是经过errstart和errfinish函数处理的，分工大致为：

  • errstart
    1. 在errdata堆栈中压入一个新的edata
    2. 为edata填充部分错误信息，例如错误等级、需要输出到server/client、按需升级错误等级（例如Crit区域中大于等于ERROR的需要变成PINIC）
  • errfinish
    1. 在进入errfinish前，错误信息的文本经过errmsg或errmsg_internal函数中的EVALUATE_MESSAGE宏记入edata中的message中，内存用的是errfinish
    2. 三部分工作：
      • 3.1 完成PG_TRY()、PG_CATCH()跳转功能，为errfinish添加try/catch功能
      • 3.2 完成error_context_stack的回调功能，为errfinish增加报错信息
      • 3.3 完成EmitErrorReport，为errfinish发送错误信息

3.1 完成PG_TRY()、PG_CATCH()跳转功能，为errfinish添加try/catch功能

注意PG_CATCH和PG_FINALLY是二选一的，区别是PG_FINALLY会在最后把异常重新抛出去，而PG_CATCH自己处理完了就不在向上抛了。

#define PG_TRY()  \
	do { \
		sigjmp_buf *_save_exception_stack = PG_exception_stack; \
		ErrorContextCallback *_save_context_stack = error_context_stack; \
		sigjmp_buf _local_sigjmp_buf; \
		bool _do_rethrow = false; \
		if (sigsetjmp(_local_sigjmp_buf, 0) == 0) \
		{ \
			PG_exception_stack = &_local_sigjmp_buf

#define PG_CATCH(...)	\
		} \
		else \
		{ \
			PG_exception_stack = _save_exception_stack; \
			error_context_stack = _save_context_stack

#define PG_FINALLY() \
		} \
		else \
			_do_rethrow = true; \
		{ \
			PG_exception_stack = _save_exception_stack; \
			error_context_stack = _save_context_stack

#define PG_END_TRY()  \
		} \
		if (_do_rethrow) \
				PG_RE_THROW(); \
		PG_exception_stack = _save_exception_stack; \
		error_context_stack = _save_context_stack; \
	} while (0)

我们先看一个PG中常规的报错流程，注意是不在PG_TRY中的elog(ERROR)，发生>=ERROR级别的异常后，在errfinish中会抛出异常，jmp到PostgresMain函数中的sigsetjmp的位置，进入异常回收流程。
在这里插入图片描述
那么如果代码中的报错被PG_TRY、PG_CATCH包裹时，抛出异常会发生什么呢？
在这里插入图片描述

3.2 完成error_context_stack的回调功能，为errfinish增加报错信息

error_context_stack是一个Lisrt记录了回调函数回调函数的参数，这里的函数的作用是添加报错信息，因为这些函数会在errfinish时被调用，函数中往往都会使用errcontext_msg记录一些更详细的报错文本。

typedef struct ErrorContextCallback
{
	struct ErrorContextCallback *previous;
	void		(*callback) (void *arg);
	void	   *arg;
} ErrorContextCallback;

extern PGDLLIMPORT ErrorContextCallback *error_context_stack;

例如pl编译时配置的plpgsql_compile_error_callback函数，为了增加编译报错时，错误的发生的位置等：

do_compile
	...
	plerrcontext.callback = plpgsql_compile_error_callback;
	plerrcontext.arg = forValidator ? proc_source : NULL;
	plerrcontext.previous = error_context_stack;
	error_context_stack = &plerrcontext;
	...

static void
plpgsql_compile_error_callback(void *arg)
{
	if (arg)
	{
		/*
		 * Try to convert syntax error position to reference text of original
		 * CREATE FUNCTION or DO command.
		 */
		if (function_parse_error_transpose((const char *) arg))
			return;

		/*
		 * Done if a syntax error position was reported; otherwise we have to
		 * fall back to a "near line N" report.
		 */
	}

	if (plpgsql_error_funcname)
		errcontext("compilation of PL/pgSQL function \"%s\" near line %d",
				   plpgsql_error_funcname, plpgsql_latest_lineno());
}

error_context_stack和上面提到的PG_exception_stack都会在TRY中进行保存和恢复，为什么：

  • PG_exception_stack比较好理解，因为TRY时会建一个新的jmpbuf用PG_exception_stack指向，之前的旧值需要记录下来，TRY完了需要恢复。
  • error_context_stack的回调函数是在子模块中配置的，正常执行完子模块会把error_context_stack恢复原样，但一旦error发生了跳转，恢复逻辑就被跳过了。所以在TRY中自带了恢复error_context_stack的逻辑。

3.3 完成EmitErrorReport，为errfinish发送错误信息

errfinish
	...
	...
	EmitErrorReport
	...
	...

EmitErrorReport函数中会执行发送逻辑：

EmitErrorReport
	...
	if (edata->output_to_server && emit_log_hook)
		(*emit_log_hook) (edata);

	/* Send to server log, if enabled */
	if (edata->output_to_server)
		send_message_to_server_log(edata);    // 写 write_syslog

	/* Send to client, if enabled */
	if (edata->output_to_client)
		send_message_to_frontend(edata);      // 写libpq，发送到客户端或主进程

4 CopyErrorData / FlushErrorState / FreeErrorData

由于edata中的信息是在ErrorContext中申请的，在PG_CATCH时，是能拿到edata使用的，但在catch时不应该使用ErrorContext申请任何内存，所以惯用法是在PG_CATCH中用CopyErrorData把edata拷贝到当前的上下文中，在进行操作。然后把ErrorContext中的edata用FlushErrorState清理干净。

例如PL中的用法

		PG_CATCH();
		{
			ErrorData  *edata;
			...
			...
			/* Save error info in our stmt_mcontext */
			MemoryContextSwitchTo(stmt_mcontext);
			
			// 拷贝edata到当前上下文中
			edata = CopyErrorData();
			// ErrorContext中的用完尽快释放
			FlushErrorState();

			...
			...
			// 尽情使用使用edata
			exception_matches_conditions(edata, exception->conditions)
			...
			...

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1327255.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

重塑数字生产力体系，生成式AI将开启云计算未来新十年？

重塑数字生产力体系，生成式AI将开启云计算未来新十年？

科技云报道原创。 今天我们正身处一个历史的洪流，一个巨变的十字路口。生成式AI让人工智能技术完全破圈，带来了机器学习被大规模采用的历史转折点。 它掀起的新一轮科技革命，远超出我们今天的想象，这意味着一个巨大的历史机遇正…
阅读更多...
Hbase的安装配置

Hbase的安装配置

注：本文默认已经完成hadoop的下载以及环境配置 1.上传zookeeper和hbase压缩包到指令路径并且解压 (理论上讲，hbase其实内置了zookeeper，我们也可以不另外下载，另外下载的目的在于减少组件间依赖性) cd /home mkir hbase cd /hom…
阅读更多...
IDEA 黑色主题很难看到鼠标

IDEA 黑色主题很难看到鼠标

“控制面板”—搜索“鼠标”关键字—选择“更改鼠标设置” 参考： IDEA 黑色主题很难看到鼠标
阅读更多...
ansible的脚本-----playbook剧本

ansible的脚本-----playbook剧本

ansible的脚本-----playbook剧本 playbook组成部分： 1、tasks任务：包含要在目标主机上执行的操作，使用模块定义这些操作。每个任务都是一个模块的调用 2、variables变量：存储和传递数据，变量可以自定义，…
阅读更多...
WeakMap 和 WeakSet：解决内存泄漏避免循环引用(上)

WeakMap 和 WeakSet：解决内存泄漏避免循环引用(上)

🤍 前端开发工程师（主业）、技术博主（副业）、已过CET6 🍨 阿珊和她的猫_CSDN个人主页 🕠 牛客高级专题作者、在牛客打造高质量专栏《前端面试必备》 🍚 蓝桥云课签约作者、已在蓝桥云…
阅读更多...
React组件状态管理

React组件状态管理

React组件的状态管理是一个很重要的内容。从字面来理解，按钮是否可单击、图片是否显示等，这些都是状态。广义来讲，React组件的状态还1包括传入React的数据，例如某个组件要展示列表，列表的数据也是该组件的状态。总之&a…
阅读更多...
Dynamic Coarse-to-Fine Learning for Oriented Tiny Object Detection（CVPR2023待补）

Dynamic Coarse-to-Fine Learning for Oriented Tiny Object Detection（CVPR2023待补）

文章目录 BeginningAbstract挑战方法成果 Introduction引出问题早期的work及存在的问题近期的work及存在的问题our workContribution Related Work（paper for me）Oriented Object DetectionPrior for Oriented ObjectsLabel Assignment Tiny Object Dete…
阅读更多...
【算法】算法题-20231221

【算法】算法题-20231221

这里写目录标题 一、830. 较大分组的位置二、657. 机器人能否返回原点三、771. 宝石与石头 一、830. 较大分组的位置 在一个由小写字母构成的字符串 s 中，包含由一些连续的相同字符所构成的分组。 例如，在字符串 s "abbxxxxzyy"中&#xff0…
阅读更多...
【XML】TinyXML 详解

【XML】TinyXML 详解

1、简介 优点： TinyXML 是一个简单、小型的 C XML 解析器，可以轻松集成到项目中。 TinyXML 解析 XML 文档，并根据该文档构建可读取、修改和保存的文档对象模型 (DOM) TinyXML 是在 ZLib 许可下发布的，因此可以在开源或商业代码中…
阅读更多...
【SQL题目】连续日期的判断

【SQL题目】连续日期的判断

【1.查询至少连续3天下单的用户】 思路1（使用lead）： distinct user_id,create_date去重，确保每个用户每天只有一条访问记录lead(create_date,2,‘9999-12-31’) over(partition by user_id order by create_date)根据用户分区&am…
阅读更多...
模型实战（18）之C++ - tensorRT部署GAN模型实现人脸超分辨重建

模型实战（18）之C++ - tensorRT部署GAN模型实现人脸超分辨重建

模型实战（18）之C++ - tensorRT部署GAN模型实现人脸超分辨重建 一个实现人脸超分辨率重建的demo支持StyleGAN: GPEN or GFPGAN通过C++ - tensorrt 快速部署，推理速度每帧 在RTX3090上5.5ms+，RTX3050上10ms+下边是实现效果（图片来源于网络search，如若侵权，联系删除） 下边…
阅读更多...
AI Native工程化：百度App AI互动技术实践

AI Native工程化：百度App AI互动技术实践

作者 | GodStart 导读 随着AI浪潮的兴起，越来越多的应用都在利用大模型重构业务形态，在设计和优化Prompt的过程中，我们发现整个Prompt测评和优化周期非常长，因此，我们提出了一种Prompt生成、评估与迭代的一体化解决方案…
阅读更多...
YashanDB个人版体验总结

YashanDB个人版体验总结

前言 YashanDB数据库具有多项功能特性。首先，它是一个分布式数据库，支持水平扩展，能够将数据分散到多个节点上，从而提高系统的可靠性和性能。其次，YashanDB数据库具备高可用性，支持主从复制和自动故障转移…
阅读更多...
竞赛保研 基于Django与深度学习的股票预测系统

竞赛保研 基于Django与深度学习的股票预测系统

文章目录 0 前言1 课题背景2 实现效果3 Django框架4 数据整理5 模型准备和训练6 最后 0 前言 🔥 优质竞赛项目系列，今天要分享的是 🚩 **基于Django与深度学习的股票预测系统 ** 该项目较为新颖，适合作为竞赛课题方向&#xff…
阅读更多...
VS ASP.Net Core项目还原Packages包到本地（解决服务器没有网无法重新生成的问题）

VS ASP.Net Core项目还原Packages包到本地（解决服务器没有网无法重新生成的问题）

问题背景 ASP.Net Core MVC项目，无法重新生成。 现场服务器没有网,放上去的代码无法通过nuget还原包到服务器，导致无法编译无法运行。 解决办法 将Packages还原到本机（有网），然后再将代码放到服务器运行。 在有网的…
阅读更多...
KoPA: Making Large Language Models Perform Better in Knowledge Graph Completion

KoPA: Making Large Language Models Perform Better in Knowledge Graph Completion

本来这个论文用来组会讲的，但是冲突了，没怎么讲，记录一下供以后学习。 创新点 按照我的理解简单概述一下这篇论文的创新点 提出使用大模型补全知识图谱，并且融合知识图谱的结构信息提出一个新的模型KoPA模型，采用少…
阅读更多...
Excel 获取当前行的行数

Excel 获取当前行的行数

ROW() 获取当前行 ROW()1 获取当前行然后支持二次开发
阅读更多...
java基础入门-23-【网络编程】

java基础入门-23-【网络编程】

java基础入门-23-【网络编程】 32、网络编程1.什么是网络编程2.网络编程三要素1.1 IP1.2 总结1.3 IPV4的地址分类形式1.4 常见的CMD命令1.5 InetAddress类的使用1.6 端口和协议 2.UDP通信程序2.1 UDP发送数据2.2UDP接收数据2.3UDP通信程序练习2.4UDP三种通讯方式2.5UDP组播实现…
阅读更多...
more的详细用法

more的详细用法

概要&#xff1a; Linux中more的功能是分页显示文件内容 空格键显示下一屏(页)&#xff0c;回车键Enter显示下一行&#xff0c;q键退出 本篇所用系统是Ubuntu22.04 一、more filename more后面跟的是文件名&#xff0c;分页显示文件内容 二、more < filename more从…
阅读更多...
在MacOS上Qt配置OpenCV并进行测试

在MacOS上Qt配置OpenCV并进行测试

一.Qt环境准备 上一篇博客我讲了如何下载配置OpenCV库&#xff0c;但是在Qt5.15.2使用OpenCV库时&#xff0c;出现了一个问题就是我下载的Qt5.15.2是x86架构的&#xff0c;不能对OpenCV库进行链接&#xff0c;而OpenCV库是arm架构的 直接使用Qt5.15.2编译链接OpenCV库链接头文件…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023