search result for BeginBlock in tendermint

[yfhk]

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.Request_InitChain:
399 _, ok = res.Value.(*types.Response_InitChain)
400: case *types.Request_BeginBlock:
401: _, ok = res.Value.(*types.Response_BeginBlock)
402 case *types.Request_EndBlock:
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