From bf6ffa3d11933e397d2135a97dfd73c624b4f864 Mon Sep 17 00:00:00 2001 From: 554325746@qq.com <554325746@qq.com> Date: 星期三, 21 八月 2019 14:03:38 +0800 Subject: [PATCH] add default shm param --- nngopt.go | 12 +++++++++--- 1 files changed, 9 insertions(+), 3 deletions(-) diff --git a/nngopt.go b/nngopt.go index 0fda3c7..bd7aa65 100644 --- a/nngopt.go +++ b/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 -- Gitblit v1.8.0