[fix] compare

src/broker/modules/matching.go

@@ -3,6 +3,7 @@ package modules
 import (
 	"errors"
 	_ "errors"
+	"fmt"
 	"github.com/juliangruber/go-intersect"
 	"reflect"
 )
@@ -37,7 +38,7 @@ func (moscato *Moscato) Matching(msg MsgUnit) {
 		valPtr := pos.list.head
 		for valPtr != nil {
 			compare := Compare(valPtr.val, value)
-			if compare < 0 { // sub.val > pub.val
+			if compare > 0 { // sub.val > pub.val
 				// single : { >, >= }
 
 				// (1) case : >
@@ -67,7 +68,7 @@ func (moscato *Moscato) Matching(msg MsgUnit) {
 					big = append(big, sub)
 				}
 
-			} else if compare > 0 { // sub.val < pub.val
+			} else if compare < 0 { // sub.val < pub.val
 
 				// single : { <, <= }
 
@@ -149,7 +150,9 @@ func (moscato *Moscato) Matching(msg MsgUnit) {
 			ip := sub_mng.sub2ip[sub]
 			ret = append(ret, ip)
 		}
-
+		fmt.Println("big = ", big)
+		fmt.Println("small = ", small)
+		fmt.Println("ret = ", ret)
 		moscato.MatchingManager.match_count++
 		moscato.SendQueue <- myType{ret, msg, nil}
 	}