external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #7 from citusdata/add-wal 

Add wal support
merge-cstore-pykello
Nils Dijk 2020-09-15 12:41:41 +02:00 committed by GitHub
parent 139da88ad9 a94bbcc7ef
commit 00cb58135d
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
cstore_writer.c
View File

@ -18,6 +18,7 @@
#include "access/nbtree.h" #include "access/nbtree.h"
#include "catalog/pg_am.h" #include "catalog/pg_am.h"
#include "miscadmin.h"
#include "storage/fd.h" #include "storage/fd.h"
#include "storage/smgr.h" #include "storage/smgr.h"
#include "utils/memutils.h" #include "utils/memutils.h"
@ -401,11 +402,30 @@ WriteToSmgr(TableWriteState *writeState, char *data, uint32 dataLength)
/* always appending */ /* always appending */
Assert(phdr->pd_lower == addr.offset); Assert(phdr->pd_lower == addr.offset);
START_CRIT_SECTION();
to_write = Min(phdr->pd_upper - phdr->pd_lower, remaining); to_write = Min(phdr->pd_upper - phdr->pd_lower, remaining);
memcpy(page + phdr->pd_lower, data, to_write); memcpy(page + phdr->pd_lower, data, to_write);
phdr->pd_lower += to_write; phdr->pd_lower += to_write;
MarkBufferDirty(buffer); MarkBufferDirty(buffer);
if (RelationNeedsWAL(rel))
{
XLogBeginInsert();
/*
* Since cstore will mostly write whole pages we force the transmission of the
* whole image in the buffer
*/
XLogRegisterBuffer(0, buffer, REGBUF_FORCE_IMAGE);
XLogRecPtr recptr = XLogInsert(RM_GENERIC_ID, 0);
PageSetLSN(page, recptr);
}
END_CRIT_SECTION();
UnlockReleaseBuffer(buffer); UnlockReleaseBuffer(buffer);
data += to_write; data += to_write;