淇敼锛歵opic & message chan overload check

git-svn-id: svn://47.119.165.148/zhub@129 e63fbceb-bcc3-4977-ac22-735b83d8d0f4

zsub/zsub.go

@@ -2,6 +2,7 @@ package zsub
 
 import (
 	"bufio"
+	"fmt"
 	"log"
 	"net"
 	"os"
@@ -369,8 +370,15 @@ func (s *ZSub) Publish(topic, msg string) {
 	if ztopic == nil {
 		return
 	}
-	ztopic.chMsg <- msg
 	ztopic.mcount++
+
+	// topic chan overload check
+	if len(ztopic.chMsg) == cap(ztopic.chMsg) {
+		log.Println(fmt.Sprintf("ztopic no cap: [%s %s]", topic, msg))
+		return
+	}
+
+	ztopic.chMsg <- msg
 }
 
 /*

zsub/ztopic.go

@@ -1,6 +1,10 @@
 package zsub
 
-import "sync"
+import (
+	"fmt"
+	"log"
+	"sync"
+)
 
 type ZTopic struct { //ZTopic
 	sync.Mutex
@@ -19,7 +23,12 @@ func (t *ZTopic) init() {
 				break
 			}
 
-			for _, group := range t.groups {
+			for name, group := range t.groups {
+				// zgroup chan overload check
+				if len(group.chMsg) == cap(group.chMsg) {
+					log.Println(fmt.Sprintf("zgroup no cap: [%s.%s %s]", name, t.topic, msg))
+					continue
+				}
 				group.chMsg <- msg
 			}
 		}