Package com.h2tcoin.takamakachain.utils.threadSafeUtils

Class TkmNodeManager

java.lang.Object

com.h2tcoin.takamakachain.utils.threadSafeUtils.TkmNodeManager

public class TkmNodeManager
extends Object

Author:

iris.dimni

Constructor Summary

Constructors

Constructor	Description
TkmNodeManager()

Method Summary

Modifier and Type	Method	Description
static KeyWriterStatusBean	createNodeManagerStatusBean(int epoch, int slot, String uid)
static ConcurrentSkipListMap<String,ConcurrentSkipListSet<String>>	getBucketMap(ConcurrentSkipListSet<String> input)
static ConcurrentSkipListSet<String>	getDiffHexKeyeList(ConcurrentSkipListMap<String,NodeManagerBean> input, ConcurrentSkipListSet<String> diffList)
static KeyWriterNodeManagerBean	getKeyWriterNodeManagerQueryBean(TransactionBox[] transactions)	starting from an array of transactions the method generates a container with all the addresses involved to efficiently perform the bulk recovery of the financial statements and their subsequent updating.
static KeyWriterStatusBean	getKWSB(KeyWriterSerializableStatusBean kwSSB)	convert system status to serializable form
static void	getLinkByAddr(ConcurrentSkipListSet<String> addrs, int e, int s, String u)
static ConcurrentSkipListSet<String>	getLinkedHexKeyes(ConcurrentSkipListMap<String,NodeManagerBean> input)
static KeyWriterSerializableStatusBean	getSerializableKWSB(KeyWriterStatusBean kwSB)	get the serializable version of the key status writer
static KeyWriterStatusBean	nextNodeStatusBean(int epoch, int slot, String uid, KeyWriterStatusBean oldKwSB)
static KeyWriterStatusBean	readStatusBeanFromFile(int epoch, int slot, String uid, FixedParameters.HexKeyWriter type)	read path file from disk
static ConcurrentSkipListMap<String,NodeManagerBean>	retriveNodeLinks(KeyWriterNodeManagerBean nwB, KeyWriterStatusBean kwSB)	this function does not alter bean.
static void	saveStatusBeanToFile(KeyWriterStatusBean kwSB)	save passed status file to disk in json form
static void	updateNodeLinks(KeyWriterGlobalStatus kwGS)
static void	updateNodeLinksDeregister(KeyWriterGlobalStatus kwGS)

Methods inherited from class java.lang.Object

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

Constructor Detail

TkmNodeManager

public TkmNodeManager()

Method Detail

createNodeManagerStatusBean

public static KeyWriterStatusBean createNodeManagerStatusBean(int epoch,
                                                              int slot,
                                                              String uid)

nextNodeStatusBean

public static KeyWriterStatusBean nextNodeStatusBean(int epoch,
                                                     int slot,
                                                     String uid,
                                                     KeyWriterStatusBean oldKwSB)

getKeyWriterNodeManagerQueryBean

public static KeyWriterNodeManagerBean getKeyWriterNodeManagerQueryBean(TransactionBox[] transactions)

starting from an array of transactions the method generates a container with all the addresses involved to efficiently perform the bulk recovery of the financial statements and their subsequent updating. Punctual recovery from the filesystem is too expensive when over a thousand queries are exceeded. Furthermore the search space is potentially 2 ^ 256 addresses. This makes it impossible to use completely memory solutions.

Parameters:

transactions -

Returns:

retriveNodeLinks

public static ConcurrentSkipListMap<String,NodeManagerBean> retriveNodeLinks(KeyWriterNodeManagerBean nwB,
                                                                                   KeyWriterStatusBean kwSB)

this function does not alter bean. Return a brand new list of beans from saved values the retrieve key is the hex format of the address. Returns a list of ALL the nodes linked to the given address

Parameters:

kwBB -

kwSB -

Returns:

getLinkByAddr

public static void getLinkByAddr(ConcurrentSkipListSet<String> addrs,
                                 int e,
                                 int s,
                                 String u)

getLinkedHexKeyes

public static ConcurrentSkipListSet<String> getLinkedHexKeyes(ConcurrentSkipListMap<String,NodeManagerBean> input)

getDiffHexKeyeList

public static ConcurrentSkipListSet<String> getDiffHexKeyeList(ConcurrentSkipListMap<String,NodeManagerBean> input,
                                                               ConcurrentSkipListSet<String> diffList)

updateNodeLinks

public static void updateNodeLinks(KeyWriterGlobalStatus kwGS)

updateNodeLinksDeregister

public static void updateNodeLinksDeregister(KeyWriterGlobalStatus kwGS)

saveStatusBeanToFile

public static void saveStatusBeanToFile(KeyWriterStatusBean kwSB)

save passed status file to disk in json form

Parameters:

kwSB -

getSerializableKWSB

public static KeyWriterSerializableStatusBean getSerializableKWSB(KeyWriterStatusBean kwSB)

get the serializable version of the key status writer

Parameters:

kwSB -

Returns:

getKWSB

public static KeyWriterStatusBean getKWSB(KeyWriterSerializableStatusBean kwSSB)

convert system status to serializable form

Parameters:

kwSSB -

Returns:

readStatusBeanFromFile

public static KeyWriterStatusBean readStatusBeanFromFile(int epoch,
                                                         int slot,
                                                         String uid,
                                                         FixedParameters.HexKeyWriter type)

read path file from disk

Parameters:

epoch -

slot -

uid -

type -

Returns:

getBucketMap

public static ConcurrentSkipListMap<String,ConcurrentSkipListSet<String>> getBucketMap(ConcurrentSkipListSet<String> input)

Parameters:

input -

Returns: