Package com.suse.coco.attestation

Class ProcessingThread

java.lang.Object

com.suse.coco.attestation.AbstractProcessorThread

com.suse.coco.attestation.ProcessingThread

All Implemented Interfaces:

Runnable

class ProcessingThread
extends AbstractProcessorThread

Main processing thread of the AttestationQueueProcessor. Extracts the attestation result of the supported types and uses the correct AttestationModule to process them.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	batchSize
private final Object	dataAvailableLock
private final ExecutorService	executorService
private ListeningThread	listeningThread
private static final org.apache.logging.log4j.Logger	LOGGER
private final AttestationModuleLoader	moduleLoader
private final AttestationResultService	service

Constructor Summary

Constructors

Constructor	Description
ProcessingThread(AttestationResultService serviceIn, ExecutorService executorServiceIn, AttestationModuleLoader moduleLoaderIn, int batchSizeIn)

Method Summary

Modifier and Type	Method	Description
void	notifyDataAvailable()	Notifies the processor that some data is ready to be processed.
void	run()
void	setListeningThread(ListeningThread listeningThreadIn)
void	start()	Starts the processing of the thread.

Methods inherited from class com.suse.coco.attestation.AbstractProcessorThread

await, isRunning, setRunning, stop

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

dataAvailableLock

private final Object dataAvailableLock

moduleLoader

private final AttestationModuleLoader moduleLoader

service

private final AttestationResultService service

executorService

private final ExecutorService executorService

batchSize

private final int batchSize

listeningThread

private ListeningThread listeningThread

Constructor Details

ProcessingThread

ProcessingThread(AttestationResultService serviceIn,
 ExecutorService executorServiceIn,
 AttestationModuleLoader moduleLoaderIn,
 int batchSizeIn)

Method Details

setListeningThread

public void setListeningThread(ListeningThread listeningThreadIn)

notifyDataAvailable

public void notifyDataAvailable()

Notifies the processor that some data is ready to be processed. Used by the ListeningThread to trigger the processing after receiving a notification.

start

public void start()

Description copied from class: AbstractProcessorThread

Starts the processing of the thread.

Overrides:

start in class AbstractProcessorThread

run

public void run()