Commit 366d076f authored by nanahira's avatar nanahira

log mark

parent b8711499
Pipeline #13062 canceled with stages
in 1 minute and 12 seconds
//go:build linux
// +build linux
package gost
......@@ -45,13 +46,14 @@ func (h *tcpRedirectHandler) Handle(c net.Conn) {
srcAddr := conn.RemoteAddr()
dstAddr, conn, err := h.getOriginalDstAddr(conn)
mark := h.options.Chain.Mark
if err != nil {
log.Logf("[red-tcp] %s -> %s : %s", srcAddr, dstAddr, err)
log.Logf("[red-tcp] (Mark: %d) %s -> %s : %s", mark, srcAddr, dstAddr, err)
return
}
defer conn.Close()
log.Logf("[red-tcp] %s -> %s", srcAddr, dstAddr)
log.Logf("[red-tcp] (Mark: %d) %s -> %s", mark, srcAddr, dstAddr)
cc, err := h.options.Chain.DialContext(context.Background(),
"tcp", dstAddr.String(),
......@@ -59,14 +61,14 @@ func (h *tcpRedirectHandler) Handle(c net.Conn) {
TimeoutChainOption(h.options.Timeout),
)
if err != nil {
log.Logf("[red-tcp] %s -> %s : %s", srcAddr, dstAddr, err)
log.Logf("[red-tcp] (Mark: %d) %s -> %s : %s", mark, srcAddr, dstAddr, err)
return
}
defer cc.Close()
log.Logf("[red-tcp] %s <-> %s", srcAddr, dstAddr)
log.Logf("[red-tcp] (Mark: %d) %s <-> %s", mark, srcAddr, dstAddr)
transport(conn, cc)
log.Logf("[red-tcp] %s >-< %s", srcAddr, dstAddr)
log.Logf("[red-tcp] (Mark: %d) %s >-< %s", mark, srcAddr, dstAddr)
}
func (h *tcpRedirectHandler) getOriginalDstAddr(conn *net.TCPConn) (addr net.Addr, c *net.TCPConn, err error) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment