Package io.odysz.semantic.syn

Class SyndomContext

java.lang.Object

io.odysz.semantic.syn.SyndomContext

public class SyndomContext
extends Object

A synode context, a database cache, per domain, for managing and sharing domain wide information, e.g. stamp, n0, Nyquvect, etc., across multiple syn-change handlers.

Author:

ody

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SyndomContext.OnMutexLock

Field Summary

Fields

Modifier and Type	Field	Description
SyncUser	admin	The admin's id, first of synusers in dictionary.json, used for logging into peers.
protected final SynChangeMeta	chgm
final boolean	dbg
protected String	domain
protected final SynchangeBuffMeta	exbm
static boolean	forceExceptionStamp2n0	Force throw exception if stamp >= n0 + 1 when try to increase stamp.
final SynodeMode	mode
protected final PeersMeta	pnvm
protected final SynSubsMeta	subm
final String	synconn
protected SyncUser	synlocker
final SynodeMeta	synm
final String	synode

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SyndomContext(SynodeMode mod, String dom, String synode, String synconn, boolean debug)

Method Summary

Modifier and Type	Method	Description
SyndomContext	admin(io.odysz.semantics.IUser r)
String	domain()
SyndomContext	domainitOnjoin(DBSyntableBuilder b, String dom, Nyquence n0)	Update domain context by upper node's reply.
static Nyquence	getNyquence(DATranscxt trb, String conn, io.odysz.semantics.IUser usr, SynodeMeta m, String nyqfield, String... where_eqs)	Load nyquence without triggering semantics handling.
static Nyquence	getNyquence(DBSyntableBuilder trb)	For test.
Nyquence	incN0(DBSyntableBuilder b)
void	incStamp(DBSyntableBuilder synb, HashMap<String,Nyquence> peernv)
SyndomContext	loadNvstamp(DATranscxt tb, io.odysz.semantics.IUser usr)
HashMap<String,Nyquence>	loadNvstamp(DBSyntableBuilder synb)
boolean	lockme(SyndomContext.OnMutexLock onMutext)	Request a mutex lock for synchronization, for synssion of myself.
boolean	lockx(SyncUser usr)
Nyquence	n0()
Nyquence	n0(DBSyntableBuilder synb, Nyquence maxn)
Nyquence	persistamp(DBSyntableBuilder trb, Nyquence... up2max)
Nyquence	persistNyquence(DBSyntableBuilder trb, String synid, Nyquence n)
long	stamp()
void	unlockme()
void	unlockx(SyncUser usr)

Methods inherited from class java.lang.Object

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

Field Details

forceExceptionStamp2n0

public static boolean forceExceptionStamp2n0

Force throw exception if stamp >= n0 + 1 when try to increase stamp.

dbg

public final boolean dbg

domain

protected String domain

synode

public final String synode

synconn

public final String synconn

synm

public final SynodeMeta synm

pnvm

protected final PeersMeta pnvm

subm

protected final SynSubsMeta subm

chgm

protected final SynChangeMeta chgm

exbm

protected final SynchangeBuffMeta exbm

admin

public SyncUser admin

The admin's id, first of synusers in dictionary.json, used for logging into peers. for tasks such as update syn_node, etc.

mode

public final SynodeMode mode

synlocker

protected SyncUser synlocker

Constructor Details

SyndomContext

protected SyndomContext(SynodeMode mod,
 String dom,
 String synode,
 String synconn,
 boolean debug)
                 throws Exception

Throws:

Exception

Method Details

domain

public String domain()

admin

public SyndomContext admin(io.odysz.semantics.IUser r)

stamp

public long stamp()

n0

public Nyquence n0()

incStamp

public void incStamp(DBSyntableBuilder synb,
 HashMap<String,Nyquence> peernv)
              throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

incN0

public Nyquence incN0(DBSyntableBuilder b)
               throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

n0

public Nyquence n0(DBSyntableBuilder synb,
 Nyquence maxn)
            throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

loadNvstamp

public HashMap<String,Nyquence> loadNvstamp(DBSyntableBuilder synb)
                                     throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

loadNvstamp

public SyndomContext loadNvstamp(DATranscxt tb,
 io.odysz.semantics.IUser usr)
                          throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

getNyquence

public static Nyquence getNyquence(DBSyntableBuilder trb)
                            throws SQLException,
io.odysz.transact.x.TransException

For test.

Parameters:

trb -

Returns:

Nyquence

Throws:

SQLException

io.odysz.transact.x.TransException

getNyquence

public static Nyquence getNyquence(DATranscxt trb,
 String conn,
 io.odysz.semantics.IUser usr,
 SynodeMeta m,
 String nyqfield,
 String... where_eqs)
                            throws SQLException,
io.odysz.transact.x.TransException

Load nyquence without triggering semantics handling.

Parameters:

trb -

conn -

m -

nyqfield -

where_eqs -

Returns:

nyquence

Throws:

SQLException

io.odysz.transact.x.TransException

domainitOnjoin

public SyndomContext domainitOnjoin(DBSyntableBuilder b,
 String dom,
 Nyquence n0)
                             throws io.odysz.transact.x.TransException,
SQLException

Update domain context by upper node's reply.

Parameters:

b -

dom -

n0 -

Returns:

Throws:

io.odysz.transact.x.TransException

SQLException

persistamp

public Nyquence persistamp(DBSyntableBuilder trb,
 Nyquence... up2max)
                    throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

persistNyquence

public Nyquence persistNyquence(DBSyntableBuilder trb,
 String synid,
 Nyquence n)
                         throws io.odysz.transact.x.TransException,
SQLException

Throws:

io.odysz.transact.x.TransException

SQLException

unlockx

public void unlockx(SyncUser usr)

lockme

public boolean lockme(SyndomContext.OnMutexLock onMutext)
               throws InterruptedException

Request a mutex lock for synchronization, for synssion of myself.

Parameters:

onMutext - delay provide, a random value, 0 for trying immediately, < 0 for quite.

Returns:

whether successful or not

Throws:

InterruptedException

unlockme

public void unlockme()

lockx

public boolean lockx(SyncUser usr)