// SetLockTimeout has property such that if the lock is held past this duration,
// then a configured fatal callback is called.
321996
func (b *BaseKvdb) SetLockTimeout(timeout time.Duration) {
	b.lock.Lock()
	defer b.lock.Unlock()
	logrus.Infof("Setting lock timeout to: %v", timeout)
	b.LockTimeout = timeout
}
258490
func (cs *ConsensusState) SetTimeoutTicker(timeoutTicker TimeoutTicker) {
	cs.mtx.Lock()
	cs.timeoutTicker = timeoutTicker
	cs.mtx.Unlock()
}
1252380
func (s *RedshiftSettings) SetLoadTimeout(v int64) *RedshiftSettings {
	s.LoadTimeout = &v
	return s
}
906036
func (p *TSocket) SetTimeout(timeout time.Duration) error {
	p.timeout = timeout
	return nil
}
1256941
func (s *FunctionConfiguration) SetTimeout(v int64) *FunctionConfiguration {
	s.Timeout = &v
	return s
}
139662
func (p *Plugin) SetTimeout(t time.Duration) {
	p.mu.Lock()
	p.timeout = t
	p.mu.Unlock()
}
584518
func (c *Config) SetTimeout(t time.Duration) error {
	if c == nil {
		return fmt.Errorf("nil config")
	} else if c.httpClient == nil {
		return fmt.Errorf("nil HTTP client")
	} else if c.httpClient.Transport == nil {
		return fmt.Errorf("nil HTTP client transport")
	}

	// Apply a timeout.
	if t.Nanoseconds() >= 0 {
		transport, ok := c.httpClient.Transport.(*http.Transport)
		if !ok {
			return fmt.Errorf("unexpected HTTP transport: %T", c.httpClient.Transport)
		}

		transport.DialContext = (&net.Dialer{
			Timeout:   t,
			KeepAlive: 30 * time.Second,
		}).DialContext
	}

	return nil
}
744578
func (c *FCGIClient) SetSendTimeout(t time.Duration) error {
	if conn, ok := c.rwc.(net.Conn); ok && t != 0 {
		return conn.SetWriteDeadline(time.Now().Add(t))
	}
	return nil
}
567601
func (f *Fibre) SetWriteTimeout(wait string) {
	f.wtimeout, _ = time.ParseDuration(wait)
}
1073155
func (r *request) SetTimeout(timeout time.Duration) error {
	r.timeout = timeout
	return nil
}
914504
func (s *Socket) SetSendTimeout(d time.Duration) error {
	s.sto = d
	return nil
}
373937
func (s *JobRun) SetTimeout(v int64) *JobRun {
	s.Timeout = &v
	return s
}
81762
func (s *ChangeMessageVisibilityBatchRequestEntry) SetVisibilityTimeout(v int64) *ChangeMessageVisibilityBatchRequestEntry {
	s.VisibilityTimeout = &v
	return s
}
137223
func (s *ShutdownEventConfiguration) SetExecutionTimeout(v int64) *ShutdownEventConfiguration {
	s.ExecutionTimeout = &v
	return s
}
697430
func (s *CreateJobInput) SetTimeout(v int64) *CreateJobInput {
	s.Timeout = &v
	return s
}
270253
func (r *Request) SetTimeout(connectTimeout, readWriteTimeout time.Duration) *Request {
	r.setting.ConnectTimeout = connectTimeout
	r.setting.ReadWriteTimeout = readWriteTimeout
	return r
}
1303000
func (s *ActivityTaskTimedOutEventAttributes) SetTimeoutType(v string) *ActivityTaskTimedOutEventAttributes {
	s.TimeoutType = &v
	return s
}