de.ipcon.db.protocol

Class BackendCommandHandler

java.lang.Object

java.lang.Thread

de.ipcon.db.protocol.BackendCommandHandler

All Implemented Interfaces:

DBManEventListenerI, BackendCommandHandlerI, java.lang.Runnable

public class BackendCommandHandler
extends java.lang.Thread
implements DBManEventListenerI, BackendCommandHandlerI

Instances of BackendCommandHandler threads are responsible for handling commands from the client and sending out DBMan events to them. For every client there are two commandHandler instances: one which the client sent the CMD_LOGIN to which after that handles the DBMan event sending and one new instance which listens to and handles further commands from the client.

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static int	HANDLED_OK
static int	HANDLED_WANT_EXIT
static org.apache.log4j.Logger	log

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
BackendCommandHandler(BackendProtocolServer _backend, java.lang.String _logString, TransportI _transport, java.lang.String _postfix, java.lang.String ip, java.lang.String threadName)

Method Summary

Modifier and Type	Method and Description
void	cancelRequest(int slot)
PermissionHandlerDecisionI	checkReadAllowed(BO bo)
void	close()
void	close(boolean fromDecCommandHandler)
void	cookEvents(L10nCurrentLocaleProviderI localeProviderForThread, java.lang.String threadName)
void	createSessionForLogin(Anmeldung anmeldung, java.lang.String claddr, java.lang.String clport)
void	enterLoginMode()
boolean	exists(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
BackendProtocolServerI	getBackend()
BackendQueryAnsweringBOLoaderI	getBackendQueryAnsweringBOLoaderInstance() Returns a new BackendQueryAnsweringBOLoaderI which is aware that it is answering a backend query and thus can be asked about that.
byte[]	getBLOB(java.lang.Long id)
long	getBLOB(java.lang.Long id, java.io.DataOutput os)
long	getBLOB(java.lang.Long id, java.io.DataOutput os, boolean closeOS)
long	getBLOB(java.lang.Long id, java.io.DataOutput os, boolean closeOS, java.lang.Long backuppingBPId)
byte[]	getBLOB(java.lang.Long id, java.lang.Long backuppingBPId)
InputStreamWrapper	getBLOBAsStream(java.lang.Long id)
InputStreamWrapper	getBLOBAsStream(java.lang.Long id, java.lang.Long backuppingBPId)
InitialBLOBTransferMetaDataContainer	getBLOBBOIdsForIntitialBLOBCopy(java.util.Map idsAndVFilesOnSyncNode, java.util.List pendingBLOBChangeBOIdsOnSyncNode, java.util.List pendingBLOBChangeBOIdsOnAuthNode)
VFile	getBLOBInfo(java.lang.Long id)
VFile	getBLOBInfo(java.lang.Long id, java.lang.Long backuppingBPId)
DBManLocalI	getDbm()
java.lang.String	getDescription()
KeyRange	getIdRange(long size)
BOLoaderI	getLoader()
java.lang.Long	getNextId()
int	getPid()
SchemaI	getSchema()
BackendSessionI	getSession()
DBManUserContextI	getUtx()
void	handleServerSideBackendRequest(BackendRequestI br)
void	incObjects()
void	initNewSession(java.lang.Long sessionId)
boolean	isAuthed()
boolean	isBackStreamToClient() Returns true, if this backend command handler is acting as back stream to the client, false otherwise.
boolean	isLoginMode()
boolean	isServerAuth()
void	leaveLoginMode()
void	processDBManEvent(DBManEvent e) Processes a DBManEvent by placing it into an ArrayDeque and notifying the BackendCommandHandler, which is responsible for transporting the event to the client.
void	putResponse(java.lang.Object br)
java.util.List	queryBO(java.lang.String t)
java.util.List	queryBO(java.lang.String t, java.lang.Object[] pvals)
void	responder() Worker thread responsible for emptying the responseQueue and sending the actual responses.
void	run()
void	startEventListening()

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

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface de.ipcon.db.protocol.BackendCommandHandlerI

start

Field Detail

log

public static final org.apache.log4j.Logger log

HANDLED_OK

public static final int HANDLED_OK

See Also:

Constant Field Values

HANDLED_WANT_EXIT

public static final int HANDLED_WANT_EXIT

See Also:

Constant Field Values

Constructor Detail

BackendCommandHandler

public BackendCommandHandler(BackendProtocolServer _backend,
                             java.lang.String _logString,
                             TransportI _transport,
                             java.lang.String _postfix,
                             java.lang.String ip,
                             java.lang.String threadName)

Method Detail

getDbm

public DBManLocalI getDbm()

getBackend

public BackendProtocolServerI getBackend()

Specified by:

getBackend in interface BackendCommandHandlerI

getSession

public BackendSessionI getSession()

Specified by:

getSession in interface BackendCommandHandlerI

getUtx

public DBManUserContextI getUtx()

Specified by:

getUtx in interface BackendCommandHandlerI

getLoader

public BOLoaderI getLoader()

Specified by:

getLoader in interface BackendCommandHandlerI

getPid

public int getPid()

Specified by:

getPid in interface BackendCommandHandlerI

cancelRequest

public void cancelRequest(int slot)

Specified by:

cancelRequest in interface BackendCommandHandlerI

close

public void close()

Specified by:

close in interface BackendCommandHandlerI

close

public void close(boolean fromDecCommandHandler)

isAuthed

public boolean isAuthed()

Specified by:

isAuthed in interface BackendCommandHandlerI

isLoginMode

public boolean isLoginMode()

Specified by:

isLoginMode in interface BackendCommandHandlerI

isBackStreamToClient

public boolean isBackStreamToClient()

Description copied from interface: BackendCommandHandlerI

Returns true, if this backend command handler is acting as back stream to the client, false otherwise.

Specified by:

isBackStreamToClient in interface BackendCommandHandlerI

checkReadAllowed

public PermissionHandlerDecisionI checkReadAllowed(BO bo)

Specified by:

checkReadAllowed in interface BackendCommandHandlerI

incObjects

public void incObjects()

Specified by:

incObjects in interface BackendCommandHandlerI

getDescription

public java.lang.String getDescription()

getBackendQueryAnsweringBOLoaderInstance

public BackendQueryAnsweringBOLoaderI getBackendQueryAnsweringBOLoaderInstance()

Description copied from interface: BackendCommandHandlerI

Returns a new BackendQueryAnsweringBOLoaderI which is aware that it is answering a backend query and thus can be asked about that.

Specified by:

getBackendQueryAnsweringBOLoaderInstance in interface BackendCommandHandlerI

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

handleServerSideBackendRequest

public void handleServerSideBackendRequest(BackendRequestI br)
                                    throws java.io.IOException,
                                           java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

putResponse

public void putResponse(java.lang.Object br)

Specified by:

putResponse in interface BackendCommandHandlerI

responder

public void responder()

Worker thread responsible for emptying the responseQueue and sending the actual responses.

initNewSession

public void initNewSession(java.lang.Long sessionId)

Specified by:

initNewSession in interface BackendCommandHandlerI

createSessionForLogin

public void createSessionForLogin(Anmeldung anmeldung,
                                  java.lang.String claddr,
                                  java.lang.String clport)
                           throws AuthenticationException

Specified by:

createSessionForLogin in interface BackendCommandHandlerI

Throws:

AuthenticationException

enterLoginMode

public void enterLoginMode()

Specified by:

enterLoginMode in interface BackendCommandHandlerI

leaveLoginMode

public void leaveLoginMode()

Specified by:

leaveLoginMode in interface BackendCommandHandlerI

startEventListening

public void startEventListening()

Specified by:

startEventListening in interface BackendCommandHandlerI

processDBManEvent

public void processDBManEvent(DBManEvent e)

Processes a DBManEvent by placing it into an ArrayDeque and notifying the BackendCommandHandler, which is responsible for transporting the event to the client. The event handler thread from DBMan is thus not delayed by the actual processing of the event.

Specified by:

processDBManEvent in interface DBManEventListenerI

Parameters:

e - The DBManEvent to be processed.

cookEvents

public void cookEvents(L10nCurrentLocaleProviderI localeProviderForThread,
                       java.lang.String threadName)

exists

public boolean exists(java.lang.Long id,
                      java.lang.Class<? extends BOI> classtip)

Specified by:

exists in interface BackendCommandHandlerI

queryBO

public java.util.List queryBO(java.lang.String t)

queryBO

public java.util.List queryBO(java.lang.String t,
                              java.lang.Object[] pvals)

isServerAuth

public boolean isServerAuth()

Specified by:

isServerAuth in interface BackendCommandHandlerI

getNextId

public java.lang.Long getNextId()

Specified by:

getNextId in interface BackendCommandHandlerI

getIdRange

public KeyRange getIdRange(long size)

Specified by:

getIdRange in interface BackendCommandHandlerI

getBLOB

public byte[] getBLOB(java.lang.Long id)

getBLOB

public byte[] getBLOB(java.lang.Long id,
                      java.lang.Long backuppingBPId)

getBLOBAsStream

public InputStreamWrapper getBLOBAsStream(java.lang.Long id)

getBLOBAsStream

public InputStreamWrapper getBLOBAsStream(java.lang.Long id,
                                          java.lang.Long backuppingBPId)

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os)

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os,
                    boolean closeOS)

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os,
                    boolean closeOS,
                    java.lang.Long backuppingBPId)

Specified by:

getBLOB in interface BackendCommandHandlerI

getBLOBInfo

public VFile getBLOBInfo(java.lang.Long id)

getBLOBInfo

public VFile getBLOBInfo(java.lang.Long id,
                         java.lang.Long backuppingBPId)

getBLOBBOIdsForIntitialBLOBCopy

public InitialBLOBTransferMetaDataContainer getBLOBBOIdsForIntitialBLOBCopy(java.util.Map idsAndVFilesOnSyncNode,
                                                                            java.util.List pendingBLOBChangeBOIdsOnSyncNode,
                                                                            java.util.List pendingBLOBChangeBOIdsOnAuthNode)
                                                                     throws java.io.IOException

Throws:

java.io.IOException

getSchema

public SchemaI getSchema()

Specified by:

getSchema in interface BackendCommandHandlerI