Re: Logical Replication WIP

On 12/16/2016 07:49 AM, Petr Jelinek wrote:
> Hi,
>
> attached is version 13 of the patch.
>
> I merged in changes from PeterE. And did following changes:
> - fixed the ownership error messages for both provider and subscriber
> - added ability to send invalidation message to invalidate whole
> relcache and use it in publication code
> - added the post creation/alter/drop hooks
> - removed parts of docs that refer to initial sync (which does not exist
> yet)
> - added timeout handling/retry, etc to apply/launcher based on the GUCs
> that exist for wal receiver (they could use renaming though)
> - improved feedback behavior
> - apply worker now uses owner of the subscription as connection user
> - more tests
> - check for max_replication_slots in launcher
> - clarify the update 'K' sub-message description in protocol

A few things I've noticed so far

If I shutdown the publisher I see the following in the log

2016-12-17 11:33:49.548 EST [1891] LOG: worker process: ?)G? (PID 1987)
exited with exit code 1

but then if I shutdown the subscriber postmaster and restart it switches to
2016-12-17 11:43:09.628 EST [2373] LOG: worker process: ???? (PID 2393)
exited with exit code 1

Not sure where the 'G' was coming from (other times I have seen an 'I'
here or other random characters)

I don't think we are cleaning up subscriptions on a drop database

If I do the following

1) Create a subscription in a new database
2) Stop the publisher
3) Drop the database on the subscriber

test=# create subscription mysuba connection 'host=localhost dbname=test
port=5440' publication mypub;
test=# \c b
b=# drop database test;
DROP DATABASE
b=# select * FROM pg_subscription ;
subdbid | subname | subowner | subenabled | subconninfo |
subslotname | subpublications
---------+---------+----------+------------+--------------------------------------+-------------+-----------------
16384 | mysuba | 10 | t | host=localhost dbname=test
port=5440 | mysuba | {mypub}

b=# select datname FROM pg_database where oid=16384;
datname
---------
(0 rows)

Also I don't think I can now drop mysuba
b=# drop subscription mysuba;
ERROR: subscription "mysuba" does not exist

>
>