|
7 | 7 | * |
8 | 8 | * |
9 | 9 | * IDENTIFICATION |
10 | | - * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.6 1996/11/10 03:02:27 momjian Exp $ |
| 10 | + * $Header: /cvsroot/pgsql/src/backend/storage/ipc/shmem.c,v 1.7 1996/11/27 07:20:07 vadim Exp $ |
11 | 11 | * |
12 | 12 | *------------------------------------------------------------------------- |
13 | 13 | */ |
|
64 | 64 | #include"storage/ipc.h" |
65 | 65 | #include"storage/shmem.h" |
66 | 66 | #include"storage/spin.h" |
| 67 | +#include"storage/proc.h" |
67 | 68 | #include"utils/dynahash.h" |
68 | 69 | #include"utils/hsearch.h" |
69 | 70 |
|
@@ -559,4 +560,43 @@ ShmemInitStruct(char *name, unsigned long size, bool *foundPtr) |
559 | 560 | } |
560 | 561 |
|
561 | 562 |
|
| 563 | +/* |
| 564 | + * TransactionIdIsInProgress -- is given transaction running by some backend |
| 565 | + * |
| 566 | + * Strange place for this func, but we have to lookup process data structures |
| 567 | + * for all running backends. - vadim 11/26/96 |
| 568 | + */ |
| 569 | +bool |
| 570 | +TransactionIdIsInProgress (TransactionIdxid) |
| 571 | +{ |
| 572 | +BindingEnt*result; |
| 573 | +PROC*proc; |
| 574 | + |
| 575 | +Assert (BindingTable); |
| 576 | + |
| 577 | +SpinAcquire(BindingLock); |
| 578 | + |
| 579 | + (void)hash_seq ((HTAB*)NULL); |
| 580 | +while ( (result= (BindingEnt*)hash_seq (BindingTable))!=NULL ) |
| 581 | + { |
| 582 | +if (result== (BindingEnt*) TRUE ) |
| 583 | + { |
| 584 | +SpinRelease(BindingLock); |
| 585 | +return (false); |
| 586 | +} |
| 587 | +if (result->location==INVALID_OFFSET|| |
| 588 | +strncmp (result->key,"PID ",4)!=0 ) |
| 589 | +continue; |
| 590 | +proc= (PROC*)MAKE_PTR (result->location); |
| 591 | +if (proc->xid==xid ) |
| 592 | + { |
| 593 | +SpinRelease(BindingLock); |
| 594 | +return (true); |
| 595 | +} |
| 596 | + } |
| 597 | + |
| 598 | +SpinRelease(BindingLock); |
| 599 | +elog (WARN,"TransactionIdIsInProgress: BindingTable corrupted"); |
| 600 | +return (false); |
| 601 | +} |
562 | 602 |
|