* FreeBlockNumberArray - array of block numbers sized so that metadata fill
* all space in metapage.
*/
-typedef BlockNumber FreeBlockNumberArray[
- MAXALIGN_DOWN(
- BLCKSZ - SizeOfPageHeaderData - MAXALIGN(sizeof(BloomPageOpaqueData))
- - MAXALIGN(sizeof(uint16) * 2 + sizeof(uint32) + sizeof(BloomOptions))
- ) / sizeof(BlockNumber)
-];
+typedef BlockNumber FreeBlockNumberArray[MAXALIGN_DOWN(BLCKSZ - SizeOfPageHeaderData - MAXALIGN(sizeof(BloomPageOpaqueData))
+ - MAXALIGN(sizeof(uint16) * 2 + sizeof(uint32) + sizeof(BloomOptions)))
+ / sizeof(BlockNumber)];
/* Metadata of bloom index */
typedef struct BloomMetaPageData
* time for an incremental parse. We'll do all but the last MIN_CHUNK
* so that we have enough left for the final piece.
*/
- json_parse_manifest_incremental_chunk(
- ib->inc_state, ib->buf.data, ib->buf.len - MIN_CHUNK, false);
+ json_parse_manifest_incremental_chunk(ib->inc_state, ib->buf.data,
+ ib->buf.len - MIN_CHUNK, false);
/* now remove what we just parsed */
memmove(ib->buf.data, ib->buf.data + (ib->buf.len - MIN_CHUNK),
MIN_CHUNK + 1);
oldcontext = MemoryContextSwitchTo(ib->mcxt);
/* Parse the last chunk of the manifest */
- json_parse_manifest_incremental_chunk(
- ib->inc_state, ib->buf.data, ib->buf.len, true);
+ json_parse_manifest_incremental_chunk(ib->inc_state, ib->buf.data,
+ ib->buf.len, true);
/* Done with the buffer, so release memory. */
pfree(ib->buf.data);
default_locale.collate_is_c = true;
default_locale.ctype_is_c = (strcmp(datlocale, "C") == 0);
- default_locale.info.builtin.locale = MemoryContextStrdup(
- TopMemoryContext, datlocale);
+ default_locale.info.builtin.locale = MemoryContextStrdup(TopMemoryContext,
+ datlocale);
}
else if (dbform->datlocprovider == COLLPROVIDER_ICU)
{
/* We want the exclusion constraint owning the index */
if ((conform->contype != CONSTRAINT_EXCLUSION &&
- !(conform->conperiod && (
- conform->contype == CONSTRAINT_PRIMARY
+ !(conform->conperiod && (conform->contype == CONSTRAINT_PRIMARY
|| conform->contype == CONSTRAINT_UNIQUE))) ||
conform->conindid != RelationGetRelid(indexRelation))
continue;
(long long int) statbuf.st_size);
}
bytes_left -= rc;
- json_parse_manifest_incremental_chunk(
- inc_state, buffer, rc, bytes_left == 0);
+ json_parse_manifest_incremental_chunk(inc_state, buffer, rc, bytes_left == 0);
}
/* Release the incremental state memory */
*/
void
-json_parse_manifest_incremental_chunk(
- JsonManifestParseIncrementalState *incstate, const char *chunk, size_t size,
- bool is_last)
+json_parse_manifest_incremental_chunk(JsonManifestParseIncrementalState *incstate,
+ const char *chunk, size_t size, bool is_last)
{
JsonParseErrorType res,
expected;
bool prop_hex_digit = pg_u_prop_hex_digit(code);
bool prop_join_control = pg_u_prop_join_control(code);
- bool icu_prop_alphabetic = u_hasBinaryProperty(
- code, UCHAR_ALPHABETIC);
- bool icu_prop_lowercase = u_hasBinaryProperty(
- code, UCHAR_LOWERCASE);
- bool icu_prop_uppercase = u_hasBinaryProperty(
- code, UCHAR_UPPERCASE);
- bool icu_prop_cased = u_hasBinaryProperty(
- code, UCHAR_CASED);
- bool icu_prop_case_ignorable = u_hasBinaryProperty(
- code, UCHAR_CASE_IGNORABLE);
- bool icu_prop_white_space = u_hasBinaryProperty(
- code, UCHAR_WHITE_SPACE);
- bool icu_prop_hex_digit = u_hasBinaryProperty(
- code, UCHAR_HEX_DIGIT);
- bool icu_prop_join_control = u_hasBinaryProperty(
- code, UCHAR_JOIN_CONTROL);
+ bool icu_prop_alphabetic = u_hasBinaryProperty(code, UCHAR_ALPHABETIC);
+ bool icu_prop_lowercase = u_hasBinaryProperty(code, UCHAR_LOWERCASE);
+ bool icu_prop_uppercase = u_hasBinaryProperty(code, UCHAR_UPPERCASE);
+ bool icu_prop_cased = u_hasBinaryProperty(code, UCHAR_CASED);
+ bool icu_prop_case_ignorable = u_hasBinaryProperty(code, UCHAR_CASE_IGNORABLE);
+ bool icu_prop_white_space = u_hasBinaryProperty(code, UCHAR_WHITE_SPACE);
+ bool icu_prop_hex_digit = u_hasBinaryProperty(code, UCHAR_HEX_DIGIT);
+ bool icu_prop_join_control = u_hasBinaryProperty(code, UCHAR_JOIN_CONTROL);
/*
* Compare with ICU for character classes using:
extern void json_parse_manifest(JsonManifestParseContext *context,
const char *buffer, size_t size);
extern JsonManifestParseIncrementalState *json_parse_manifest_incremental_init(JsonManifestParseContext *context);
-extern void json_parse_manifest_incremental_chunk(
- JsonManifestParseIncrementalState *incstate, const char *chunk, size_t size,
+extern void json_parse_manifest_incremental_chunk(JsonManifestParseIncrementalState *incstate,
+ const char *chunk, size_t size,
bool is_last);
extern void json_parse_manifest_incremental_shutdown(JsonManifestParseIncrementalState *incstate);
TimestampTz prepare_time);
/* start streaming transaction callback signature */
-typedef void (*ReorderBufferStreamStartCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamStartCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr first_lsn);
/* stop streaming transaction callback signature */
-typedef void (*ReorderBufferStreamStopCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamStopCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr last_lsn);
/* discard streamed transaction callback signature */
-typedef void (*ReorderBufferStreamAbortCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamAbortCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr abort_lsn);
/* prepare streamed transaction callback signature */
-typedef void (*ReorderBufferStreamPrepareCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamPrepareCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr prepare_lsn);
/* commit streamed transaction callback signature */
-typedef void (*ReorderBufferStreamCommitCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamCommitCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr commit_lsn);
/* stream change callback signature */
-typedef void (*ReorderBufferStreamChangeCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamChangeCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
Relation relation,
ReorderBufferChange *change);
/* stream message callback signature */
-typedef void (*ReorderBufferStreamMessageCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamMessageCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr message_lsn,
bool transactional,
const char *message);
/* stream truncate callback signature */
-typedef void (*ReorderBufferStreamTruncateCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferStreamTruncateCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
int nrelations,
Relation relations[],
ReorderBufferChange *change);
/* update progress txn callback signature */
-typedef void (*ReorderBufferUpdateProgressTxnCB) (
- ReorderBuffer *rb,
+typedef void (*ReorderBufferUpdateProgressTxnCB) (ReorderBuffer *rb,
ReorderBufferTXN *txn,
XLogRecPtr lsn);