testing udporigin/test_udp

This reverts commit 69694a17be1ef8817d9afb3a1265e605298e7ab3.

1 files changed, 2 insertions, 9 deletions

diff --git a/weed/command/volume.go b/weed/command/volume.go
index ab3c63a9a..eb89027ab 100644
--- a/weed/command/volume.go
+++ b/weed/command/volume.go
@@ -3,7 +3,7 @@ package command
 import (
 	"fmt"
 	"github.com/chrislusf/seaweedfs/weed/storage/types"
-	"github.com/chrislusf/seaweedfs/weed/udptransfer"
+	"github.com/chrislusf/seaweedfs/weed/wdclient/penet"
 	"net"
 	"net/http"
 	httppprof "net/http/pprof"
@@ -401,13 +401,7 @@ func (v VolumeServerOptions) startTcpService(volumeServer *weed_server.VolumeSer
 func (v VolumeServerOptions) startUdpService(volumeServer *weed_server.VolumeServer) {
 	listeningAddress := *v.bindIp + ":" + strconv.Itoa(*v.port+20001)
 
-	listener, err := udptransfer.NewEndpoint(&udptransfer.Params{
-		LocalAddr:      listeningAddress,
-		Bandwidth:      100,
-		FastRetransmit: true,
-		FlatTraffic:    true,
-		IsServ:         true,
-	})
+	listener, err := penet.Listen("", listeningAddress)
 	if err != nil {
 		glog.Fatalf("Volume server listen on %s:%v", listeningAddress, err)
 	}
@@ -416,7 +410,6 @@ func (v VolumeServerOptions) startUdpService(volumeServer *weed_server.VolumeSer
 	for {
 		conn, err := listener.Accept()
 		if err == nil {
-			glog.V(0).Infof("Client from %s", conn.RemoteAddr())
 			go volumeServer.HandleUdpConnection(conn)
 		} else if isTemporaryError(err) {
 			continue