messageProcessor
Class MessageProcessorController.RequestMixThread

java.lang.Object
  java.lang.Thread
      messageProcessor.MessageProcessorController.RequestMixThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

MessageProcessorController

private final class MessageProcessorController.RequestMixThread
extends java.lang.Thread

Thread, which coordinates the mixing process of request. Can be instantiated several times, to increase mix performance on systems with several processing units.

Included functionality:

• taking (unprocessed) requests from InputOutputHandler
• decrypting requests
• validating integrity
• detecting replays
• passing (the now processed) requests to the OutputStrategy component.

See ReplyMixThread for the thread coordinating replies.

Author:

Karl-Peter Fuchs

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private Recoder	recoder The Recoder used to decrypt messages.
private ReplayDetection	replayDetection ReplayDetection used to detect replays.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

private

MessageProcessorController.RequestMixThread(Recoder recoder, ReplayDetection replayDetection) Saves references on the bypassed objects and calls start() .

Method Summary

void	run() Coordinates the mixing process of request.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

recoder

private Recoder recoder

The Recoder used to decrypt messages.

replayDetection

private ReplayDetection replayDetection

ReplayDetection used to detect replays.

Constructor Detail

MessageProcessorController.RequestMixThread

private MessageProcessorController.RequestMixThread(Recoder recoder,
                                                    ReplayDetection replayDetection)

Saves references on the bypassed objects and calls start() .

Parameters:

recoder - The Recoder that shall be used to decrypt messages.

replayDetection - ReplayDetection used to detect replays.

Method Detail

run

public void run()

Coordinates the mixing process of request.

Included functionality:

• taking (unprocessed) requests from InputOutputHandler
• decrypting requests
• validating integrity
• detecting replays
• passing (the now processed) requests to the OutputStrategy component.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread