Package io.odysz.semantic.syn

Class ExessionPersist

java.lang.Object

io.odysz.semantic.syn.ExessionPersist

public class ExessionPersist
extends Object

Persisting exchange session with remote node, using temporary tables. This is a session context, and different from DBSynmantext which is used for handling local data integration and database semantics.

Author:

Ody

Field Summary

Fields

Modifier and Type	Field	Description
int	answerSeq
int	challengeSeq	Challenging sequence number, i.
protected int	chsize	challenge page size
int	expAnswerSeq
String[]	ssinf	Information used by upper level, such as semantic.jser.
int	totalChallenges	Counted when in init(), and not correct after DBSyntableBuilder.cleanStale(HashMap, String) has been called.
DBSyntableBuilder	trb

Constructor Summary

Constructors

Constructor	Description
ExessionPersist(DBSyntableBuilder tb, String target)	Create context at client side.
ExessionPersist(DBSyntableBuilder tb, String peer, ExchangeBlock ini)	Create context at server side.

Method Summary

Modifier and Type	Method	Description
ExchangeBlock	abortExchange()
void	clear()
ExchangeBlock	closexchange(ExchangeBlock rep)
ExessionPersist	entities(String tbl, AnResultset ents)
ExessionPersist	expect(ExchangeBlock req)
ExessionAct	exstat()
int	exstate()
ExessionPersist	exstate(int state)
boolean	hasNextChpages(DBSyntableBuilder b)	Has another page in SynchangeBuffMeta.tbl to be send to.
ExchangeBlock	init()	Setup exchange buffer table.
Nyquence	n0()
ExchangeBlock	nextExchange(ExchangeBlock rep)
ExchangeBlock	onInit(ExchangeBlock ini)	insert into exchanges select * from change_logs where n > nyquvect[sx.peer].n
int	pages()
String	peer()
ExessionPersist	persisession()	update syn_node set session = {session, challengeSeq, answers, ...}
ExessionPersist	persistarting(String peer)	Save starting session.
ExchangeBlock	retryLast(String peer)	Retry last page
String	session()
ExchangeBlock	signup(String admin)	Create a signing up request.
Nyquence	stamp()

Methods inherited from class java.lang.Object

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

Field Details

trb

public DBSyntableBuilder trb

totalChallenges

public int totalChallenges

Counted when in init(), and not correct after DBSyntableBuilder.cleanStale(HashMap, String) has been called.

expAnswerSeq

public int expAnswerSeq

challengeSeq

public int challengeSeq

Challenging sequence number, i. e. current page

chsize

protected int chsize

challenge page size

answerSeq

public int answerSeq

ssinf

public String[] ssinf

Information used by upper level, such as semantic.jser.

Constructor Details

ExessionPersist

public ExessionPersist(DBSyntableBuilder tb,
 String target)

Create context at client side.

Parameters:

tb -

target -

ExessionPersist

public ExessionPersist(DBSyntableBuilder tb,
 String peer,
 ExchangeBlock ini)

Create context at server side.

Parameters:

tb -

Method Details

peer

public String peer()

signup

public ExchangeBlock signup(String admin)
                     throws SQLException,
io.odysz.transact.x.TransException

Create a signing up request.

Parameters:

admin -

Returns:

the request

Throws:

SQLException

io.odysz.transact.x.TransException

init

public ExchangeBlock init()
                   throws io.odysz.transact.x.TransException,
SQLException

Setup exchange buffer table.

 exstate.state = init;
 expAnswerSeq = 0;
 challengeSeq = 0;
 answerSeq = 0;
 

Throws:

io.odysz.transact.x.TransException

SQLException

onInit

public ExchangeBlock onInit(ExchangeBlock ini)
                     throws io.odysz.transact.x.TransException,
SQLException

insert into exchanges select * from change_logs where n > nyquvect[sx.peer].n

Parameters:

ini -

Returns:

new message

Throws:

io.odysz.transact.x.TransException

SQLException

clear

public void clear()

session

public String session()

exstate

public int exstate()

exstate

public ExessionPersist exstate(int state)

exstat

public ExessionAct exstat()

hasNextChpages

public boolean hasNextChpages(DBSyntableBuilder b)
                       throws SQLException,
io.odysz.transact.x.TransException

Has another page in SynchangeBuffMeta.tbl to be send to.

Parameters:

b - synchronizing transaction builder

Returns:

true if has another page

Throws:

SQLException

io.odysz.transact.x.TransException

expect

public ExessionPersist expect(ExchangeBlock req)
                       throws ExchangeException

Throws:

ExchangeException

nextExchange

public ExchangeBlock nextExchange(ExchangeBlock rep)
                           throws SQLException,
io.odysz.transact.x.TransException

Throws:

SQLException

io.odysz.transact.x.TransException

closexchange

public ExchangeBlock closexchange(ExchangeBlock rep)
                           throws ExchangeException

Throws:

ExchangeException

abortExchange

public ExchangeBlock abortExchange()

retryLast

public ExchangeBlock retryLast(String peer)
                        throws io.odysz.transact.x.TransException,
SQLException

Retry last page

Parameters:

peer -

Returns:

request message

Throws:

SQLException

io.odysz.transact.x.TransException

n0

public Nyquence n0()

entities

public ExessionPersist entities(String tbl,
 AnResultset ents)

pages

public int pages()

persisession

public ExessionPersist persisession()
                             throws io.odysz.transact.x.TransException,
SQLException

update syn_node set session = {session, challengeSeq, answers, ...}

Returns:

this

Throws:

SQLException

io.odysz.transact.x.TransException

persistarting

public ExessionPersist persistarting(String peer)
                              throws io.odysz.transact.x.TransException,
SQLException

Save starting session.

Parameters:

peer -

Returns:

this

Throws:

io.odysz.transact.x.TransException

SQLException

stamp

public Nyquence stamp()