File tree 1 file changed +6
-2
lines changed
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -904,13 +904,15 @@ func SetReceiver(portId uint16) (OUT *Flow, err error) {
904
904
// Creates RAW socket, returns new opened flow with received packets.
905
905
func SetReceiverOS (device string ) (* Flow , error ) {
906
906
v , ok := ioDevices [device ]
907
- socketID := v .( int )
907
+ var socketID int
908
908
if ! ok {
909
909
socketID = low .InitDevice (device )
910
910
if socketID == - 1 {
911
911
return nil , common .WrapWithNFError (nil , "Can't initialize socket" , common .BadSocket )
912
912
}
913
913
ioDevices [device ] = socketID
914
+ } else {
915
+ socketID = v .(int )
914
916
}
915
917
rings := low .CreateRings (burstSize * sizeMultiplier , 1 )
916
918
addOSReceiver (socketID , rings )
@@ -925,13 +927,15 @@ func SetSenderOS(IN *Flow, device string) error {
925
927
return err
926
928
}
927
929
v , ok := ioDevices [device ]
928
- socketID := v .( int )
930
+ var socketID int
929
931
if ! ok {
930
932
socketID = low .InitDevice (device )
931
933
if socketID == - 1 {
932
934
return common .WrapWithNFError (nil , "Can't initialize socket" , common .BadSocket )
933
935
}
934
936
ioDevices [device ] = socketID
937
+ } else {
938
+ socketID = v .(int )
935
939
}
936
940
addSenderOS (socketID , finishFlow (IN ), IN .inIndexNumber )
937
941
return nil
You can’t perform that action at this time.
0 commit comments