fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-28 20:21:47 +00:00
Code Issues Projects Releases Wiki Activity

[tm-bench] updated deps

Browse Source
This commit is contained in:
Anton Kaliaev
2017-07-28 18:13:39 -04:00
parent f427590622
commit 73ced040a3
3 changed files with 58 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tm-bench/transacter.go
View File

@ -11,11 +11,11 @@ import (
"sync"
"time"
"github.com/go-kit/kit/log"
"github.com/gorilla/websocket"
"github.com/pkg/errors"
rpctypes "github.com/tendermint/go-rpc/types"
"github.com/tendermint/tmlibs/log"
)
const (
@ -91,7 +91,7 @@ func (t *transacter) receiveLoop(connIndex int) {
_, _, err := c.ReadMessage()
if err != nil {
if websocket.IsUnexpectedCloseError(err, websocket.CloseNormalClosure) {
t.logger.Log("err", errors.Wrap(err, "failed to read response"))
t.logger.Error("failed to read response", "err", err)
}
return
}
@ -104,7 +104,7 @@ func (t *transacter) receiveLoop(connIndex int) {
// sendLoop generates transactions at a given rate.
func (t *transacter) sendLoop(connIndex int) {
c := t.conns[connIndex]
logger := log.With(t.logger, "addr", c.RemoteAddr())
logger := t.logger.With("addr", c.RemoteAddr())
var txNumber = 0
@ -142,12 +142,12 @@ func (t *transacter) sendLoop(connIndex int) {
timeToSend := time.Now().Sub(startTime)
time.Sleep(time.Second - timeToSend)
logger.Log("event", fmt.Sprintf("sent %d transactions", t.Rate), "took", timeToSend)
logger.Info(fmt.Sprintf("sent %d transactions", t.Rate), "took", timeToSend)
case <-pingsTicker.C:
// Right now go-rpc server closes the connection in the absence of pings
c.SetWriteDeadline(time.Now().Add(sendTimeout))
if err := c.WriteMessage(websocket.PingMessage, []byte{}); err != nil {
logger.Log("err", errors.Wrap(err, "failed to write ping message"))
logger.Error("failed to write ping message", "err", err)
}
}
@ -157,7 +157,7 @@ func (t *transacter) sendLoop(connIndex int) {
c.SetWriteDeadline(time.Now().Add(sendTimeout))
err := c.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
if err != nil {
logger.Log("err", errors.Wrap(err, "failed to write close message"))
logger.Error("failed to write close message", "err", err)
}
return