Channel production and consumption set up. Ready to fully implement.
This commit is contained in:
parent
7f1b5c5f9b
commit
b1dd4f79f3
@ -357,6 +357,7 @@ func geth(ctx *cli.Context) error {
|
|||||||
stack.RegisterAPIs(pluginGetAPIs(stack, wrapperBackend))
|
stack.RegisterAPIs(pluginGetAPIs(stack, wrapperBackend))
|
||||||
//end PluGeth code injection
|
//end PluGeth code injection
|
||||||
startNode(ctx, stack, backend, false)
|
startNode(ctx, stack, backend, false)
|
||||||
|
pluginHookTester()
|
||||||
stack.Wait()
|
stack.Wait()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -98,6 +98,7 @@ func PluginPostProcessBlock(pl *plugins.PluginLoader, block *types.Block) {
|
|||||||
_, ok := item.(func(core.Hash))
|
_, ok := item.(func(core.Hash))
|
||||||
return ok
|
return ok
|
||||||
})
|
})
|
||||||
|
log.Error("inside post pppp()))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))))")
|
||||||
for _, fni := range fnList {
|
for _, fni := range fnList {
|
||||||
if fn, ok := fni.(func(core.Hash)); ok {
|
if fn, ok := fni.(func(core.Hash)); ok {
|
||||||
fn(core.Hash(block.Hash()))
|
fn(core.Hash(block.Hash()))
|
||||||
@ -116,6 +117,7 @@ func PluginNewHead(pl *plugins.PluginLoader, block *types.Block, hash common.Has
|
|||||||
_, ok := item.(func([]byte, core.Hash, [][]byte, *big.Int))
|
_, ok := item.(func([]byte, core.Hash, [][]byte, *big.Int))
|
||||||
return ok
|
return ok
|
||||||
})
|
})
|
||||||
|
log.Error("inside of pluginNewHead()", "len fnList", len(fnList))
|
||||||
blockBytes, _ := rlp.EncodeToBytes(block)
|
blockBytes, _ := rlp.EncodeToBytes(block)
|
||||||
logBytes := make([][]byte, len(logs))
|
logBytes := make([][]byte, len(logs))
|
||||||
for i, l := range logs {
|
for i, l := range logs {
|
||||||
|
Loading…
Reference in New Issue
Block a user