|
|
@@ -1,6 +1,4 @@
|
|
|
-/*
|
|
|
-遇到mod的问题，先ctrl+s保存一下，然后直接go run main.go 如果不行的话，再使用go mod init，之后再go run main.go
|
|
|
-*/
|
|
|
+
|
|
|
package main
|
|
|
|
|
|
import (
|
|
|
@@ -170,7 +168,7 @@ func db2_Msg_Set_Goroutine() {
|
|
|
//get all messages in wach hour
|
|
|
func test2(finalTime string, lastTimesIndex int) (finalIndex int) {
|
|
|
fmt.Println("text2() starts")
|
|
|
- //goroutine六个channel的初始化
|
|
|
+ //6 goroutines init
|
|
|
db1_key_channel = make(chan string, channelSize)
|
|
|
db1_val_channel = make(chan string, channelSize)
|
|
|
db2_time_key_channel = make(chan string, channelSize)
|
|
|
@@ -415,7 +413,7 @@ func sendOut_real(list <-chan string, c net.Conn, cover *megred) {
|
|
|
pd := make([]byte, padding_length)
|
|
|
jsons = append(jsons, pd...)
|
|
|
if len(jsons) != packetLength {
|
|
|
- fmt.Println("err出错了，长度不对，rst=", rst)
|
|
|
+ fmt.Println("err，rst=", rst)
|
|
|
}
|
|
|
c.Write(jsons)
|
|
|
real_lock.Lock()
|
