|
|
@@ -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,7 +65,7 @@ func init() {
|
|
|
MongodbAddr: mconf["addr"].(string),
|
|
|
Size: util.IntAllDef(mconf["pool"], 5),
|
|
|
DbName: mconf["db"].(string),
|
|
|
- //ReplSet: "bidding",
|
|
|
+ ReplSet: "bidding",
|
|
|
}
|
|
|
mgo.InitPool()
|
|
|
|
|
|
@@ -101,7 +101,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 +182,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)
|
