diff options
| -rw-r--r-- | src/backend/storage/ipc/sinvaladt.c | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/src/backend/storage/ipc/sinvaladt.c b/src/backend/storage/ipc/sinvaladt.c index 0328660b83e..bd3e2c7383b 100644 --- a/src/backend/storage/ipc/sinvaladt.c +++ b/src/backend/storage/ipc/sinvaladt.c @@ -410,9 +410,7 @@ BackendIdGetProc(int backendID) void BackendIdGetTransactionIds(int backendID, TransactionId *xid, TransactionId *xmin) { - ProcState *stateP; SISeg *segP = shmInvalBuffer; - PGXACT *xact; *xid = InvalidTransactionId; *xmin = InvalidTransactionId; @@ -422,11 +420,16 @@ BackendIdGetTransactionIds(int backendID, TransactionId *xid, TransactionId *xmi if (backendID > 0 && backendID <= segP->lastBackend) { - stateP = &segP->procState[backendID - 1]; - xact = &ProcGlobal->allPgXact[stateP->proc->pgprocno]; + ProcState *stateP = &segP->procState[backendID - 1]; + PGPROC *proc = stateP->proc; - *xid = xact->xid; - *xmin = xact->xmin; + if (proc != NULL) + { + PGXACT *xact = &ProcGlobal->allPgXact[proc->pgprocno]; + + *xid = xact->xid; + *xmin = xact->xmin; + } } LWLockRelease(SInvalWriteLock); |