run

func BlockPrint(block chain.Block)

func NewTask(model *python3.PyObject, unlabel *python3.PyObject, size [][]int, comp_size []int, globalParam [][]float64, momentum [][]float64, rank int, beta float64, slr float64) network.TaskInfo

func NodesCommitteeUpdate(nodes []*node.Node, conn *rpc.Client, bcnet *network.BlockchainNetwork)

func NodesGetTask(nodes []*node.Node, bcnet *network.BlockchainNetwork)

func ProcessBlock(bcnet *network.BlockchainNetwork, nodes []*node.Node, testData *python3.PyObject, conn *rpc.Client)

func ProcessBlockPre(nodes []*node.Node, round int, conn *rpc.Client, bcnet *network.BlockchainNetwork)

func ProcessCommittee(nodes []*node.Node, conn *rpc.Client, bcnet *network.BlockchainNetwork)

func ProcessFL(workers []*client.Client, attackers []*client.Client, round int, nodes []*node.Node, conn *rpc.Client)

func ProcessNextRound(bcnet *network.BlockchainNetwork, nodes []*node.Node, conn *rpc.Client, round *int)

func SaveStakeMap(nodes []*node.Node, stakemap map[int]int)

func TaskPublish(task network.TaskInfo, bcnet *network.BlockchainNetwork)

func Test(model *python3.PyObject, globalModel *python3.PyObject, testData *python3.PyObject, model_size [][]int) float64