Package com.h2tcoin.takamakachain.transactions

Class TkmStakeBeanHelper

java.lang.Object

com.h2tcoin.takamakachain.transactions.TkmStakeBeanHelper

public class TkmStakeBeanHelper
extends Object

Author:

Giovanni Antino

Field Summary

Fields

Modifier and Type	Field	Description
static Object	ARCHIVE_PATH_MAP_LOCK
static Object	BET_UPDATE_LOCK

Constructor Summary

Constructors

Constructor	Description
TkmStakeBeanHelper()

Method Summary

Modifier and Type	Method	Description
static void	acceptBets(KeyWriterGlobalStatus kwGS)
static void	applyStakeUndo(KeyWriterGlobalStatus kwGS)
static ConcurrentSkipListMap<String,AcceptedBetByHolderBean>	cleanBucketAcceptedBet(ConcurrentSkipListMap<String,AcceptedBetByHolderBean> bucket)
static boolean	compareStakeBean(StakeBean source, StakeBean dest)	TODO test
static ConcurrentSkipListMap<String,AcceptedBetByTargetBean>	convertAcceptedBetByHolderToAcceptedBetByTarget(ConcurrentSkipListSet<AcceptedBetByHolderBean> acceptedBetByHolderSet)
protected static StakeBeanInternal	createStakeBeanInternal(TransactionBox tbox)
protected static StakeBeanInternal	createStakeBeanInternal(String sith, String targetAddress, BigInteger value, long stakeDate)
static ConcurrentSkipListMap<String,AcceptedBetByTargetBean>	deepCopy(ConcurrentSkipListMap<String,AcceptedBetByTargetBean> abbtMap)	Create an independent copy of the object passed as an argument
static ConcurrentSkipListSet<AcceptedBetByHolderBean>	getAcceptedBetByHolderAtPointInTime(int epoch, int slot, String uid)
static ConcurrentSkipListSet<AcceptedBetByHolderBean>	getAcceptedBetByHolderAtPointInTime(int epoch, int slot, String uid, ConcurrentSkipListSet<String> hexKeys)	This function reads the status from the persistent archive.
static ConcurrentSkipListMap<String,AcceptedBetByTargetBean>	getAcceptedBetByTargetAtPointInTime(int epoch, int slot, String uid)	This function reads the status from the persistent archive.
static StakeBean	getEmptyStakeBean(String holderAddrURL64)
static ConcurrentSkipListSet<StakeDataBean>	getHolderStakesAtPointInTime(int epoch, int slot, String uid, ConcurrentSkipListSet<String> hexKeys)	This function reads the status from the persistent archive.
static AcceptedBetByHolderBean	getNewAcceptedBetByHolderBean(String fromUrl64)	return a new empty initialized accepted bet by holder bean
static AcceptedBetByTargetBean	getNewAcceptedBetByTargetBean(String addrUrl64)
static ConcurrentSkipListSet<StakeUndoBean>	getStakeUndoAtPointInTime(int epoch, int slot, String uid, ConcurrentSkipListSet<String> hexKeys)
static void	mergeStakeBeanRightToLeft(StakeBean left, StakeBean right)
static void	overwriteStakeBeanLeftToRight(StakeBean left, StakeBean right)	left is more recent of right.
static void	sumRightToLeft(AcceptedBetByTargetBean left, AcceptedBetByTargetBean right)	This function modifies the list of left stakes.
static void	traceOverTheLimit(KeyWriterGlobalStatus kwGS)

Methods inherited from class java.lang.Object

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

Field Detail

BET_UPDATE_LOCK

public static final Object BET_UPDATE_LOCK

ARCHIVE_PATH_MAP_LOCK

public static final Object ARCHIVE_PATH_MAP_LOCK

Constructor Detail

TkmStakeBeanHelper

public TkmStakeBeanHelper()

Method Detail

getEmptyStakeBean

public static StakeBean getEmptyStakeBean(String holderAddrURL64)

createStakeBeanInternal

protected static StakeBeanInternal createStakeBeanInternal(String sith,
                                                           String targetAddress,
                                                           BigInteger value,
                                                           long stakeDate)

createStakeBeanInternal

protected static StakeBeanInternal createStakeBeanInternal(TransactionBox tbox)

compareStakeBean

