Hi, thanks for writing the patch.
On 05/12/17 06:58, Craig Ringer wrote: > Hi all > > [...] >> The cause appears to be that walsender.c's ProcessRepliesIfAny writes a > LOG for unexpected EOF then calls proc_exit(0). But serialized txn > cleanup is done by > ReorderBufferRestoreCleanup, as called by ReorderBufferCleanupTXN, which > is invoked from the PG_CATCH() in ReorderBufferCommit() and on various > normal exits. It won't get called if we proc_exit() without an ERROR, so > we leave stale data lying around. > > It's not a problem on crash restart because StartupReorderBuffer already > does the required delete. > > ReorderBufferSerializeTXN, which spills the txns to disk, doesn't appear > to have any guard to ensure that the segment files don't already exist > when it goes to serialize a snapshot. Adding one there would probably be > expensive; we don't know the last lsn of the txn yet, so to be really > safe we'd have to do a directory listing and scan for any txn-$OURXID-* > entries. > > So to fix, I suggest that we should do a > slot-specific StartupReorderBuffer-style deletion when we start a new > decoding session on a slot, per attached patch. > > It might be nice to also add a hook on proc exit, so we don't have stale > buffers lying around until next decoding session, but I didn't want to > add new global state to reorderbuffer.c so I've left that for now. Hmm, can't we simply call the new cleanup function in ReplicationSlotRelease()? That's called during process exit and we know there about slot so no extra global variables are needed. -- Petr Jelinek http://www.2ndQuadrant.com/ PostgreSQL Development, 24x7 Support, Training & Services
