diff options
Diffstat (limited to 'src/backend/catalog/heap.c')
| -rw-r--r-- | src/backend/catalog/heap.c | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/src/backend/catalog/heap.c b/src/backend/catalog/heap.c index 384e90de7c5..8cb313ed856 100644 --- a/src/backend/catalog/heap.c +++ b/src/backend/catalog/heap.c @@ -1290,24 +1290,10 @@ heap_create_with_catalog(const char *relname, if (oncommit != ONCOMMIT_NOOP) register_on_commit_action(relid, oncommit); - /* - * If this is an unlogged relation, it needs an init fork so that it can - * be correctly reinitialized on restart. Since we're going to do an - * immediate sync, we only need to xlog this if archiving or streaming is - * enabled. And the immediate sync is required, because otherwise there's - * no guarantee that this will hit the disk before the next checkpoint - * moves the redo pointer. - */ if (relpersistence == RELPERSISTENCE_UNLOGGED) { Assert(relkind == RELKIND_RELATION || relkind == RELKIND_TOASTVALUE); - - RelationOpenSmgr(new_rel_desc); - smgrcreate(new_rel_desc->rd_smgr, INIT_FORKNUM, false); - if (XLogIsNeeded()) - log_smgrcreate(&new_rel_desc->rd_smgr->smgr_rnode.node, - INIT_FORKNUM); - smgrimmedsync(new_rel_desc->rd_smgr, INIT_FORKNUM); + heap_create_init_fork(new_rel_desc); } /* @@ -1320,6 +1306,22 @@ heap_create_with_catalog(const char *relname, return relid; } +/* + * Set up an init fork for an unlogged table so that it can be correctly + * reinitialized on restart. Since we're going to do an immediate sync, we + * only need to xlog this if archiving or streaming is enabled. And the + * immediate sync is required, because otherwise there's no guarantee that + * this will hit the disk before the next checkpoint moves the redo pointer. + */ +void +heap_create_init_fork(Relation rel) +{ + RelationOpenSmgr(rel); + smgrcreate(rel->rd_smgr, INIT_FORKNUM, false); + if (XLogIsNeeded()) + log_smgrcreate(&rel->rd_smgr->smgr_rnode.node, INIT_FORKNUM); + smgrimmedsync(rel->rd_smgr, INIT_FORKNUM); +} /* * RelationRemoveInheritance |