de.ipcon.db

Class SyncService

java.lang.Object

de.ipcon.db.SyncService

All Implemented Interfaces:

java.lang.Runnable

public class SyncService
extends java.lang.Object
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor and Description
SyncService()

Method Summary

Modifier and Type	Method and Description
void	checkIds()
static java.lang.Long	connectToAuthoritativeServer(DBManLocalI _dbm, BackendConnectionManager _rcl, java.lang.String _authNodeUrl, java.lang.String _authNodeUser, java.lang.String _authNodePass) Connect to and authenticate with authoritative server.
java.lang.String	dot(boolean last)
void	handleLogSync()
void	init(DBManLocalI _dbm, netrexx.lang.Rexx _section)
void	injectIntoTx(Transaction tx, java.lang.Long id, BOT bot)
void	localDBManEvent(DBManEvent e)
void	localSave(Transaction txl, Transaction txr) Saves transaction that occurred on remote server to local database.
void	logSync(BT bt, Transaction tx, BLOBLoaderI blobLoader, Transaction txForFutureBLOBChangingBPsQuery) Version 2 der logSync-Methode.
void	logSync(de.ipcon.db.core.QueryResultsI localQR, de.ipcon.db.core.QueryResultsI remoteQR)
void	logSyncLocalToRemote(BT bt, Transaction txl, Transaction txr, boolean last) Saves transaction that occurred in local database to remote server.
void	logSyncRemoteToLocal(BT bt, Transaction txl, Transaction txr, boolean last) Saves transaction that occurred on remote server to local database.
void	rememberLocalBT(BT bt)
void	rememberRemoteBT(BT bt)
void	remoteDBManEvent(DBManEvent e)
void	remoteSave(Transaction txl, Transaction txr) Saves transaction that occurred in local database to remote server.
void	run()
boolean	syncChecker(boolean ignoreCheckInterval)
void	synthesizeBOIntoTx(ObjectNotPersistentException onpe, BOLoaderI loader, Transaction tx)
void	synthesizeBOIntoTx(ObjectsNotPersistentException osnpe, BOLoaderI loader, Transaction tx)
void	synthesizeBOIntoTx(PersistenceException pe, BOLoaderI loader, Transaction tx)
void	waitOnEvent(boolean checkForRemoteChanges)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncService

public SyncService()

Method Detail

init

public void init(DBManLocalI _dbm,
                 netrexx.lang.Rexx _section)

run

public void run()

Specified by:

run in interface java.lang.Runnable

connectToAuthoritativeServer

public static java.lang.Long connectToAuthoritativeServer(DBManLocalI _dbm,
                                                          BackendConnectionManager _rcl,
                                                          java.lang.String _authNodeUrl,
                                                          java.lang.String _authNodeUser,
                                                          java.lang.String _authNodePass)

Connect to and authenticate with authoritative server.

waitOnEvent

public void waitOnEvent(boolean checkForRemoteChanges)

localDBManEvent

public void localDBManEvent(DBManEvent e)

remoteDBManEvent

public void remoteDBManEvent(DBManEvent e)

rememberLocalBT

public void rememberLocalBT(BT bt)

rememberRemoteBT

public void rememberRemoteBT(BT bt)

handleLogSync

public void handleLogSync()
                   throws java.lang.Throwable

Throws:

java.lang.Throwable

logSync

public void logSync(de.ipcon.db.core.QueryResultsI localQR,
                    de.ipcon.db.core.QueryResultsI remoteQR)
             throws java.lang.Throwable

Throws:

java.lang.Throwable

dot

public java.lang.String dot(boolean last)

logSyncRemoteToLocal

public void logSyncRemoteToLocal(BT bt,
                                 Transaction txl,
                                 Transaction txr,
                                 boolean last)

Saves transaction that occurred on remote server to local database.

localSave

public void localSave(Transaction txl,
                      Transaction txr)

Saves transaction that occurred on remote server to local database.

Parameters:

txl - the transaction that gets saved

txr - FIXME TT 2019-02-07: not used

logSyncLocalToRemote

public void logSyncLocalToRemote(BT bt,
                                 Transaction txl,
                                 Transaction txr,
                                 boolean last)

Saves transaction that occurred in local database to remote server.

remoteSave

public void remoteSave(Transaction txl,
                       Transaction txr)

Saves transaction that occurred in local database to remote server.

Parameters:

txl - FIXME TT 2019-02-07: not used

txr - the transaction that gets saved

synthesizeBOIntoTx

public void synthesizeBOIntoTx(PersistenceException pe,
                               BOLoaderI loader,
                               Transaction tx)

synthesizeBOIntoTx

public void synthesizeBOIntoTx(ObjectNotPersistentException onpe,
                               BOLoaderI loader,
                               Transaction tx)

synthesizeBOIntoTx

public void synthesizeBOIntoTx(ObjectsNotPersistentException osnpe,
                               BOLoaderI loader,
                               Transaction tx)

logSync

public void logSync(BT bt,
                    Transaction tx,
                    BLOBLoaderI blobLoader,
                    Transaction txForFutureBLOBChangingBPsQuery)

Version 2 der logSync-Methode. Da wir jetzt auch Transaktionen zum Server schicken koennen, in denen die BOs nicht 'real' sind, also gegen blinde Stubs getauscht sind, die lediglich id, crea, und lmod enthalten, zudem im Log auch die neu erstellen Objekte explizit genannt werden, koennen wir auch eine BO-Liste der beteiligten Objekte erstellen. Damit kriegen wir allein aus einer BT alles zusammen, was wir fuer eine Transaction brauchen. Na denn mal los...

injectIntoTx

public void injectIntoTx(Transaction tx,
                         java.lang.Long id,
                         BOT bot)

syncChecker

public boolean syncChecker(boolean ignoreCheckInterval)

checkIds

public void checkIds()