fix send failed

plugin/consensus/ticket/ticket_test.go

@@ -21,8 +21,13 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
-// 执行： go test -cover
 func TestTicket(t *testing.T) {
+	for i := 0; i < 10; i++ {
+		testTicket(t)
+	}
+}
+
+func testTicket(t *testing.T) {
 	mock33 := testnode.New("testdata/chain33.cfg.toml", nil)
 	defer mock33.Close()
 	mock33.Listen()
@@ -61,7 +66,7 @@ func TestTicket(t *testing.T) {
 	status, err = mock33.GetAPI().GetWalletStatus()
 	assert.Nil(t, err)
 	assert.Equal(t, true, status.IsAutoMining)
-	err = mock33.WaitHeight(100)
+	err = mock33.WaitHeight(50)
 	assert.Nil(t, err)
 	//查询票是否自动close，并且购买了新的票
 	req := &types.ReqWalletTransactionList{Count: 1000}

vendor/github.com/33cn/chain33/executor/statedb.go

@@ -128,7 +128,10 @@ func (s *StateDB) get(key []byte) ([]byte, error) {
 	}
 	query := &types.StoreGet{StateHash: s.stateHash, Keys: [][]byte{key}}
 	msg := s.client.NewMessage("store", types.EventStoreGet, query)
-	s.client.Send(msg, true)
+	err := s.client.Send(msg, true)
+	if err != nil {
+		return nil, err
+	}
 	resp, err := s.client.Wait(msg)
 	if err != nil {
 		panic(err) //no happen for ever

vendor/github.com/33cn/chain33/util/testnode/testnode.go

@@ -289,14 +289,23 @@ func (mock *Chain33Mock) Close() {
 }
 
 func (mock *Chain33Mock) closeNoLock() {
+	lognode.Info("network close")
 	mock.network.Close()
+	lognode.Info("network close")
 	mock.rpc.Close()
+	lognode.Info("rpc close")
 	mock.mem.Close()
+	lognode.Info("mem close")
 	mock.exec.Close()
+	lognode.Info("exec close")
 	mock.cs.Close()
+	lognode.Info("cs close")
 	mock.wallet.Close()
+	lognode.Info("wallet close")
 	mock.chain.Close()
+	lognode.Info("chain close")
 	mock.store.Close()
+	lognode.Info("store close")
 	mock.client.Close()
 	os.RemoveAll(mock.datadir)
 }