Commit af308d28 authored by duanjinfei's avatar duanjinfei

change log print

parent ce0be510
......@@ -19,7 +19,6 @@ var (
batchRecoverRequest chan *crypterv1.BatchRecoverRequest
batchRecoverTxRequest chan *crypterv1.BatchRecoverTxRequest
batchVerifyRequest chan *crypterv1.BatchVerifyRequest
clientMap map[int]crypterv1.CrypterServiceClient
bathHandleSendCount, allSignedTxCount, totalSendTime int64
)
......@@ -28,7 +27,6 @@ func init() {
batchRecoverRequest = make(chan *crypterv1.BatchRecoverRequest, 1000000)
batchRecoverTxRequest = make(chan *crypterv1.BatchRecoverTxRequest, 1000000)
batchVerifyRequest = make(chan *crypterv1.BatchVerifyRequest, 1000000)
clientMap = make(map[int]crypterv1.CrypterServiceClient)
}
// batchSign 发送的签名交易
......@@ -227,13 +225,10 @@ func batchRecoverTx(client crypterv1.CrypterServiceClient, sleepTime int) {
atomic.AddInt64(&bathHandleSendCount, 1)
sinceTime := time.Since(sendTranStartTime).Milliseconds()
atomic.AddInt64(&totalSendTime, sinceTime)
for i, tx := range sign.GetRecoverdTx() {
rawTx := batchRecoverTx.RawTx
if tx.From.Hex() != rawTx[i].From.Hex() {
log.Error(" tx.From.Hex():", tx.From.Hex(), "rawTx[i].From.Hex():", rawTx[i].From.Hex())
for _, tx := range sign.GetRecoverdTx() {
log.Info(" tx_From :", tx.From.Hex())
}
}
log.Infof("Send transaction time: %d ms, sign: %s ", sinceTime)
log.Infof("Send transaction time: %d ms", sinceTime)
}
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment