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 DBSyntext which is used for handling local data integration and database semantics.

Author:

Ody

Field Summary

Fields

Modifier and Type	Field and Description
AnResultset	answerPage
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(), not correct after DBSyntableBuilder.cleanStale(HashMap, String) has been called.
DBSyntableBuilder	trb

Constructor Summary

Constructors

Constructor and 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 and 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.
ExchangeBlock	nextExchange(ExchangeBlock rep)
ExchangeBlock	onInit(ExchangeBlock ini) insert into exchanges select * from change_logs where n > nyquvect[sx.peer].n
int	pages()
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)

Methods inherited from class java.lang.Object

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

Field Detail

answerPage

public AnResultset answerPage

trb

public DBSyntableBuilder trb

totalChallenges

public int totalChallenges

Counted when in init(), 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 Detail

ExessionPersist

public ExessionPersist(DBSyntableBuilder tb,
                       String target)

Create context at client side.

Parameters:

tb -

chgm -

localtb - local transaction builder

target -

exbm -

subm -

builder -

ExessionPersist

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

Create context at server side.

Parameters:

tb -

session - session id supplied by client

chgm -

localtb -

target -

Method Detail

signup

public ExchangeBlock signup(String admin)

init

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

Setup exchange buffer table.

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

Parameters:

i -

Returns:

Throws:

io.odysz.transact.x.TransException

SQLException

SemanticException

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

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