Package com.suse.coco.attestation

Class ProcessingThread

java.lang.Object

com.suse.coco.attestation.AbstractProcessorThread

com.suse.coco.attestation.ProcessingThread

All Implemented Interfaces:

java.lang.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 int	batchSize
private java.lang.Object	dataAvailableLock
private java.util.concurrent.ExecutorService	executorService
private ListeningThread	listeningThread
private static org.apache.logging.log4j.Logger	LOGGER
private AttestationModuleLoader	moduleLoader
private AttestationResultService	service

Constructor Summary

Constructors

Constructor	Description
ProcessingThread(AttestationResultService serviceIn, java.util.concurrent.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 Detail

LOGGER

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

dataAvailableLock

private final java.lang.Object dataAvailableLock

moduleLoader

private final AttestationModuleLoader moduleLoader

service

private final AttestationResultService service

executorService

private final java.util.concurrent.ExecutorService executorService

batchSize

private final int batchSize

listeningThread

private ListeningThread listeningThread

Constructor Detail

ProcessingThread

ProcessingThread(AttestationResultService serviceIn,
                 java.util.concurrent.ExecutorService executorServiceIn,
                 AttestationModuleLoader moduleLoaderIn,
                 int batchSizeIn)

Method Detail

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()