disable the concurrent of tcp package handling

Author: extrame

edgerouter.go

@@ -26,7 +26,6 @@ func Organize(name string, plugins ...interface{}) *EdgeRouter {
 		paths := strings.Split(path, "/")
 		er.Plugins[paths[len(paths)-1]] = plugin
 	}
-	fmt.Println("----")
 	return er
 }
 

math/parse_test.go

@@ -9,8 +9,8 @@ func TestParse0(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val(nil) != 30 {
-		t.Error(ds.Val(nil), "not equals 30")
+	if ds.Int(nil) != 30 {
+		t.Error(ds.Int(nil), "not equals 30")
 	}
 }
 
@@ -21,8 +21,8 @@ func TestParse(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val(nil) != 24 {
-		t.Error(ds.Val(nil), "not equals 24")
+	if ds.Int(nil) != 24 {
+		t.Error(ds.Int(nil), "not equals 24")
 	}
 }
 
@@ -33,8 +33,8 @@ func TestParse1(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val(nil) != 27 {
-		t.Error(ds.Val(nil), "not equals 27")
+	if ds.Int(nil) != 27 {
+		t.Error(ds.Int(nil), "not equals 27")
 	}
 }
 
@@ -45,8 +45,8 @@ $1*6 - 3
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{1}) != 3 {
-		t.Error(ds.Val([]int{1}), "not equals 3")
+	if ds.Int([]int{1}) != 3 {
+		t.Error(ds.Int([]int{1}), "not equals 3")
 	}
 }
 
@@ -57,8 +57,8 @@ $1*$2 - 3
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{1, 3}) != 0 {
-		t.Error(ds.Val([]int{1, 3}), "not equals 0")
+	if ds.Int([]int{1, 3}) != 0 {
+		t.Error(ds.Int([]int{1, 3}), "not equals 0")
 	}
 }
 
@@ -69,8 +69,8 @@ $1* ($2 - 3)
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{2, 4}) != 2 {
-		t.Error(ds.Val([]int{2, 4}), "not equals 2")
+	if ds.Int([]int{2, 4}) != 2 {
+		t.Error(ds.Int([]int{2, 4}), "not equals 2")
 	}
 }
 
@@ -81,8 +81,8 @@ func TestParseClosure1(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{2, 4}) != 2 {
-		t.Error(ds.Val([]int{2, 4}), "not equals 2")
+	if ds.Int([]int{2, 4}) != 2 {
+		t.Error(ds.Int([]int{2, 4}), "not equals 2")
 	}
 }
 
@@ -93,8 +93,8 @@ func TestParseClosure3(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{2, 4}) != 5 {
-		t.Error(ds.Val([]int{2, 4}), "not equals 5")
+	if ds.Int([]int{2, 4}) != 5 {
+		t.Error(ds.Int([]int{2, 4}), "not equals 5")
 	}
 }
 
@@ -105,8 +105,8 @@ func TestParseClosure0(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{2, 4}) != 1 {
-		t.Error(ds.Val([]int{2, 4}), "not equals 1")
+	if ds.Int([]int{2, 4}) != 1 {
+		t.Error(ds.Int([]int{2, 4}), "not equals 1")
 	}
 }
 
@@ -119,7 +119,7 @@ func TestParseClosure2(t *testing.T) {
 
     `)
 	ds := Parse(tokens)
-	if ds.Val([]int{49, 48, 48, 48}) != 16 {
-		t.Error(ds.Val([]int{49, 48, 48, 48}), "not equals 16")
+	if ds.Int([]int{49, 48, 48, 48}) != 16 {
+		t.Error(ds.Int([]int{49, 48, 48, 48}), "not equals 16")
 	}
 }

tcp_server.go

@@ -55,9 +55,7 @@ func handleTcpConn(conn *net.TCPConn, handler TcpHandler) {
 			return
 		}
 		if read_length > 0 {
-			go panicWrapping(func() {
-				handler.PacketReceived(data[0:read_length], conn)
-			})
+			handler.PacketReceived(data[0:read_length], conn)
 		}
 	}
 }