Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-03-07 06:49:37 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化mongomodule模式

Browse Source
This commit is contained in:
boyce
2021-03-12 11:17:34 +08:00
parent e8233a6840
commit 149c79703d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
sysmodule/mongomodule/mongomodule.go
View File

@@ -28,7 +28,7 @@ type MongoModule struct {
func (slf *MongoModule) Init(url string,sessionNum uint32,dialTimeout time.Duration, timeout time.Duration) error { func (slf *MongoModule) Init(url string,sessionNum uint32,dialTimeout time.Duration, timeout time.Duration) error {
var err 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 return err
} }
@@ -48,7 +48,7 @@ func dialWithTimeout(url string, sessionNum uint32, dialTimeout time.Duration, t
if err != nil { if err != nil {
return nil, err return nil, err
} }
s.SetMode(mgo.Monotonic,true) s.SetMode(mgo.Strong,true)
s.SetSyncTimeout(timeout) s.SetSyncTimeout(timeout)
s.SetSocketTimeout(timeout) s.SetSocketTimeout(timeout)