Class AsyncFederationAccessManagerImpl

java.lang.Object

se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase1

se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase2

se.liu.ida.hefquin.federation.access.impl.AsyncFederationAccessManagerImpl

All Implemented Interfaces:

StatsProvider, FederationAccessManager

public class AsyncFederationAccessManagerImpl
extends FederationAccessManagerBase2

Nested Class Summary

Nested classes/interfaces inherited from class se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase1

FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromSolMapsResponse, FederationAccessManagerBase1.FunctionToObtainCardinalityResponseFromTPFResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	completedBRTPFRequests
protected AtomicLong	completedOtherRequests
protected AtomicLong	completedSPARQLRequests
protected AtomicLong	completedTPFRequests
protected AtomicLong	issuedBRTPFRequests
protected AtomicLong	issuedOtherRequests
protected AtomicLong	issuedSPARQLRequests
protected AtomicLong	issuedTPFRequests
protected final ExecutorService	threadPool

Fields inherited from class se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase2

reqProcBRTPF, reqProcSPARQL, reqProcTPF

Fields inherited from class se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase1

countVar, enNumberOfBRTPFCardRequestsIssued, enNumberOfSPARQLCardRequestsIssued, enNumberOfTPFCardRequestsIssued, enOverallNumberOfCardRequestsIssued, fctToObtainCardinalityResponseFromSolMapsResponse, fctToObtainCardinalityResponseFromTPFResponse, issuedCardRequestsBRTPF, issuedCardRequestsSPARQL, issuedCardRequestsTPF

Constructor Summary

Constructors

Constructor	Description
AsyncFederationAccessManagerImpl(ExecutorService execService, int defaultParallelRequestLimitPerServer, SPARQLRequestProcessor reqProcSPARQL, TPFRequestProcessor reqProcTPF, BRTPFRequestProcessor reqProcBRTPF, List<RequestProcessor<?,?,?>> otherRequestProcessors)

Method Summary

Modifier and Type	Method	Description
protected FederationAccessStatsImpl	_getStats()
protected void	_resetStats()
<ReqType extends DataRetrievalRequest, RespType extends DataRetrievalResponse<?>, MemberType extends FederationMember> CompletableFuture<RespType>	issueRequest(ReqType req, MemberType fm, boolean ignoreRetrievalCache)
void	shutdown()	Shuts down all thread pools associated with this federation access manager.

Methods inherited from class se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase2

getReqProc

Methods inherited from class se.liu.ida.hefquin.federation.access.impl.FederationAccessManagerBase1

_issueCardinalityRequest, _issueCardinalityRequest, _issueCardinalityRequest, _issueCardinalityRequest, getStats, issueCardinalityRequest, resetStats

Methods inherited from class java.lang.Object

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

Field Details

threadPool

protected final ExecutorService threadPool

issuedSPARQLRequests

protected AtomicLong issuedSPARQLRequests

issuedTPFRequests

protected AtomicLong issuedTPFRequests

issuedBRTPFRequests

protected AtomicLong issuedBRTPFRequests

issuedOtherRequests

protected AtomicLong issuedOtherRequests

completedSPARQLRequests

protected AtomicLong completedSPARQLRequests

completedTPFRequests

protected AtomicLong completedTPFRequests

completedBRTPFRequests

protected AtomicLong completedBRTPFRequests

completedOtherRequests

protected AtomicLong completedOtherRequests

Constructor Details

AsyncFederationAccessManagerImpl

public AsyncFederationAccessManagerImpl(ExecutorService execService,
 int defaultParallelRequestLimitPerServer,
 SPARQLRequestProcessor reqProcSPARQL,
 TPFRequestProcessor reqProcTPF,
 BRTPFRequestProcessor reqProcBRTPF,
 List<RequestProcessor<?,?,?>> otherRequestProcessors)

Method Details

issueRequest

public <ReqType extends DataRetrievalRequest,
RespType extends DataRetrievalResponse<?>,
MemberType extends FederationMember>
CompletableFuture<RespType> issueRequest(ReqType req,
 MemberType fm,
 boolean ignoreRetrievalCache)

_getStats

protected FederationAccessStatsImpl _getStats()

Specified by:

_getStats in class FederationAccessManagerBase1

_resetStats

protected void _resetStats()

Specified by:

_resetStats in class FederationAccessManagerBase1

shutdown

public void shutdown()

Shuts down all thread pools associated with this federation access manager.