let udp client/server session run

change_log.md

@@ -11,6 +11,10 @@
 ## develop history ##
 ---
 
+- 2018/03/08
+    > feature
+    * 1 add udp client and udp server
+
 - 2017/05/02
     > feature
     * 1 set read/write deadline for every read/write action refers to fasthttp

conn.go

@@ -10,7 +10,6 @@
 package getty
 
 import (
-	// "errors"
 	"compress/flate"
 	"crypto/tls"
 	"fmt"
@@ -581,6 +580,7 @@ func (u *gettyUDPConn) read(p []byte) (int, *net.UDPAddr, error) {
 		length, addr, err = u.conn.ReadFromUDP(p)
 	} else {
 		length, err = u.conn.Read(p)
+		addr = u.peerAddr
 	}
 	if err == nil {
 		atomic.AddUint32(&u.readCount, uint32(length))

server.go

@@ -182,6 +182,10 @@ func (s *Server) listenUDP() error {
 	if err != nil {
 		return errors.Wrapf(err, "net.ListenUDP((udp, localAddr:%#v)", localAddr)
 	}
+	if err = setUDPSocketOptions(udpConn); err != nil {
+		return errors.Wrapf(err, "setUDPSocketOptions(udpConn:%#v)", udpConn)
+	}
+
 	s.udpConn = udpConn
 
 	return nil
@@ -268,6 +272,7 @@ func (s *Server) runUDPEventloop(newSession NewSessionCallback) {
 	if err := newSession(ss); err != nil {
 		panic(err.Error())
 	}
+	ss.(*session).run()
 }
 
 type wsHandler struct {