pg源码阅读三
2016-07-19 22:34
211 查看
之前提到,bgwriter没有检查点就执行BgBufferSync();刷新buffer,下马继续看下多久执行一次,主要是通过BgWriterNap()来配置等待时间
/*
* Nap for the configured time, or sleep for 10 seconds if there is no
* bgwriter activity configured.
*
* On some platforms, signals won’t interrupt the sleep. To ensure we
* respond reasonably promptly when someone signals us, break down the
* sleep into 1-second increments, and check for interrupts after each
* nap.
*
* We absorb pending requests after each short sleep.
*/
主要通过配置的等待时间,或是10s一次
/*
* GUC parameters
*/
int BgWriterDelay = 200;
int CheckPointTimeout = 300;
int CheckPointWarning = 30;
double CheckPointCompletionTarget = 0.5;
默认延时是200ms
/* GUC variables */
bool zero_damaged_pages = false;
int bgwriter_lru_maxpages = 100;
double bgwriter_lru_multiplier = 2.0;
在buffermgr中配置了最大lru刷新的叶是100
使用
if (bgwriter_lru_maxpages > 0 || ckpt_active)
udelay = BgWriterDelay * 1000L;
else if (XLogArchiveTimeout > 0)
udelay = 1000000L; /* One second */
else
udelay = 10000000L; /* Ten seconds */
决定延时是多少
while (udelay > 999999L)
{
if (got_SIGHUP || shutdown_requested ||
(ckpt_active ? ImmediateCheckpointRequested() : checkpoint_requested))
break;
pg_usleep(1000000L);
AbsorbFsyncRequests();
udelay -= 1000000L;
}
基本1s一次调用
/*
* Nap for the configured time, or sleep for 10 seconds if there is no
* bgwriter activity configured.
*
* On some platforms, signals won’t interrupt the sleep. To ensure we
* respond reasonably promptly when someone signals us, break down the
* sleep into 1-second increments, and check for interrupts after each
* nap.
*
* We absorb pending requests after each short sleep.
*/
主要通过配置的等待时间,或是10s一次
/*
* GUC parameters
*/
int BgWriterDelay = 200;
int CheckPointTimeout = 300;
int CheckPointWarning = 30;
double CheckPointCompletionTarget = 0.5;
默认延时是200ms
/* GUC variables */
bool zero_damaged_pages = false;
int bgwriter_lru_maxpages = 100;
double bgwriter_lru_multiplier = 2.0;
在buffermgr中配置了最大lru刷新的叶是100
使用
if (bgwriter_lru_maxpages > 0 || ckpt_active)
udelay = BgWriterDelay * 1000L;
else if (XLogArchiveTimeout > 0)
udelay = 1000000L; /* One second */
else
udelay = 10000000L; /* Ten seconds */
决定延时是多少
while (udelay > 999999L)
{
if (got_SIGHUP || shutdown_requested ||
(ckpt_active ? ImmediateCheckpointRequested() : checkpoint_requested))
break;
pg_usleep(1000000L);
AbsorbFsyncRequests();
udelay -= 1000000L;
}
基本1s一次调用
相关文章推荐
- HDU 5726 GCD(线段树+预处理)
- 有爱的旅途最美好——出发篇
- Mac双系统切换
- .NET基础架构方法—DataTableToList通用方法
- android 串口通信实例分析
- AIX常用文章集锦
- 谈谈对布局文件、自定义控件、Fragment、Activity的认识
- Hadoop环境搭建(二)
- Android事件分发机制
- 文件同步监控工具
- wget命令3(转载)
- c++ 关于char *的类库函数
- 剑指offer——字符流中第一个不重复的字符
- static和const关键字的作用
- Unity3d gameObject
- [2016ACM多校] HDU5726 st表 离线
- AIX常用命令汇总
- 时钟系统
- APP开发实战106-缓存实现
- 支付宝支付的流程