Method WriteTo

kv/memberlist/tcp_transport.go:469–491

WriteTo is a packet-oriented interface that fires off the given payload to the given address.

(b []byte, addr string)

// WriteTo is a packet-oriented interface that fires off the given
// payload to the given address.
func (t *TCPTransport) WriteTo(b []byte, addr string) (time.Time, error) {
	t.shutdownMu.RLock()
	defer t.shutdownMu.RUnlock() // Unlock at the end to protect the chan
	if t.shutdown {
		return time.Time{}, errors.New("transport is shutting down")
	}

	// Send the packet to the write workers
	// If this blocks for too long (as configured), abort and log an error.
	select {
	case <-time.After(t.cfg.AcquireWriterTimeout):
		// Dropped packets are not an issue, the memberlist protocol will retry later.
		level.Debug(t.logger).Log("msg", "WriteTo failed to acquire a writer. Dropping message", "timeout", t.cfg.AcquireWriterTimeout, "addr", addr)
		t.droppedPackets.Inc()
		// WriteTo is used to send "UDP" packets. Since we use TCP, we can detect more errors,
		// but memberlist library doesn't seem to cope with that very well. That is why we return nil instead.
		return time.Now(), nil
	case t.writeCh <- writeRequest{b: b, addr: addr}:
		// OK
	}

	return time.Now(), nil
}

func (t *TCPTransport) writeWorker() {
	defer t.writeWG.Done()