Open yfhk opened 5 years ago
Searching 737 files for "BeginBlock"
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/client.go: 34 CommitAsync() ReqRes 35 InitChainAsync(types.RequestInitChain) ReqRes 36: BeginBlockAsync(types.RequestBeginBlock) ReqRes 37 EndBlockAsync(types.RequestEndBlock) ReqRes 38 .. 46 CommitSync() (types.ResponseCommit, error) 47 InitChainSync(types.RequestInitChain) (types.ResponseInitChain, error) 48: BeginBlockSync(types.RequestBeginBlock) (types.ResponseBeginBlock, error) 49 EndBlockSync(types.RequestEndBlock) (types.ResponseEndBlock, error) 50 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/local_client.go: 123 } 124 125: func (app localClient) BeginBlockAsync(req types.RequestBeginBlock) ReqRes { 126 app.mtx.Lock() 127: res := app.Application.BeginBlock(req) 128 app.mtx.Unlock() 129 return app.callback( 130: types.ToRequestBeginBlock(req), 131: types.ToResponseBeginBlock(res), 132 ) 133 } ... 202 } 203 204: func (app localClient) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 205 app.mtx.Lock() 206: res := app.Application.BeginBlock(req) 207 app.mtx.Unlock() 208 return &res, nil
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/socket_client.go: 259 } 260 261: func (cli socketClient) BeginBlockAsync(req types.RequestBeginBlock) ReqRes { 262: return cli.queueRequest(types.ToRequestBeginBlock(req)) 263 } 264 ... 326 } 327 328: func (cli socketClient) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 329: reqres := cli.queueRequest(types.ToRequestBeginBlock(req)) 330 cli.FlushSync() 331: return reqres.Response.GetBeginBlock(), cli.Error() 332 } 333 ... 398 case types.RequestInitChain: 399 , ok = res.Value.(types.Response_InitChain) 400: case types.RequestBeginBlock: 401: , ok = res.Value.(types.Response_BeginBlock) 402 case types.RequestEndBlock: 403 , ok = res.Value.(types.Response_EndBlock)
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/example/kvstore/persistent_kvstore.go: 100 101 // Track the block hash and header information 102: func (app *PersistentKVStoreApplication) BeginBlock(req types.RequestBeginBlock) types.ResponseBeginBlock { 103 // reset valset changes 104 app.ValUpdates = make([]types.ValidatorUpdate, 0) 105: return types.ResponseBeginBlock{} 106 } 107
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/server/socket_server.go: 195 res := s.app.InitChain(r.InitChain) 196 responses <- types.ToResponseInitChain(res) 197: case types.Request_BeginBlock: 198: res := s.app.BeginBlock(r.BeginBlock) 199: responses <- types.ToResponseBeginBlock(res) 200 case types.Request_EndBlock: 201 res := s.app.EndBlock(*r.EndBlock)
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/types/application.go: 20 // Consensus Connection 21 InitChain(RequestInitChain) ResponseInitChain // Initialize blockchain with validators and other info from TendermintCore 22: BeginBlock(RequestBeginBlock) ResponseBeginBlock // Signals the beginning of a block 23 DeliverTx(tx []byte) ResponseDeliverTx // Deliver a tx for full processing 24 EndBlock(RequestEndBlock) ResponseEndBlock // Signals the end of a block, returns changes to the validator set .. 66 } 67 68: func (BaseApplication) BeginBlock(req RequestBeginBlock) ResponseBeginBlock { 69: return ResponseBeginBlock{} 70 } 71 .. 128 } 129 130: func (app GRPCApplication) BeginBlock(ctx context.Context, req RequestBeginBlock) (ResponseBeginBlock, error) { 131: res := app.app.BeginBlock(req) 132 return &res, nil 133 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/types/messages.go: 124 } 125 126: func ToRequestBeginBlock(req RequestBeginBlock) Request { 127 return &Request{ 128: Value: &Request_BeginBlock{&req}, 129 } 130 } ... 198 } 199 200: func ToResponseBeginBlock(res ResponseBeginBlock) Response { 201 return &Response{ 202: Value: &Response_BeginBlock{&res}, 203 } 204 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/proxy/app_conn.go: 15 InitChainSync(types.RequestInitChain) (types.ResponseInitChain, error) 16 17: BeginBlockSync(types.RequestBeginBlock) (types.ResponseBeginBlock, error) 18 DeliverTxAsync(tx []byte) abcicli.ReqRes 19 EndBlockSync(types.RequestEndBlock) (types.ResponseEndBlock, error) .. 66 } 67 68: func (app appConnConsensus) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 69: return app.appConn.BeginBlockSync(req) 70 } 71
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/state/execution.go: 232 proxyAppConn.SetResponseCallback(proxyCb) 233 234: commitInfo, byzVals := getBeginBlockValidatorInfo(block, lastValSet, stateDB) 235 236 // Begin block. 237: _, err := proxyAppConn.BeginBlockSync(abci.RequestBeginBlock{ 238 Hash: block.Hash(), 239 Header: types.TM2PB.Header(&block.Header), ... 242 }) 243 if err != nil { 244: logger.Error("Error in proxyAppConn.BeginBlock", "err", err) 245 return nil, err 246 } ... 272 } 273 274: func getBeginBlockValidatorInfo(block types.Block, lastValSet types.ValidatorSet, stateDB dbm.DB) (abci.LastCommitInfo, []abci.Evidence) { 275 276 // Sanity check that commit length matches validator set size -
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/state/metrics.go: 11 12 type Metrics struct { 13: // Time between BeginBlock and EndBlock. 14 BlockProcessingTime metrics.Histogram 15 } .. 21 Subsystem: MetricsSubsystem, 22 Name: "block_processing_time", 23: Help: "Time between BeginBlock and EndBlock in ms.", 24 Buckets: stdprometheus.LinearBuckets(1, 10, 10), 25 }, []string{}),
234 matches across 15 files
Searching 737 files for "BeginBlock"
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/client.go: 34 CommitAsync() ReqRes 35 InitChainAsync(types.RequestInitChain) ReqRes 36: BeginBlockAsync(types.RequestBeginBlock) ReqRes 37 EndBlockAsync(types.RequestEndBlock) ReqRes 38
.. 46 CommitSync() (types.ResponseCommit, error) 47 InitChainSync(types.RequestInitChain) (types.ResponseInitChain, error) 48: BeginBlockSync(types.RequestBeginBlock) (types.ResponseBeginBlock, error) 49 EndBlockSync(types.RequestEndBlock) (types.ResponseEndBlock, error) 50 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/local_client.go: 123 } 124
125: func (app localClient) BeginBlockAsync(req types.RequestBeginBlock) ReqRes { 126 app.mtx.Lock() 127: res := app.Application.BeginBlock(req) 128 app.mtx.Unlock() 129 return app.callback( 130: types.ToRequestBeginBlock(req), 131: types.ToResponseBeginBlock(res), 132 ) 133 } ... 202 } 203
204: func (app localClient) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 205 app.mtx.Lock() 206: res := app.Application.BeginBlock(req) 207 app.mtx.Unlock() 208 return &res, nil
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/client/socket_client.go: 259 } 260
261: func (cli socketClient) BeginBlockAsync(req types.RequestBeginBlock) ReqRes { 262: return cli.queueRequest(types.ToRequestBeginBlock(req)) 263 } 264
... 326 } 327
328: func (cli socketClient) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 329: reqres := cli.queueRequest(types.ToRequestBeginBlock(req)) 330 cli.FlushSync() 331: return reqres.Response.GetBeginBlock(), cli.Error() 332 } 333
... 398 case types.RequestInitChain: 399 , ok = res.Value.(types.Response_InitChain) 400: case types.RequestBeginBlock: 401: , ok = res.Value.(types.Response_BeginBlock) 402 case types.RequestEndBlock: 403 , ok = res.Value.(types.Response_EndBlock)
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/example/kvstore/persistent_kvstore.go: 100
101 // Track the block hash and header information 102: func (app *PersistentKVStoreApplication) BeginBlock(req types.RequestBeginBlock) types.ResponseBeginBlock { 103 // reset valset changes 104 app.ValUpdates = make([]types.ValidatorUpdate, 0) 105: return types.ResponseBeginBlock{} 106 } 107
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/server/socket_server.go: 195 res := s.app.InitChain(r.InitChain) 196 responses <- types.ToResponseInitChain(res) 197: case types.Request_BeginBlock: 198: res := s.app.BeginBlock(r.BeginBlock) 199: responses <- types.ToResponseBeginBlock(res) 200 case types.Request_EndBlock: 201 res := s.app.EndBlock(*r.EndBlock)
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/types/application.go: 20 // Consensus Connection 21 InitChain(RequestInitChain) ResponseInitChain // Initialize blockchain with validators and other info from TendermintCore 22: BeginBlock(RequestBeginBlock) ResponseBeginBlock // Signals the beginning of a block 23 DeliverTx(tx []byte) ResponseDeliverTx // Deliver a tx for full processing 24 EndBlock(RequestEndBlock) ResponseEndBlock // Signals the end of a block, returns changes to the validator set .. 66 } 67
68: func (BaseApplication) BeginBlock(req RequestBeginBlock) ResponseBeginBlock { 69: return ResponseBeginBlock{} 70 } 71
.. 128 } 129
130: func (app GRPCApplication) BeginBlock(ctx context.Context, req RequestBeginBlock) (ResponseBeginBlock, error) { 131: res := app.app.BeginBlock(req) 132 return &res, nil 133 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/abci/types/messages.go: 124 } 125
126: func ToRequestBeginBlock(req RequestBeginBlock) Request { 127 return &Request{ 128: Value: &Request_BeginBlock{&req}, 129 } 130 } ... 198 } 199
200: func ToResponseBeginBlock(res ResponseBeginBlock) Response { 201 return &Response{ 202: Value: &Response_BeginBlock{&res}, 203 } 204 }
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/proxy/app_conn.go: 15 InitChainSync(types.RequestInitChain) (types.ResponseInitChain, error) 16
17: BeginBlockSync(types.RequestBeginBlock) (types.ResponseBeginBlock, error) 18 DeliverTxAsync(tx []byte) abcicli.ReqRes 19 EndBlockSync(types.RequestEndBlock) (types.ResponseEndBlock, error) .. 66 } 67
68: func (app appConnConsensus) BeginBlockSync(req types.RequestBeginBlock) (types.ResponseBeginBlock, error) { 69: return app.appConn.BeginBlockSync(req) 70 } 71
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/state/execution.go: 232 proxyAppConn.SetResponseCallback(proxyCb) 233
234: commitInfo, byzVals := getBeginBlockValidatorInfo(block, lastValSet, stateDB) 235
236 // Begin block. 237: _, err := proxyAppConn.BeginBlockSync(abci.RequestBeginBlock{ 238 Hash: block.Hash(), 239 Header: types.TM2PB.Header(&block.Header), ... 242 }) 243 if err != nil { 244: logger.Error("Error in proxyAppConn.BeginBlock", "err", err) 245 return nil, err 246 } ... 272 } 273
274: func getBeginBlockValidatorInfo(block types.Block, lastValSet types.ValidatorSet, stateDB dbm.DB) (abci.LastCommitInfo, []abci.Evidence) { 275
276 // Sanity check that commit length matches validator set size -
/home/jia.hu/golibs/src/github.com/tendermint/tendermint/state/metrics.go: 11
12 type Metrics struct { 13: // Time between BeginBlock and EndBlock. 14 BlockProcessingTime metrics.Histogram 15 } .. 21 Subsystem: MetricsSubsystem, 22 Name: "block_processing_time", 23: Help: "Time between BeginBlock and EndBlock in ms.", 24 Buckets: stdprometheus.LinearBuckets(1, 10, 10), 25 }, []string{}),
234 matches across 15 files