streamer: fixup pool(to) connection session variables setting #12

xelabs · Apr 9, 2019 · 3d6f763 · 3d6f763
1 parent 800e65f
commit 3d6f763
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/common/streamer.go b/src/common/streamer.go
@@ -135,7 +135,7 @@ func Streamer(log *xlog.Log, args *Args) {
 	AssertNil(err)
 	defer fromPool.Close()
 
-	toPool, err := NewPool(log, args.Threads, args.ToAddress, args.ToUser, args.ToPassword, "")
+	toPool, err := NewPool(log, args.Threads, args.ToAddress, args.ToUser, args.ToPassword, args.SessionVars)
 	AssertNil(err)
 	defer toPool.Close()
 

diff --git a/src/mystreamer/main.go b/src/mystreamer/main.go
@@ -54,7 +54,7 @@ func main() {
 	flag.Usage = func() { usage() }
 	flag.Parse()
 
-	if flagHost == "" || flagUser == "" || flagPasswd == "" || flagDb == "" || flag2host == "" || flag2user == "" || flag2passwd == "" {
+	if flagHost == "" || flagUser == "" || flagDb == "" || flag2host == "" || flag2user == "" {
 		usage()
 		os.Exit(0)
 	}