Function OptimizedCopyWithBufferSizeAndMetrics

pkg/shared/network.go:307–331

OptimizedCopyWithBufferSizeAndMetrics performs optimized copying with custom buffer size and metrics

(dst, src net.Conn, bufferSize int, recordBytes func(int64))

// OptimizedCopyWithBufferSizeAndMetrics performs optimized copying with custom buffer size and metrics
func OptimizedCopyWithBufferSizeAndMetrics(dst, src net.Conn, bufferSize int, recordBytes func(int64)) {
	done := make(chan struct{}, 2)
	
	// Copy from src to dst
	go func() {
		defer func() { done <- struct{}{} }()
		copyWithBufferAndMetrics(dst, src, bufferSize, recordBytes)
	}()
	
	// Copy from dst to src
	go func() {
		defer func() { done <- struct{}{} }()
		copyWithBufferAndMetrics(src, dst, bufferSize, recordBytes)
	}()
	
	// Wait for either direction to complete
	<-done
	
	// Close both connections to stop the other direction
	dst.Close()
	src.Close()
	
	// Wait for the other direction to complete
	<-done
}

// OptimizedCopyWithContextAndMetrics performs high-performance bidirectional copying with context and metrics
func OptimizedCopyWithContextAndMetrics(ctx context.Context, dst, src net.Conn, recordBytes func(int64)) {