From 59f9316f51ce3cb470200b0cfe847116a0583d25 Mon Sep 17 00:00:00 2001 From: Mathias Hall-Andersen Date: Thu, 6 Jul 2017 15:43:55 +0200 Subject: Initial working full exchange The implementation is now capable of connecting to another wireguard instance, complete a handshake and exchange transport messages. --- src/peer.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/peer.go') diff --git a/src/peer.go b/src/peer.go index 1c40598..77bd4df 100644 --- a/src/peer.go +++ b/src/peer.go @@ -35,7 +35,7 @@ type Peer struct { handshakeTimeout *time.Timer } queue struct { - nonce chan []byte // nonce / pre-handshake queue + nonce chan *QueueOutboundElement // nonce / pre-handshake queue outbound chan *QueueOutboundElement // sequential ordering of work inbound chan *QueueInboundElement // sequential ordering of work } @@ -78,9 +78,9 @@ func (device *Device) NewPeer(pk NoisePublicKey) *Peer { // prepare queuing - peer.queue.nonce = make(chan []byte, QueueOutboundSize) - peer.queue.inbound = make(chan *QueueInboundElement, QueueInboundSize) + peer.queue.nonce = make(chan *QueueOutboundElement, QueueOutboundSize) peer.queue.outbound = make(chan *QueueOutboundElement, QueueOutboundSize) + peer.queue.inbound = make(chan *QueueInboundElement, QueueInboundSize) // prepare signaling -- cgit v1.2.3