diff options
author | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2017-11-19 13:19:07 +0100 |
---|---|---|
committer | Mathias Hall-Andersen <mathias@hall-andersen.dk> | 2017-11-19 13:19:07 +0100 |
commit | b5ae42349c4fd88022a63006060d72b03aa83b16 (patch) | |
tree | 18fecbdba6437003f574c15eddeb75bbed9980b3 /src/send.go | |
parent | 5705a5e2efdcbbaffa5da00555b1afb3b4f9d2af (diff) | |
parent | 9ebab57c417d4fd19db6cf69f920a3adb1a1e092 (diff) | |
download | wireguard-go-b5ae42349c4fd88022a63006060d72b03aa83b16.tar.gz wireguard-go-b5ae42349c4fd88022a63006060d72b03aa83b16.zip |
Merge branch 'source-caching'
Diffstat (limited to 'src/send.go')
-rw-r--r-- | src/send.go | 23 |
1 files changed, 1 insertions, 22 deletions
diff --git a/src/send.go b/src/send.go index 5c88ead..52872f6 100644 --- a/src/send.go +++ b/src/send.go @@ -2,7 +2,6 @@ package main import ( "encoding/binary" - "errors" "golang.org/x/crypto/chacha20poly1305" "golang.org/x/net/ipv4" "golang.org/x/net/ipv6" @@ -105,26 +104,6 @@ func addToEncryptionQueue( } } -func (peer *Peer) SendBuffer(buffer []byte) (int, error) { - peer.device.net.mutex.RLock() - defer peer.device.net.mutex.RUnlock() - - peer.mutex.RLock() - defer peer.mutex.RUnlock() - - endpoint := peer.endpoint - if endpoint == nil { - return 0, errors.New("No known endpoint for peer") - } - - conn := peer.device.net.conn - if conn == nil { - return 0, errors.New("No UDP socket for device") - } - - return conn.WriteToUDP(buffer, endpoint) -} - /* Reads packets from the TUN and inserts * into nonce queue for peer * @@ -343,7 +322,7 @@ func (peer *Peer) RoutineSequentialSender() { // send message and return buffer to pool length := uint64(len(elem.packet)) - _, err := peer.SendBuffer(elem.packet) + err := peer.SendBuffer(elem.packet) device.PutMessageBuffer(elem.buffer) if err != nil { logDebug.Println("Failed to send authenticated packet to peer", peer.String()) |