@@ -80,7 +80,6 @@ type operation struct {
80
80
buf syscall.WSABuf
81
81
msg windows.WSAMsg
82
82
rsa * syscall.RawSockaddrAny
83
- rsan int32
84
83
bufs []syscall.WSABuf
85
84
}
86
85
@@ -668,9 +667,9 @@ func (fd *FD) ReadFrom(buf []byte) (int, syscall.Sockaddr, error) {
668
667
if o .rsa == nil {
669
668
o .rsa = new (syscall.RawSockaddrAny )
670
669
}
671
- o . rsan = int32 (unsafe .Sizeof (* o .rsa ))
670
+ rsan : = int32 (unsafe .Sizeof (* o .rsa ))
672
671
var flags uint32
673
- err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & o . rsan , & o .o , nil )
672
+ err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & rsan , & o .o , nil )
674
673
return qty , err
675
674
})
676
675
err = fd .eofError (n , err )
@@ -699,9 +698,9 @@ func (fd *FD) ReadFromInet4(buf []byte, sa4 *syscall.SockaddrInet4) (int, error)
699
698
if o .rsa == nil {
700
699
o .rsa = new (syscall.RawSockaddrAny )
701
700
}
702
- o . rsan = int32 (unsafe .Sizeof (* o .rsa ))
701
+ rsan : = int32 (unsafe .Sizeof (* o .rsa ))
703
702
var flags uint32
704
- err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & o . rsan , & o .o , nil )
703
+ err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & rsan , & o .o , nil )
705
704
return qty , err
706
705
})
707
706
err = fd .eofError (n , err )
@@ -730,9 +729,9 @@ func (fd *FD) ReadFromInet6(buf []byte, sa6 *syscall.SockaddrInet6) (int, error)
730
729
if o .rsa == nil {
731
730
o .rsa = new (syscall.RawSockaddrAny )
732
731
}
733
- o . rsan = int32 (unsafe .Sizeof (* o .rsa ))
732
+ rsan : = int32 (unsafe .Sizeof (* o .rsa ))
734
733
var flags uint32
735
- err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & o . rsan , & o .o , nil )
734
+ err = syscall .WSARecvFrom (fd .Sysfd , & o .buf , 1 , & qty , & flags , o .rsa , & rsan , & o .o , nil )
736
735
return qty , err
737
736
})
738
737
err = fd .eofError (n , err )
@@ -1040,10 +1039,11 @@ func (fd *FD) ConnectEx(ra syscall.Sockaddr) error {
1040
1039
1041
1040
func (fd * FD ) acceptOne (s syscall.Handle , rawsa []syscall.RawSockaddrAny , o * operation ) (string , error ) {
1042
1041
// Submit accept request.
1043
- o . rsan = int32 (unsafe .Sizeof (rawsa [0 ]))
1042
+ rsan := uint32 (unsafe .Sizeof (rawsa [0 ]))
1044
1043
_ , err := fd .execIO (o , func (o * operation ) (qty uint32 , err error ) {
1045
- err = AcceptFunc (fd .Sysfd , s , (* byte )(unsafe .Pointer (& rawsa [0 ])), 0 , uint32 ( o . rsan ), uint32 ( o . rsan ) , & qty , & o .o )
1044
+ err = AcceptFunc (fd .Sysfd , s , (* byte )(unsafe .Pointer (& rawsa [0 ])), 0 , rsan , rsan , & qty , & o .o )
1046
1045
return qty , err
1046
+
1047
1047
})
1048
1048
if err != nil {
1049
1049
CloseFunc (s )
@@ -1078,7 +1078,7 @@ func (fd *FD) Accept(sysSocket func() (syscall.Handle, error)) (syscall.Handle,
1078
1078
1079
1079
errcall , err := fd .acceptOne (s , rawsa [:], o )
1080
1080
if err == nil {
1081
- return s , rawsa [:], uint32 (o . rsan ), "" , nil
1081
+ return s , rawsa [:], uint32 (unsafe . Sizeof ( rawsa [ 0 ]) ), "" , nil
1082
1082
}
1083
1083
1084
1084
// Sometimes we see WSAECONNRESET and ERROR_NETNAME_DELETED is
0 commit comments