}
}

func (c *DeadlineConn) setWriteDeadline() {
	// Do not set a Write deadline, if upstream wants to cancel all reads.
	if c.writeDeadline <= 0 || c.abortWrites.Load() || c.infWrites.Load() {
		return
	}

	c.mu.Lock()
	defer c.mu.Unlock()
	if c.abortWrites.Load() {
		return
	}
	now := time.Now()
	if now.Sub(c.writeSetAt) > updateInterval {
		c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))

		now := time.Now()
		// Only set write deadline once every second
		if now.Sub(lastSetDeadline) > time.Second {
			err := conn.SetWriteDeadline(now.Add(connWriteTimeout + time.Second))
			if err != nil {
				gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err))
				return false
			}
			lastSetDeadline = now
		}

		_, err := buf.WriteTo(conn)
		if err != nil {