zhangmeng
2019-08-26 0ac4c151e08a9735d085c08ca5bcd9b50944d650
nngopt.go
@@ -10,16 +10,22 @@
var (
   maxRecvSize  = 33 * 1024 * 1024
   surveyorTime = 0
   timeout      = time.Duration(25)
)
func setTimeOut(tm int) {
   timeout = time.Duration(tm)
}
func optDefault() map[string]interface{} {
   options := make(map[string]interface{})
   options[mangos.OptionMaxRecvSize] = maxRecvSize
   options[mangos.OptionWriteQLen] = 0
   options[mangos.OptionReadQLen] = 0
   options[mangos.OptionRecvDeadline] = time.Second
   options[mangos.OptionSendDeadline] = time.Second
   options[mangos.OptionRecvDeadline] = timeout * time.Millisecond
   options[mangos.OptionSendDeadline] = timeout * time.Millisecond
   // options[mangos.OptionRaw] = true
   return options