554325746@qq.com
2019-08-21 bf6ffa3d11933e397d2135a97dfd73c624b4f864
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] = 30 * time.Millisecond
   options[mangos.OptionSendDeadline] = 30 * time.Millisecond
   options[mangos.OptionRecvDeadline] = timeout * time.Millisecond
   options[mangos.OptionSendDeadline] = timeout * time.Millisecond
   // options[mangos.OptionRaw] = true
   return options