public static boolean compareStakeBean(StakeBean source,
                                       StakeBean dest)

TODO test

Parameters:

source -

dest -

Returns:

mergeStakeBeanRightToLeft

public static void mergeStakeBeanRightToLeft(StakeBean left,
                                             StakeBean right)

overwriteStakeBeanLeftToRight

public static void overwriteStakeBeanLeftToRight(StakeBean left,
                                                 StakeBean right)

left is more recent of right. Overwite right with left.

Parameters:

left -

right -

applyStakeUndo

public static void applyStakeUndo(KeyWriterGlobalStatus kwGS)

traceOverTheLimit

public static void traceOverTheLimit(KeyWriterGlobalStatus kwGS)

acceptBets

public static void acceptBets(KeyWriterGlobalStatus kwGS)

getNewAcceptedBetByHolderBean

public static AcceptedBetByHolderBean getNewAcceptedBetByHolderBean(String fromUrl64)

return a new empty initialized accepted bet by holder bean

Parameters:

fromUrl64 -

Returns:

cleanBucketAcceptedBet

public static ConcurrentSkipListMap<String,AcceptedBetByHolderBean> cleanBucketAcceptedBet(ConcurrentSkipListMap<String,AcceptedBetByHolderBean> bucket)

getAcceptedBetByTargetAtPointInTime

public static ConcurrentSkipListMap<String,AcceptedBetByTargetBean> getAcceptedBetByTargetAtPointInTime(int epoch,
                                                                                                              int slot,
                                                                                                              String uid)

This function reads the status from the persistent archive. It should always be called AFTER TkmOperations.persistGlobalStatus (globalStatus). This function has a high computational load, do not use in methods that must respond in limited time.

Parameters:

epoch -

slot -

uid -

Returns:

deepCopy

public static ConcurrentSkipListMap<String,AcceptedBetByTargetBean> deepCopy(ConcurrentSkipListMap<String,AcceptedBetByTargetBean> abbtMap)

Create an independent copy of the object passed as an argument

Parameters:

abbtMap -

Returns:

sumRightToLeft

public static void sumRightToLeft(AcceptedBetByTargetBean left,
                                  AcceptedBetByTargetBean right)

This function modifies the list of left stakes. The stakes contained in the right bean are added or created in the left bean

Parameters:

left -

right -

getAcceptedBetByHolderAtPointInTime

public static ConcurrentSkipListSet<AcceptedBetByHolderBean> getAcceptedBetByHolderAtPointInTime(int epoch,
                                                                                                 int slot,
                                                                                                 String uid,
                                                                                                 ConcurrentSkipListSet<String> hexKeys)

This function reads the status from the persistent archive. It should always be called AFTER TkmOperations.persistGlobalStatus (globalStatus). This function has a high computational load, do not use in methods that must respond in limited time.

Parameters:

epoch -

slot -

uid -

Returns:

getAcceptedBetByHolderAtPointInTime

public static ConcurrentSkipListSet<AcceptedBetByHolderBean> getAcceptedBetByHolderAtPointInTime(int epoch,
                                                                                                 int slot,
                                                                                                 String uid)

getHolderStakesAtPointInTime

public static ConcurrentSkipListSet<StakeDataBean> getHolderStakesAtPointInTime(int epoch,
                                                                                int slot,
                                                                                String uid,
                                                                                ConcurrentSkipListSet<String> hexKeys)

This function reads the status from the persistent archive. This function has a high computational load, do not use in methods that must respond in limited time.

Parameters:

epoch -

slot -

uid -

Returns:

getNewAcceptedBetByTargetBean

public static AcceptedBetByTargetBean getNewAcceptedBetByTargetBean(String addrUrl64)

convertAcceptedBetByHolderToAcceptedBetByTarget

public static ConcurrentSkipListMap<String,AcceptedBetByTargetBean> convertAcceptedBetByHolderToAcceptedBetByTarget(ConcurrentSkipListSet<AcceptedBetByHolderBean> acceptedBetByHolderSet)

getStakeUndoAtPointInTime

public static ConcurrentSkipListSet<StakeUndoBean> getStakeUndoAtPointInTime(int epoch,
                                                                             int slot,
                                                                             String uid,
                                                                             ConcurrentSkipListSet<String> hexKeys)