Commit62a4854

committed

Support optimized transfer of internal basetypes

1 parent6f61722 commit62a4854Copy full SHA for 62a4854

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -187,8 +187,8 @@ pg_decode_startup(LogicalDecodingContext * ctx, OutputPluginOptions *opt,`
`187`	`187`	`ALLOCSET_DEFAULT_MINSIZE,`
`188`	`188`	`ALLOCSET_DEFAULT_INITSIZE,`
`189`	`189`	`ALLOCSET_DEFAULT_MAXSIZE);`
`190`		`-data->allow_internal_basetypes=false;`
`191`		`-data->allow_binary_basetypes=false;`
	`190`	`+data->allow_internal_basetypes=true;`
	`191`	`+data->allow_binary_basetypes=true;`
`192`	`192`
`193`	`193`
`194`	`194`	`ctx->output_plugin_private=data;`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -476,6 +476,7 @@ pglogical_write_tuple(StringInfo out, PGLogicalOutputData *data,`
`476`	`476`	`transfer_type=decide_datum_transfer(att,typclass,`
`477`	`477`	`data->allow_internal_basetypes,`
`478`	`478`	`data->allow_binary_basetypes);`
	`479`	`+`
`479`	`480`	`pq_sendbyte(out,transfer_type);`
`480`	`481`	`switch (transfer_type)`
`481`	`482`	`{`

Comments

(0)