mirror of
https://github.com/yusing/godoxy.git
synced 2026-04-25 09:48:32 +02:00
fix(acl): complete tcp and udp wrapper interface
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
package acl
|
package acl
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
"io"
|
"io"
|
||||||
"net"
|
"net"
|
||||||
"time"
|
"time"
|
||||||
@@ -54,6 +55,21 @@ func (s *TCPListener) Accept() (net.Conn, error) {
|
|||||||
return c, nil
|
return c, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type tcpListener interface {
|
||||||
|
SetDeadline(t time.Time) error
|
||||||
|
}
|
||||||
|
|
||||||
|
var _ tcpListener = (*net.TCPListener)(nil)
|
||||||
|
|
||||||
|
func (s *TCPListener) SetDeadline(t time.Time) error {
|
||||||
|
switch lis := s.lis.(type) {
|
||||||
|
case tcpListener:
|
||||||
|
return lis.SetDeadline(t)
|
||||||
|
default:
|
||||||
|
return errors.New("not a TCPListener")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (s *TCPListener) Close() error {
|
func (s *TCPListener) Close() error {
|
||||||
return s.lis.Close()
|
return s.lis.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package acl
|
package acl
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
"net"
|
"net"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
@@ -74,6 +75,31 @@ func (s *UDPListener) SetWriteDeadline(t time.Time) error {
|
|||||||
return s.lis.SetWriteDeadline(t)
|
return s.lis.SetWriteDeadline(t)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type udpListener interface {
|
||||||
|
SetReadBuffer(bytes int) error
|
||||||
|
SetWriteBuffer(bytes int) error
|
||||||
|
}
|
||||||
|
|
||||||
|
var _ udpListener = (*net.UDPConn)(nil)
|
||||||
|
|
||||||
|
func (s *UDPListener) SetReadBuffer(bytes int) error {
|
||||||
|
switch lis := s.lis.(type) {
|
||||||
|
case udpListener:
|
||||||
|
return lis.SetReadBuffer(bytes)
|
||||||
|
default:
|
||||||
|
return errors.New("not a UDPConn")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *UDPListener) SetWriteBuffer(bytes int) error {
|
||||||
|
switch lis := s.lis.(type) {
|
||||||
|
case udpListener:
|
||||||
|
return lis.SetWriteBuffer(bytes)
|
||||||
|
default:
|
||||||
|
return errors.New("not a UDPConn")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (s *UDPListener) Close() error {
|
func (s *UDPListener) Close() error {
|
||||||
return s.lis.Close()
|
return s.lis.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user