|
@@ -161,7 +161,7 @@ func receive(c net.Conn) { //
|
|
|
//2,msg
|
|
|
msgs, err_msgs := redis.Strings(stru["Megred_Hashtags"], nil)
|
|
|
if err_msgs != nil {
|
|
|
- log.Println("err_msgs", err_msgs, "符串a", a)
|
|
|
+ log.Println("err_msgs", err_msgs, "a", a)
|
|
|
}
|
|
|
structure.Merged_Hashtags = msgs
|
|
|
//3,uid
|
|
@@ -344,10 +344,10 @@ func db12_lpush() {
|
|
|
|
|
|
//init db12,13,14
|
|
|
func initDb() {
|
|
|
- log.Println("initDb()执行完成,已经清空db13,db14")
|
|
|
+ log.Println("initDb() finished,clean up db13,db14")
|
|
|
c, c_err := redis.Dial("tcp", fmt.Sprintf("%s:%d", "127.0.0.1", 6379))
|
|
|
if c_err != nil {
|
|
|
- log.Println("连接数据库出错,c_err=", c_err)
|
|
|
+ log.Println("c_err=", c_err)
|
|
|
}
|
|
|
c.Do("select", 14)
|
|
|
c.Do("Flushdb")
|
|
@@ -520,7 +520,7 @@ var lastLearningPhase_end_flag bool
|
|
|
|
|
|
/*
|
|
|
1,users in batch_list,set their status to 1,means they enter the learning phase
|
|
|
- 2,clean db14中,send arrival message to recipients
|
|
|
+ 2,clean db14,send arrival message to recipients
|
|
|
3,tell clients,which users have changed their status
|
|
|
4,clean up batch-list
|
|
|
5,
|