// SetReadDeadline sets the network read deadline on the underlying websocket.
7808
func (w *terminalStream) SetReadDeadline(t time.Time) error {
	return w.ws.SetReadDeadline(t)
}
590323
func (mysqld *Mysqld) SetReadOnly(on bool) error {
	query := "SET GLOBAL read_only = "
	if on {
		query += "ON"
	} else {
		query += "OFF"
	}
	return mysqld.ExecuteSuperQuery(context.TODO(), query)
}
382002
func (s *UDPSession) SetDeadline(t time.Time) error {
	s.mu.Lock()
	defer s.mu.Unlock()
	s.rd = t
	s.wd = t
	s.notifyReadEvent()
	s.notifyWriteEvent()
	return nil
}
411707
func (c *Conn) SetDeadline(t time.Time) error {
	conn, ok := c.sock.(deadlineSetter)
	if !ok {
		return notSupported("set-deadline")
	}

	return newOpError("set-deadline", conn.SetDeadline(t))
}
694521
func (p *packetConn) SetDeadline(t time.Time) error {
	return p.s.SetDeadline(t)
}
465474
func (c *Client) SetReadDeadline(t time.Time) error {
	return c.p.SetReadDeadline(t)
}
916122
func (c *Conn) SetReadDeadline(t time.Time) error {
	c.rdeadmu.Lock()
	c.rdead = t
	c.rdeadmu.Unlock()
	return nil
}
908924
func (c *throttledConn) SetReadDeadline(t time.Time) error {
	return c.originalConn.SetReadDeadline(t)
}
794577
func (s *Stream) SetReadDeadline(t time.Time) error {
	s.readDeadline.Store(t)
	return nil
}
407772
func (f *Fibre) SetReadTimeout(wait string) {
	f.rtimeout, _ = time.ParseDuration(wait)
}
1069040
func (p *packetConn) SetDeadline(t time.Time) error {
	return p.SetReadDeadline(t)
}
1210058
func (t *tcpChanConn) SetDeadline(deadline time.Time) error {
	if err := t.SetReadDeadline(deadline); err != nil {
		return err
	}
	return t.SetWriteDeadline(deadline)
}
364210
func SetReadHandler(r chi.Router, ops *ReadOperations) {
	handler := func(w http.ResponseWriter, r *http.Request) {
		id := chi.URLParam(r, "id")
		if reader, err := ops.Input.NewReader(id); err != nil {
			http.Error(w, http.StatusText(404), 404)
		} else {
			defer reader.Close()
			p := pipe.New(reader)
			if err := ops.SetPipe(p); err != nil {
				http.Error(w, http.StatusText(500), 500)
			}
			p.To(w)
			if err := p.Exec(); err != nil {
				http.Error(w, http.StatusText(500), 500)
			}
		}
	}

	r.Get("/{id}", handler)
}
1174119
func (c *Connection) EnableReadDeadline(e bool) {
	c.log("Enable Read Deadline", e)
	c.dld.rde = e
}
1330709
func (r *Response) SetDeadline(t time.Time) error {
	return r.conn.SetDeadline(t)
}
1319464
func (t *Term) SetReadTimeout(d time.Duration) error {
	return t.SetOption(ReadTimeout(d))
}
321354
func (c *DeadlineConn) setReadTimeout() {
	if c.readTimeout != 0 {
		c.SetReadDeadline(time.Now().UTC().Add(c.readTimeout))
	}
}