Package ca.uhn.fhir.jpa.interceptor

Class TransactionConcurrencySemaphoreInterceptor

java.lang.Object

ca.uhn.fhir.jpa.interceptor.TransactionConcurrencySemaphoreInterceptor

public class TransactionConcurrencySemaphoreInterceptor
extends Object

This interceptor uses semaphores to avoid multiple concurrent FHIR transaction bundles from processing the same records at the same time, avoiding concurrency issues.

Constructor Summary

Constructors

Constructor	Description
TransactionConcurrencySemaphoreInterceptor(MemoryCacheService theMemoryCacheService)	Constructor

Method Summary

Modifier and Type	Method	Description
void	clearSemaphores()	Clear all semaphors from the list.
long	countSemaphores()	Returns a count of all semaphores currently in the cache (incuding held and unheld semaphores)
boolean	isLogWaits()	Should the interceptor log if a wait for a semaphore is required
void	post(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
void	pre(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, TransactionWriteOperationsDetails theWriteOperationsDetails)
void	setLogWaits(boolean theLogWaits)	Should the interceptor log if a wait for a semaphore is required

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransactionConcurrencySemaphoreInterceptor

public TransactionConcurrencySemaphoreInterceptor(MemoryCacheService theMemoryCacheService)

Constructor

Method Details

isLogWaits

public boolean isLogWaits()

Should the interceptor log if a wait for a semaphore is required

setLogWaits

public void setLogWaits(boolean theLogWaits)

Should the interceptor log if a wait for a semaphore is required

pre

public void pre(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 TransactionWriteOperationsDetails theWriteOperationsDetails)

post

public void post(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

clearSemaphores

public void clearSemaphores()

Clear all semaphors from the list. This is really mostly intended for testing scenarios.

countSemaphores

public long countSemaphores()

Returns a count of all semaphores currently in the cache (incuding held and unheld semaphores)