// ZMQ_RECOVERY_IVL_MSEC: Set multicast recovery interval in milliseconds
//
// Note: value is of type time.Duration
//
// See: http://api.zeromq.org/2-2:zmq-setsockopt#toc13
764675
func (soc *Socket) SetRecoveryIvlMsec(value time.Duration) error {
	val := int64(value / time.Millisecond)
	if value < 0 {
		val = -1
	}
	return soc.setInt64(C.ZMQ_RECOVERY_IVL_MSEC, val)
}
213288
func ZmqReply(_socket *zmq.Socket, _compute_reply RecieveArrayReturnString) error {
	_msg, err := _socket.Recv(0)
	if err != nil {
		return err
	}

	_msg_array := strings.Fields(string(_msg))
	return_value := _compute_reply(_msg_array)

	err = _socket.Send([]byte(return_value), 0)
	return err
}
782908
func (soc *Socket) SetConnectTimeout(value time.Duration) error {
	if minor < 2 {
		return ErrorNotImplemented42
	}
	val := int(value / time.Millisecond)
	return soc.setInt(C.ZMQ_CONNECT_TIMEOUT, val)
}
314497
func (s *Mpeg2Settings) SetMinIInterval(v int64) *Mpeg2Settings {
	s.MinIInterval = &v
	return s
}
1282957
func (d *ServoBlaster) setMicroseconds(channel, us int) error {
	if err := d.setup(); err != nil {
		return err
	}
	cmd := fmt.Sprintf("%v=%vus\n", channel, us)
	glog.V(1).Infof("servoblaster: sending command %q", cmd)
	_, err := d.fd.WriteString(cmd)
	return err
}
406032
func (tsv *TabletServer) SetQueryPoolTimeout(val time.Duration) {
	tsv.qe.connTimeout.Set(val)
}
1134881
func (soc *Socket) GetRcvtimeo() (time.Duration, error) {
	major, minor, _ := Version()
	if major == 2 && minor < 2 {
		return 0, ErrorNotImplemented
	}
	v, err := soc.getInt(C.ZMQ_RCVTIMEO)
	if v < 0 {
		return time.Duration(-1), err
	}
	return time.Duration(v) * time.Millisecond, err
}
25527
func ZmqRequestByte(_socket *zmq.Socket, _msg []byte) ([]byte, error) {
	_socket.Send(_msg, 0)
	return _socket.Recv(0)
}
940271
func (c *Client) SetRetryInterval(retryInterval time.Duration) {
	if c.timeout > 0 && retryInterval >= c.timeout {
		retryInterval = c.timeout / 2
	}
	c.Lock()
	c.retryInterval = retryInterval
	c.Unlock()
}
788852
func (c *Cluster) SetConnMaxLifetime(d time.Duration) {
	for _, db := range c.dbs {
		db.SetConnMaxLifetime(d)
	}
}
527825
func MilliSleep(tm int) {
	time.Sleep(time.Duration(tm) * time.Millisecond)
}
1000056
func (s *CreateIntegrationInput) SetTimeoutInMillis(v int64) *CreateIntegrationInput {
	s.TimeoutInMillis = &v
	return s
}
1274609
func (soc *Socket) SetHandshakeIvl(value time.Duration) error {
	if minor < 1 {
		return ErrorNotImplemented41
	}
	val := int(value / time.Millisecond)
	return soc.setInt(C.ZMQ_HANDSHAKE_IVL, val)
}
188182
func (s *CancelResizeOutput) SetElapsedTimeInSeconds(v int64) *CancelResizeOutput {
	s.ElapsedTimeInSeconds = &v
	return s
}
859023
func (s *UpdateGroupCertificateConfigurationOutput) SetCertificateExpiryInMilliseconds(v string) *UpdateGroupCertificateConfigurationOutput {
	s.CertificateExpiryInMilliseconds = &v
	return s
}
954513
func (s *CrawlerMetrics) SetLastRuntimeSeconds(v float64) *CrawlerMetrics {
	s.LastRuntimeSeconds = &v
	return s
}
369455
func (soc *Socket) SetRate(value int64) error {
	return soc.setInt64(C.ZMQ_RATE, value)
}