|
|
@@ -46,8 +46,8 @@ var (
|
|
|
|
|
|
func init() {
|
|
|
util.ReadConfig(&Sysconfig)
|
|
|
- inits()
|
|
|
- go checkMapJob()
|
|
|
+ //inits()
|
|
|
+ //go checkMapJob()
|
|
|
detailLength = util.IntAllDef(Sysconfig["detaillength"], 50000)
|
|
|
fileLength = util.IntAllDef(Sysconfig["filelength"], 50000)
|
|
|
updport, _ = Sysconfig["updport"].(string)
|
|
|
@@ -65,10 +65,9 @@ func init() {
|
|
|
MongodbAddr: mconf["addr"].(string),
|
|
|
Size: util.IntAllDef(mconf["pool"], 5),
|
|
|
DbName: mconf["db"].(string),
|
|
|
- ReplSet: "bidding",
|
|
|
+ //ReplSet: "bidding",
|
|
|
}
|
|
|
mgo.InitPool()
|
|
|
-
|
|
|
project2db = &mongodb.MongodbSim{
|
|
|
MongodbAddr: project2["addr"].(string),
|
|
|
Size: util.IntAllDef(project2["pool"], 5),
|
|
|
@@ -101,7 +100,7 @@ func init() {
|
|
|
}
|
|
|
mgostandard = &mongodb.MongodbSim{
|
|
|
MongodbAddr: standard["addr"].(string),
|
|
|
- ReplSet: "bidding",
|
|
|
+ //ReplSet: "bidding",
|
|
|
Size: util.IntAllDef(standard["pool"], 5),
|
|
|
DbName: standard["db"].(string),
|
|
|
}
|
|
|
@@ -182,7 +181,7 @@ func init() {
|
|
|
}
|
|
|
|
|
|
func main() {
|
|
|
- go task_index()
|
|
|
+ //go task_index()
|
|
|
updport := Sysconfig["udpport"].(string)
|
|
|
udpclient = mu.UdpClient{Local: updport, BufSize: 1024}
|
|
|
udpclient.Listen(processUdpMsg)
|
