From 149c79703d742cd8418de5d368dcfa5062b0642e Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 12 Mar 2021 11:17:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96mongomodule=E6=A8=A1=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysmodule/mongomodule/mongomodule.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sysmodule/mongomodule/mongomodule.go b/sysmodule/mongomodule/mongomodule.go index 44d9b8f..ebbb025 100644 --- a/sysmodule/mongomodule/mongomodule.go +++ b/sysmodule/mongomodule/mongomodule.go @@ -28,7 +28,7 @@ type MongoModule struct { func (slf *MongoModule) Init(url string,sessionNum uint32,dialTimeout time.Duration, timeout time.Duration) error { var err error - slf.dailContext, err = dialWithTimeout(url, sessionNum, dialTimeout*time.Second, timeout*time.Minute) + slf.dailContext, err = dialWithTimeout(url, sessionNum, dialTimeout*time.Second, timeout*time.Second) return err } @@ -48,7 +48,7 @@ func dialWithTimeout(url string, sessionNum uint32, dialTimeout time.Duration, t if err != nil { return nil, err } - s.SetMode(mgo.Monotonic,true) + s.SetMode(mgo.Strong,true) s.SetSyncTimeout(timeout) s.SetSocketTimeout(timeout)