Method SendBuffers

polyamide/device/peer.go:121–178

(buffers [][]byte, eps []conn.Endpoint)

}

func (peer *Peer) SendBuffers(buffers [][]byte, eps []conn.Endpoint) error {
	peer.device.net.RLock()
	defer peer.device.net.RUnlock()

	if peer.device.isClosed() {
		return nil
	}

	peer.endpoints.Lock()
	endpoints := peer.endpoints.val
	if len(endpoints) == 0 {
		peer.endpoints.Unlock()
		return errors.New("no known endpoints for peer")
	}
	if peer.endpoints.clearSrcOnTx {
		for _, ep := range endpoints {
			ep.ClearSrc()
		}
		for _, ep := range eps {
			if ep != nil {
				ep.ClearSrc()
			}
		}
		peer.endpoints.clearSrcOnTx = false
	}
	peer.endpoints.Unlock()

	// optimization, if multiple contiguous buffers share the same endpoint, send them in a single batch
	prevIdx := 0
	prevEp := eps[0]

	var anyError error
	for i := 0; i <= len(buffers); i++ {
		if i == len(buffers) || eps[i] != prevEp {
			// send batch from prevIdx to i-1
			if prevEp == nil {
				prevEp = endpoints[0] // default endpoint
			}
			err := peer.device.net.bind.Send(buffers[prevIdx:i], prevEp)
			if err != nil {
				anyError = err
			}
			prevIdx = i
			if i < len(buffers) {
				prevEp = eps[i]
			}
		}
	}

	var totalLen uint64
	for _, b := range buffers {
		totalLen += uint64(len(b))
	}
	perf.SentPacketPerSecond.Add(float64(len(buffers)))
	perf.SentBytesPerSecond.Add(float64(totalLen))
	peer.txBytes.Add(totalLen)
	return anyError
}