// SetWriteDeadline implements net.Conn.SetWriteDeadline and
// net.PacketConn.SetWriteDeadline.
199472
func (d *deadlineTimer) SetWriteDeadline(t time.Time) error {
	d.mu.Lock()
	d.setDeadline(&d.writeCancelCh, &d.writeTimer, t)
	d.mu.Unlock()
	return nil
}
538247
func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetWriteDeadline", reflect.TypeOf((*MockStream)(nil).SetWriteDeadline), arg0)
}
104676
func (c *Connection) ReadDeadline(d time.Duration) {
	c.log("Read Deadline", d)
	c.dld.rdld = d
	c.dld.rds = true
}
1325720
func (c *I2PConn) SetWriteDeadline(t time.Time) error {
	return c.c.SetWriteDeadline(t)
}
605846
func (p *MockPeer) SetWriteDeadline(t time.Time) error {
	if t.IsZero() {
		p.writeDeadline = nil
		return nil
	}

	duration := time.Until(t)
	p.writeDeadline = time.After(duration)

	return nil
}
148499
func (s *DatagramSession) SetReadDeadline(t time.Time) error {
	return s.udpconn.SetReadDeadline(t)
}
561113
func (c *Ctx) WithDeadline(deadline time.Time) context.CancelFunc {
	ctx, cf := context.WithDeadline(c.request.Context(), deadline)
	c.request = c.request.WithContext(ctx)
	return cf
}
357547
func (s *CreateFunctionInput) SetDeadLetterConfig(v *DeadLetterConfig) *CreateFunctionInput {
	s.DeadLetterConfig = v
	return s
}
929079
func (c Conn) CloseWrite() error {
	if cw, ok := c.Wire.(interface {
		CloseWrite() error
	}); ok {
		return cw.CloseWrite()
	}
	return errors.New("pinned: underlying connection does not support CloseWrite")
}
1221813
func (c *conn) SetWriteDeadline(t time.Time) error {
	return c.rwc.SetWriteDeadline(t)
}
1043349
func (con *Connection) SetWriteDeadline(t time.Time) error {
	return con.connection.SetWriteDeadline(t)
}
998040
func (s *SurveyorSocket) SetDeadline(d time.Duration) error {
	return s.sock.SetOption(mangos.OptionSurveyTime, d)
}
699361
func (conn *WebsocketConnection) SetReadDeadline(t time.Time) error {
	return conn.ws.SetReadDeadline(t)
}
1069040
func (p *packetConn) SetDeadline(t time.Time) error {
	return p.SetReadDeadline(t)
}
1085384
func (m *Machine) SetProviderAddresses(addresses ...network.Address) error {
	err := m.setAddresses(nil, &addresses)
	return errors.Annotatef(err, "cannot set addresses of machine %v", m)
}
842770
func (l *Listener) SetWriteBuffer(bytes int) error {
	if nc, ok := l.conn.(setWriteBuffer); ok {
		return nc.SetWriteBuffer(bytes)
	}
	return errors.New(errInvalidOperation)
}
36677
func (l *Listener) SetDeadline(t time.Time) error {
	l.SetReadDeadline(t)
	l.SetWriteDeadline(t)
	return nil
}