Skip to content

Commit 91137ce

Browse files
committed
Make StartTracer accept listen & server addr arguments
1 parent 0d00ce2 commit 91137ce

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

conn.go

-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ package zk
44

55
import (
66
"encoding/binary"
7-
"errors"
87
"io"
98
"log"
109
"net"

tracer.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -177,8 +177,8 @@ func trace(conn1, conn2 net.Conn, client bool) {
177177
}
178178
}
179179

180-
func handleConnection(conn net.Conn) {
181-
zkConn, err := net.Dial("tcp", "127.0.0.1:2181")
180+
func handleConnection(addr string, conn net.Conn) {
181+
zkConn, err := net.Dial("tcp", addr)
182182
if err != nil {
183183
fmt.Println(err)
184184
return
@@ -187,8 +187,8 @@ func handleConnection(conn net.Conn) {
187187
trace(zkConn, conn, false)
188188
}
189189

190-
func StartTracer() {
191-
ln, err := net.Listen("tcp", "127.0.0.1:2182")
190+
func StartTracer(listenAddr, serverAddr string) {
191+
ln, err := net.Listen("tcp", listenAddr)
192192
if err != nil {
193193
panic(err)
194194
}
@@ -198,6 +198,6 @@ func StartTracer() {
198198
fmt.Println(err)
199199
continue
200200
}
201-
go handleConnection(conn)
201+
go handleConnection(serverAddr, conn)
202202
}
203203
}

tracer/main.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,5 +5,5 @@ import (
55
)
66

77
func main() {
8-
zk.StartTracer()
8+
zk.StartTracer("127.0.0.1:2182", "127.0.0.1:2181")
99
}

0 commit comments

Comments
 (0)