@@ -152,7 +152,11 @@ func (r *Runner) runVariableAvailableCapacitySingleFlow() error {
152152 if err != nil {
153153 return fmt .Errorf ("new manager: %w" , err )
154154 }
155- defer nm .Close ()
155+ defer func () {
156+ if closeErr := nm .Close (); closeErr != nil {
157+ r .logger .Errorf ("failed to close network manager: %v" , closeErr )
158+ }
159+ }()
156160
157161 dataDir := fmt .Sprintf ("data/%v" , r .name )
158162 err = os .MkdirAll (dataDir , 0o750 )
@@ -203,6 +207,7 @@ func (r *Runner) runVariableAvailableCapacitySingleFlow() error {
203207 },
204208 }
205209 r .runNetworkSimulation (path , nm )
210+
206211 return flow .Close ()
207212}
208213
@@ -211,7 +216,11 @@ func (r *Runner) runVariableAvailableCapacityMultipleFlows() error {
211216 if err != nil {
212217 return fmt .Errorf ("new manager: %w" , err )
213218 }
214- defer nm .Close ()
219+ defer func () {
220+ if closeErr := nm .Close (); closeErr != nil {
221+ r .logger .Errorf ("failed to close network manager: %v" , closeErr )
222+ }
223+ }()
215224
216225 dataDir := fmt .Sprintf ("data/%v" , r .name )
217226 err = os .MkdirAll (dataDir , 0o750 )
@@ -224,7 +233,8 @@ func (r *Runner) runVariableAvailableCapacityMultipleFlows() error {
224233
225234 var flows []Flow
226235 for i := 0 ; i < 2 ; i ++ {
227- flow , err := NewSimpleFlow (r .loggerFactory , nm , i , r .senderMode , dataDir )
236+ var flow Flow
237+ flow , err = NewSimpleFlow (r .loggerFactory , nm , i , r .senderMode , dataDir )
228238 if err != nil {
229239 return err
230240 }
@@ -277,6 +287,7 @@ func (r *Runner) runVariableAvailableCapacityMultipleFlows() error {
277287 panic (err )
278288 }
279289 }
290+
280291 return nil
281292}
282293
0 commit comments