Skip to content

Commit c30eb37

Browse files
committed
如果发不出去,就先循环尝试10次,不行就报错
1 parent 79a6f94 commit c30eb37

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed
4.33 MB
Binary file not shown.

producer/random_flow_generator_simple.go

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,18 @@ func (s *SimpleFlowGenerator) Run() {
101101
)
102102
err = s.handler.WritePacketData(buffer.Bytes())
103103
if err != nil {
104-
log.Fatal(err)
104+
for i := 0; i < 10; i++ {
105+
err = s.handler.WritePacketData(buffer.Bytes())
106+
if err != nil {
107+
log.Panicln(err)
108+
}else{
109+
break
110+
}
111+
time.Sleep(time.Millisecond * 10)
112+
}
113+
if err != nil {
114+
log.Fatal(err)
115+
}
105116
}
106117
//change flag
107118
if flowPackets == 1 {

0 commit comments

Comments
 (0)