|
|
@ -2262,8 +2262,8 @@ rel_sync_cache_relation_cb(Datum arg, Oid relid) |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* We can get here if the plugin was used in SQL interface as the |
|
|
|
* We can get here if the plugin was used in SQL interface as the |
|
|
|
* RelSchemaSyncCache is destroyed when the decoding finishes, but there |
|
|
|
* RelationSyncCache is destroyed when the decoding finishes, but there is |
|
|
|
* is no way to unregister the relcache invalidation callback. |
|
|
|
* no way to unregister the relcache invalidation callback. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
if (RelationSyncCache == NULL) |
|
|
|
if (RelationSyncCache == NULL) |
|
|
|
return; |
|
|
|
return; |
|
|
@ -2314,8 +2314,8 @@ rel_sync_cache_publication_cb(Datum arg, int cacheid, uint32 hashvalue) |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* We can get here if the plugin was used in SQL interface as the |
|
|
|
* We can get here if the plugin was used in SQL interface as the |
|
|
|
* RelSchemaSyncCache is destroyed when the decoding finishes, but there |
|
|
|
* RelationSyncCache is destroyed when the decoding finishes, but there is |
|
|
|
* is no way to unregister the invalidation callbacks. |
|
|
|
* no way to unregister the invalidation callbacks. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
if (RelationSyncCache == NULL) |
|
|
|
if (RelationSyncCache == NULL) |
|
|
|
return; |
|
|
|
return; |
|
|
|