|  | @@ -50,6 +50,7 @@ func (w *tcpWorker) callback(conn internet.Connection) {
 | 
											
												
													
														|  |  	}
 |  |  	}
 | 
											
												
													
														|  |  	ctx = proxy.ContextWithAllowPassiveConnection(ctx, w.allowPassiveConn)
 |  |  	ctx = proxy.ContextWithAllowPassiveConnection(ctx, w.allowPassiveConn)
 | 
											
												
													
														|  |  	ctx = proxy.ContextWithInboundDestination(ctx, v2net.TCPDestination(w.address, w.port))
 |  |  	ctx = proxy.ContextWithInboundDestination(ctx, v2net.TCPDestination(w.address, w.port))
 | 
											
												
													
														|  | 
 |  | +	ctx = proxy.ContextWithSource(ctx, v2net.DestinationFromAddr(conn.RemoteAddr()))
 | 
											
												
													
														|  |  	w.proxy.Process(ctx, v2net.Network_TCP, conn)
 |  |  	w.proxy.Process(ctx, v2net.Network_TCP, conn)
 | 
											
												
													
														|  |  	cancel()
 |  |  	cancel()
 | 
											
												
													
														|  |  	conn.Close()
 |  |  	conn.Close()
 |