aboutsummaryrefslogtreecommitdiff
path: root/src/backend/replication/logical/worker.c
diff options
context:
space:
mode:
authorFujii Masao <fujii@postgresql.org>2017-04-19 00:12:27 +0900
committerFujii Masao <fujii@postgresql.org>2017-04-19 00:12:27 +0900
commit39a6772d04940b994acd9a3fd954cacdc2f88b26 (patch)
tree2b446aa01ccc8554d2775ed89f92acc8e527dcd3 /src/backend/replication/logical/worker.c
parentb977780a9b2c546f8e2bf19fa3232b3e3d334916 (diff)
downloadpostgresql-39a6772d04940b994acd9a3fd954cacdc2f88b26.tar.gz
postgresql-39a6772d04940b994acd9a3fd954cacdc2f88b26.zip
Use DatumGetInt32() to extract 32-bit integer value from a datum.
Previously DatumGetObjectId() was wrongly used for that. Author: Masahiko Sawada Reviewed-by: Kyotaro Horiguchi Reported-by: Fujii Masao Discussion: http://postgr.es/m/CAHGQGwFDWh_Qr-q_GEMpD+qH=vYPMdVqw=ZOSY3kX_Pna9R9SA@mail.gmail.com
Diffstat (limited to 'src/backend/replication/logical/worker.c')
-rw-r--r--src/backend/replication/logical/worker.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index 656d3999796..fa4f3b652d5 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -1441,7 +1441,7 @@ subscription_change_cb(Datum arg, int cacheid, uint32 hashvalue)
void
ApplyWorkerMain(Datum main_arg)
{
- int worker_slot = DatumGetObjectId(main_arg);
+ int worker_slot = DatumGetInt32(main_arg);
MemoryContext oldctx;
char originname[NAMEDATALEN];
XLogRecPtr origin_startpos;