aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/backend/storage/sync/sync.c18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/backend/storage/sync/sync.c b/src/backend/storage/sync/sync.c
index e1fb6310038..9d6a9e91090 100644
--- a/src/backend/storage/sync/sync.c
+++ b/src/backend/storage/sync/sync.c
@@ -510,26 +510,26 @@ RememberSyncRequest(const FileTag *ftag, SyncRequestType type)
else if (type == SYNC_FILTER_REQUEST)
{
HASH_SEQ_STATUS hstat;
- PendingFsyncEntry *entry;
+ PendingFsyncEntry *pfe;
ListCell *cell;
/* Cancel matching fsync requests */
hash_seq_init(&hstat, pendingOps);
- while ((entry = (PendingFsyncEntry *) hash_seq_search(&hstat)) != NULL)
+ while ((pfe = (PendingFsyncEntry *) hash_seq_search(&hstat)) != NULL)
{
- if (entry->tag.handler == ftag->handler &&
- syncsw[ftag->handler].sync_filetagmatches(ftag, &entry->tag))
- entry->canceled = true;
+ if (pfe->tag.handler == ftag->handler &&
+ syncsw[ftag->handler].sync_filetagmatches(ftag, &pfe->tag))
+ pfe->canceled = true;
}
/* Cancel matching unlink requests */
foreach(cell, pendingUnlinks)
{
- PendingUnlinkEntry *entry = (PendingUnlinkEntry *) lfirst(cell);
+ PendingUnlinkEntry *pue = (PendingUnlinkEntry *) lfirst(cell);
- if (entry->tag.handler == ftag->handler &&
- syncsw[ftag->handler].sync_filetagmatches(ftag, &entry->tag))
- entry->canceled = true;
+ if (pue->tag.handler == ftag->handler &&
+ syncsw[ftag->handler].sync_filetagmatches(ftag, &pue->tag))
+ pue->canceled = true;
}
}
else if (type == SYNC_UNLINK_REQUEST)