X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fcypherpunks.ru%2Fgovpn%2Fserver%2Fudp.go;fp=src%2Fcypherpunks.ru%2Fgovpn%2Fserver%2Fudp.go;h=32fde7d11e1f7f7dad2ec2c4a51acefa154cb89e;hb=6c58796f178492c4b06d68af774a75a6ee5a516f;hp=c5793012e63e8cdaf7eecd479d1603c083398edd;hpb=3e92558e0c0cf721dd0a32e6c80e80ab7bb4739b;p=govpn.git

diff --git a/src/cypherpunks.ru/govpn/server/udp.go b/src/cypherpunks.ru/govpn/server/udp.go
index c579301..32fde7d 100644
--- a/src/cypherpunks.ru/govpn/server/udp.go
+++ b/src/cypherpunks.ru/govpn/server/udp.go
@@ -36,10 +36,6 @@ func (c udpSender) Write(data []byte) (int, error) {
 	return c.conn.WriteToUDP(data, c.addr)
 }
 
-// TODO move to udpSender (?)
-// buffers for UDP parallel processing
-var udpBufs = make(chan []byte, 1<<8)
-
 func (s *Server) startUDP() {
 	bind, err := net.ResolveUDPAddr("udp", s.configuration.BindAddress)
 	if err != nil {
@@ -63,6 +59,8 @@ func (s *Server) startUDP() {
 	).WithFields(
 		s.configuration.LogFields(),
 	).Info("Listen")
+
+	udpBufs := make(chan []byte, 1<<8)
 	udpBufs <- make([]byte, govpn.MTUMax)
 	go func() {
 		var buf []byte