gsadmin/ziti
1
0
Fork 0
mirror of https://github.com/openziti/ziti.git synced 2026-10-12 23:32:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implemented 'transwarp.Connection.ReadPeer'. (#44)

Browse Source
This commit is contained in:
Michael Quigley
2020-03-17 15:42:06 -04:00
parent 14bcf252e8
commit f9239dcf8d
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
transwarp/connection.go
+11 -2
View File
@@ -36,6 +36,15 @@ func (self *connection) Reader() io.Reader {
return self.socket
}
func (self *connection) ReadPeer(p []byte) (int, transport.Address, error) {
n, peer, err := self.socket.ReadFromUDP(p)
var addr transport.Address
if peer != nil {
addr = &address{hostname: peer.IP.String(), port: uint16(peer.Port)}
}
return n, addr, err
}
func (self *connection) Writer() io.Writer {
return self.socket
}
@@ -56,7 +65,7 @@ func (self *connection) Close() error {
return self.socket.Close()
}
func newConnection(detail *transport.ConnectionDetail, socket net.Conn) *connection {
func newConnection(detail *transport.ConnectionDetail, socket *net.UDPConn) *connection {
return &connection{
detail: detail,
socket: socket,
@@ -66,7 +75,7 @@ func newConnection(detail *transport.ConnectionDetail, socket net.Conn) *connect
type connection struct {
detail *transport.ConnectionDetail
socket net.Conn
socket *net.UDPConn
buffer []byte
copy []byte
}