database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-05-01 01:04:50 +03:00
Code

TransactionIdIsInProgress is here now and gives quality answer

Browse Source 
by scanning PROC structures of all running backend.
This commit is contained in:
Vadim B. Mikheev 1996-11-27 07:20:07 +00:00
parent 47312ec134
commit 3643248ae2
1 changed files with 41 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/backend/storage/ipc/shmem.c
View File

@ -7,7 +7,7 @@
*
*
* IDENTIFICATION
* $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.6 1996/11/10 03:02:27 momjian Exp $
* $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.7 1996/11/27 07:20:07 vadim Exp $
*
*-------------------------------------------------------------------------
*/
@ -64,6 +64,7 @@
#include "storage/ipc.h"
#include "storage/shmem.h"
#include "storage/spin.h"
#include "storage/proc.h"
#include "utils/dynahash.h"
#include "utils/hsearch.h"
@ -559,4 +560,43 @@ ShmemInitStruct(char *name, unsigned long size, bool *foundPtr)
}
/*
* TransactionIdIsInProgress -- is given transaction running by some backend
*
* Strange place for this func, but we have to lookup process data structures
* for all running backends. - vadim 11/26/96
*/
bool
TransactionIdIsInProgress (TransactionId xid)
{
BindingEnt *result;
PROC *proc;
Assert (BindingTable);
SpinAcquire(BindingLock);
(void) hash_seq ((HTAB *)NULL);
while ( (result = (BindingEnt *) hash_seq (BindingTable)) != NULL )
{
if ( result == (BindingEnt *) TRUE )
{
SpinRelease(BindingLock);
return (false);
}
if ( result->location == INVALID_OFFSET ||
strncmp (result->key, "PID ", 4) != 0 )
continue;
proc = (PROC *) MAKE_PTR (result->location);
if ( proc->xid == xid )
{
SpinRelease(BindingLock);
return (true);
}
}
SpinRelease(BindingLock);
elog (WARN,"TransactionIdIsInProgress: BindingTable corrupted");
return (false);
}