PostgreSQL中WaitEventSet的超时如何实现

本文涉及的产品
云原生数据库 PolarDB MySQL 版,Serverless 5000PCU 100GB
云原生数据库 PolarDB PostgreSQL 版,企业版 4核16GB
推荐场景:
HTAP混合负载
云原生数据库 PolarDB MySQL 版,通用型 2核4GB 50GB
简介: PostgreSQL中WaitEventSet的超时如何实现

PostgreSQLWaitEventSet的超时如何实现WaitEventSet的等待超时如何实现?我们了解到,它和epoll有关,首先先了解下epoll_wait这个函数:


int epoll_wait(
  int epfd,//epoll_create函数返回的epoll实例的句柄
  struct epoll_event * events, //出参。Epoll将发生的事件集合从内核复制到该数组
  int maxevents, //本次可以返回的最大事件数目
  int timeout//超时时间。-1:阻塞;0:不阻塞;>0:等待超时时间,单位ms
);

返回值:0:表示等待超时;>0:返回需要处理的事件数目;-1:出错错误标签:

  • EBADFepfd是一个非法的文件描述符
  • EFAULT:事件指向的内存区域无法使用写权限访问
  • EINTR:请求的任何事件发生前或者超时到期前,调用被信号处理程序中断
  • EINVALepdf不是epoll文件描述符,或者maxevents <=0

WaitEventSetWait
  if (timeout >= 0)
  {//timeout入参大于等于0,cur_timeout为当前时间
    INSTR_TIME_SET_CURRENT(start_time);
    cur_timeout = timeout;
  }
  while (returned_events == 0){
    rc = WaitEventSetWaitBlock(set, cur_timeout,occurred_events, nevents);
    |--  rc = epoll_wait(set->epoll_fd, set->epoll_ret_events,nevents, cur_timeout);
    |  if (rc < 0){
    |    return 0;//出错
    |  }else if (rc == 0){
    |    return -1;//超时
    |  }
    |  ...
    |--  return returned_events;//需要处理的事件数
    if (rc == -1)
      break;/* timeout occurred */
    else
      returned_events = rc;
    if (returned_events == 0 && timeout >= 0)
    {//epoll_wait出错,并且设置了超时时间
      INSTR_TIME_SET_CURRENT(cur_time);//cur_timeout=timeout-(cur_time-start_time)
      INSTR_TIME_SUBTRACT(cur_time, start_time);
      cur_timeout = timeout - (long) INSTR_TIME_GET_MILLISEC(cur_time);
      if (cur_timeout <= 0)
        break;
    }
  }//如果因出错退出epoll_wait则继续循环下去进行epoll_wait等待,直到超时
相关实践学习
使用PolarDB和ECS搭建门户网站
本场景主要介绍基于PolarDB和ECS实现搭建门户网站。
阿里云数据库产品家族及特性
阿里云智能数据库产品团队一直致力于不断健全产品体系,提升产品性能,打磨产品功能,从而帮助客户实现更加极致的弹性能力、具备更强的扩展能力、并利用云设施进一步降低企业成本。以云原生+分布式为核心技术抓手,打造以自研的在线事务型(OLTP)数据库Polar DB和在线分析型(OLAP)数据库Analytic DB为代表的新一代企业级云原生数据库产品体系, 结合NoSQL数据库、数据库生态工具、云原生智能化数据库管控平台,为阿里巴巴经济体以及各个行业的企业客户和开发者提供从公共云到混合云再到私有云的完整解决方案,提供基于云基础设施进行数据从处理、到存储、再到计算与分析的一体化解决方案。本节课带你了解阿里云数据库产品家族及特性。
目录
相关文章
|
10月前
|
SQL 监控 关系型数据库
Navicat 面向 PostgreSQL 查询超时的工具解决方案
Navicat 面向 PostgreSQL 查询超时的工具解决方案
141 0
|
关系型数据库 PostgreSQL
PostgreSQL pg_ctl start超时分析
PostgreSQL pg_ctl start超时分析
124 0
|
关系型数据库 分布式数据库 PolarDB
|
关系型数据库 分布式数据库 定位技术
PolarDB for PostgreSQL 开源必读手册-VACUUM处理(中)
PolarDB for PostgreSQL 开源必读手册-VACUUM处理
130 0
|
关系型数据库 分布式数据库 PolarDB
《阿里云产品手册2022-2023 版》——PolarDB for PostgreSQL
《阿里云产品手册2022-2023 版》——PolarDB for PostgreSQL
334 0
|
存储 缓存 关系型数据库
|
存储 SQL 并行计算
PolarDB for PostgreSQL 开源必读手册-开源PolarDB for PostgreSQL架构介绍(中)
PolarDB for PostgreSQL 开源必读手册-开源PolarDB for PostgreSQL架构介绍
382 0
|
存储 算法 安全
PolarDB for PostgreSQL 开源必读手册-开源PolarDB for PostgreSQL架构介绍(下)
PolarDB for PostgreSQL 开源必读手册-开源PolarDB for PostgreSQL架构介绍
349 0
|
关系型数据库 分布式数据库 开发工具