Fix for Bug #40

by adding ClientPerConn in loop

Fixes guoger/stupid/#40

Signed-off-by: SamYuan1990 <yy19902439@126.com>

pkg/infra/proposer.go

@@ -38,8 +38,11 @@ func CreateProposers(conn, client int, nodes []Node, logger *log.Logger) *Propos
 func (ps *Proposers) Start(signed []chan *Elements, processed chan *Elements, done <-chan struct{}, config Config) {
 	ps.logger.Infof("Start sending transactions.")
 	for i := 0; i < len(config.Endorsers); i++ {
-		for j := 0; j < config.NumOfConn; j++ {
-			go ps.workers[i][j].Start(signed[i], processed, done, len(config.Endorsers))
+		// peer connection should be config.ClientPerConn * config.NumOfConn
+		for k := 0; k < config.ClientPerConn; k++ {
+			for j := 0; j < config.NumOfConn; j++ {
+				go ps.workers[i][j].Start(signed[i], processed, done, len(config.Endorsers))
+			}
 		}
 	}
 }