add timeout interface

zhangmeng

2019-07-29 dd22fdb1c82ae93446f5e1166d500331c0ad6a1d

 nngopt.go

@@ -9,17 +9,23 @@
// maxRecvSize max recv size
var (
   maxRecvSize  = 33 * 1024 * 1024
   surveyorTime = -1
   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