| | |
|---|
| | | // 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 |
|---|
