diff options
| author | Robert Haas <rhaas@postgresql.org> | 2016-11-22 14:26:40 -0500 |
|---|---|---|
| committer | Robert Haas <rhaas@postgresql.org> | 2016-11-22 14:27:11 -0500 |
| commit | e8ac886c24776295dd9b025386a821061da8e4d1 (patch) | |
| tree | cdb4306afce149e7f9c8c0708d18ddee7737fc29 /src/backend/access/transam | |
| parent | 1c7861e81b4220364bef75d2445e9c0619f3f3f8 (diff) | |
| download | postgresql-e8ac886c24776295dd9b025386a821061da8e4d1.tar.gz postgresql-e8ac886c24776295dd9b025386a821061da8e4d1.zip | |
Support condition variables.
Condition variables provide a flexible way to sleep until a
cooperating process causes an arbitrary condition to become true. In
simple cases, this can be accomplished with a WaitLatch/ResetLatch
loop; the cooperating process can call SetLatch after performing work
that might cause the condition to be satisfied, and the waiting
process can recheck the condition each time. However, if the process
performing the work doesn't have an easy way to identify which
processes might be waiting, this doesn't work, because it can't
identify which latches to set. Condition variables solve that problem
by internally maintaining a list of waiters; a process that may have
caused some waiter's condition to be satisfied must "signal" or
"broadcast" on the condition variable.
Robert Haas and Thomas Munro
Diffstat (limited to 'src/backend/access/transam')
| -rw-r--r-- | src/backend/access/transam/xact.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/backend/access/transam/xact.c b/src/backend/access/transam/xact.c index 95805963af1..d6432165f1e 100644 --- a/src/backend/access/transam/xact.c +++ b/src/backend/access/transam/xact.c @@ -45,6 +45,7 @@ #include "replication/origin.h" #include "replication/syncrep.h" #include "replication/walsender.h" +#include "storage/condition_variable.h" #include "storage/fd.h" #include "storage/lmgr.h" #include "storage/predicate.h" @@ -2472,6 +2473,9 @@ AbortTransaction(void) /* Reset WAL record construction state */ XLogResetInsertion(); + /* Cancel condition variable sleep */ + ConditionVariableCancelSleep(); + /* * Also clean up any open wait for lock, since the lock manager will choke * if we try to wait for another lock before doing this. |