X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fcypherpunks.ru%2Fgovpn%2Fcmd%2Fgovpn-server%2Fudp.go;fp=src%2Fcypherpunks.ru%2Fgovpn%2Fcmd%2Fgovpn-server%2Fudp.go;h=0000000000000000000000000000000000000000;hb=002ab2a45e2050f697157b50a776d35685e1a20b;hp=cdcfb56996cc8492106f3f20797f315d8caa70df;hpb=bb60f10e8d825d49e635b840b5eb7512811256d9;p=govpn.git

diff --git a/src/cypherpunks.ru/govpn/cmd/govpn-server/udp.go b/src/cypherpunks.ru/govpn/cmd/govpn-server/udp.go
deleted file mode 100644
index cdcfb56..0000000
--- a/src/cypherpunks.ru/govpn/cmd/govpn-server/udp.go
+++ /dev/null
@@ -1,205 +0,0 @@
-/*
-GoVPN -- simple secure free software virtual private network daemon
-Copyright (C) 2014-2017 Sergey Matveev <stargrave@stargrave.org>
-
-This program is free software: you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This program is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this program.  If not, see <http://www.gnu.org/licenses/>.
-*/
-
-package main
-
-import (
-	"log"
-	"net"
-
-	"cypherpunks.ru/govpn"
-)
-
-type UDPSender struct {
-	conn *net.UDPConn
-	addr *net.UDPAddr
-}
-
-func (c UDPSender) Write(data []byte) (int, error) {
-	return c.conn.WriteToUDP(data, c.addr)
-}
-
-var (
-	// Buffers for UDP parallel processing
-	udpBufs = make(chan []byte, 1<<8)
-)
-
-func startUDP() {
-	bind, err := net.ResolveUDPAddr("udp", *bindAddr)
-	if err != nil {
-		log.Fatalln("Can not resolve bind address:", err)
-	}
-	conn, err := net.ListenUDP("udp", bind)
-	if err != nil {
-		log.Fatalln("Can not listen on UDP:", err)
-	}
-	govpn.BothPrintf(`[udp-listen bind="%s"]`, *bindAddr)
-
-	udpBufs <- make([]byte, govpn.MTUMax)
-	go func() {
-		var buf []byte
-		var raddr *net.UDPAddr
-		var addr string
-		var n int
-		var err error
-		var ps *PeerState
-		var hs *govpn.Handshake
-		var addrPrev string
-		var exists bool
-		var peerID *govpn.PeerID
-		var conf *govpn.PeerConf
-		for {
-			buf = <-udpBufs
-			n, raddr, err = conn.ReadFromUDP(buf)
-			if err != nil {
-				govpn.Printf(`[receive-failed bind="%s" err="%s"]`, *bindAddr, err)
-				break
-			}
-			addr = raddr.String()
-
-			peersLock.RLock()
-			ps, exists = peers[addr]
-			peersLock.RUnlock()
-			if exists {
-				go func(peer *govpn.Peer, tap *govpn.TAP, buf []byte, n int) {
-					peer.PktProcess(buf[:n], tap, true)
-					udpBufs <- buf
-				}(ps.peer, ps.tap, buf, n)
-				continue
-			}
-
-			hsLock.RLock()
-			hs, exists = handshakes[addr]
-			hsLock.RUnlock()
-			if !exists {
-				peerID = idsCache.Find(buf[:n])
-				if peerID == nil {
-					govpn.Printf(`[identity-unknown bind="%s" addr="%s"]`, *bindAddr, addr)
-					udpBufs <- buf
-					continue
-				}
-				conf = confs[*peerID]
-				if conf == nil {
-					govpn.Printf(
-						`[conf-get-failed bind="%s" peer="%s"]`,
-						*bindAddr, peerID.String(),
-					)
-					udpBufs <- buf
-					continue
-				}
-				hs := govpn.NewHandshake(
-					addr,
-					UDPSender{conn: conn, addr: raddr},
-					conf,
-				)
-				hs.Server(buf[:n])
-				udpBufs <- buf
-				hsLock.Lock()
-				handshakes[addr] = hs
-				hsLock.Unlock()
-				continue
-			}
-
-			peer := hs.Server(buf[:n])
-			if peer == nil {
-				udpBufs <- buf
-				continue
-			}
-			govpn.Printf(
-				`[handshake-completed bind="%s" addr="%s" peer="%s"]`,
-				*bindAddr, addr, peerID.String(),
-			)
-			hs.Zero()
-			hsLock.Lock()
-			delete(handshakes, addr)
-			hsLock.Unlock()
-
-			go func() {
-				udpBufs <- make([]byte, govpn.MTUMax)
-				udpBufs <- make([]byte, govpn.MTUMax)
-			}()
-			peersByIDLock.RLock()
-			addrPrev, exists = peersByID[*peer.ID]
-			peersByIDLock.RUnlock()
-			if exists {
-				peersLock.Lock()
-				peers[addrPrev].terminator <- struct{}{}
-				psNew := &PeerState{
-					peer:       peer,
-					tap:        peers[addrPrev].tap,
-					terminator: make(chan struct{}),
-				}
-				go func(peer *govpn.Peer, tap *govpn.TAP, terminator chan struct{}) {
-					govpn.PeerTapProcessor(peer, tap, terminator)
-					<-udpBufs
-					<-udpBufs
-				}(psNew.peer, psNew.tap, psNew.terminator)
-				peersByIDLock.Lock()
-				kpLock.Lock()
-				delete(peers, addrPrev)
-				delete(knownPeers, addrPrev)
-				peers[addr] = psNew
-				knownPeers[addr] = &peer
-				peersByID[*peer.ID] = addr
-				peersLock.Unlock()
-				peersByIDLock.Unlock()
-				kpLock.Unlock()
-				govpn.Printf(
-					`[rehandshake-completed bind="%s" peer="%s"]`,
-					*bindAddr, peer.ID.String(),
-				)
-			} else {
-				go func(addr string, peer *govpn.Peer) {
-					ifaceName, err := callUp(peer.ID, peer.Addr)
-					if err != nil {
-						return
-					}
-					tap, err := govpn.TAPListen(ifaceName, peer.MTU)
-					if err != nil {
-						govpn.Printf(
-							`[tap-failed bind="%s" peer="%s" err="%s"]`,
-							*bindAddr, peer.ID.String(), err,
-						)
-						return
-					}
-					psNew := &PeerState{
-						peer:       peer,
-						tap:        tap,
-						terminator: make(chan struct{}),
-					}
-					go func(peer *govpn.Peer, tap *govpn.TAP, terminator chan struct{}) {
-						govpn.PeerTapProcessor(peer, tap, terminator)
-						<-udpBufs
-						<-udpBufs
-					}(psNew.peer, psNew.tap, psNew.terminator)
-					peersLock.Lock()
-					peersByIDLock.Lock()
-					kpLock.Lock()
-					peers[addr] = psNew
-					knownPeers[addr] = &peer
-					peersByID[*peer.ID] = addr
-					peersLock.Unlock()
-					peersByIDLock.Unlock()
-					kpLock.Unlock()
-					govpn.Printf(`[peer-created bind="%s" peer="%s"]`, *bindAddr, peer.ID.String())
-				}(addr, peer)
-			}
-			udpBufs <- buf
-		}
-	}()
-}