fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-24 10:11:48 +00:00
Code Issues Projects Releases Wiki Activity

s/InitValidators/InitChain/g, s/SyncValidators/EndBlock/g, added BeginBlock

Browse Source
This commit is contained in:
Jae Kwon
2016-03-05 19:18:34 -08:00
parent 72540f9cac
commit 36c25f242f
7 changed files with 252 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
client/client.go
View File

@ -215,12 +215,16 @@ func (cli *Client) QueryAsync(query []byte) *ReqRes {
return cli.queueRequest(types.RequestQuery(query))
}
func (cli *Client) InitValidatorsAsync(validators []*types.Validator) *ReqRes {
return cli.queueRequest(types.RequestInitValidators(validators))
func (cli *Client) InitChainAsync(validators []*types.Validator) *ReqRes {
return cli.queueRequest(types.RequestInitChain(validators))
}
func (cli *Client) SyncValidatorsAsync() *ReqRes {
return cli.queueRequest(types.RequestSyncValidators())
func (cli *Client) BeginBlockAsync(height uint64) *ReqRes {
return cli.queueRequest(types.RequestBeginBlock(height))
}
func (cli *Client) EndBlockAsync() *ReqRes {
return cli.queueRequest(types.RequestEndBlock())
}
//----------------------------------------
@ -288,8 +292,8 @@ func (cli *Client) QuerySync(query []byte) (code types.CodeType, result []byte,
return res.Code, res.Data, res.Log, nil
}
func (cli *Client) InitValidatorsSync(validators []*types.Validator) (err error) {
cli.queueRequest(types.RequestInitValidators(validators))
func (cli *Client) InitChainSync(validators []*types.Validator) (err error) {
cli.queueRequest(types.RequestInitChain(validators))
cli.FlushSync()
if cli.err != nil {
return cli.err
@ -297,8 +301,17 @@ func (cli *Client) InitValidatorsSync(validators []*types.Validator) (err error)
return nil
}
func (cli *Client) SyncValidatorsSync() (validators []*types.Validator, err error) {
reqres := cli.queueRequest(types.RequestSyncValidators())
func (cli *Client) BeginBlockSync(height uint64) (err error) {
cli.queueRequest(types.RequestBeginBlock(height))
cli.FlushSync()
if cli.err != nil {
return cli.err
}
return nil
}
func (cli *Client) EndBlockSync() (validators []*types.Validator, err error) {
reqres := cli.queueRequest(types.RequestEndBlock())
cli.FlushSync()
if cli.err != nil {
return nil, cli.err