enable tests in CI and dont copy atomics

Author: AnthonyMichaelTDM

.github/workflows/ci.yaml

@@ -39,13 +39,14 @@ jobs:
         run: go vet ./...
         working-directory: src
 
+      - name: Run tests
+        run: go test ./...
+        working-directory: src
+
       - name: install staticcheck
         run: go install honnef.co/go/tools/cmd/staticcheck@latest
         working-directory: src
-          
+
       - name: Lint code (staticcheck)
         run: staticcheck ./...
         working-directory: src
-
-    #   - name: Run tests # on my machine, the tests hang, so I'm not running them here yet
-    #     run: go test ./...

src/mod/streamproxy/streamproxy.go

@@ -61,12 +61,12 @@ type ProxyRelayInstance struct {
 	Timeout          int    //Timeout for connection in sec
 
 	/* Internal */
-	tcpStopChan                 chan bool    //Stop channel for TCP listener
-	udpStopChan                 chan bool    //Stop channel for UDP listener
-	aTobAccumulatedByteTransfer atomic.Int64 //Accumulated byte transfer from A to B
-	bToaAccumulatedByteTransfer atomic.Int64 //Accumulated byte transfer from B to A
-	udpClientMap                sync.Map     //map storing the UDP client-server connections
-	parent                      *Manager     `json:"-"`
+	tcpStopChan                 chan bool     //Stop channel for TCP listener
+	udpStopChan                 chan bool     //Stop channel for UDP listener
+	aTobAccumulatedByteTransfer *atomic.Int64 //Accumulated byte transfer from A to B
+	bToaAccumulatedByteTransfer *atomic.Int64 //Accumulated byte transfer from B to A
+	udpClientMap                sync.Map      //map storing the UDP client-server connections
+	parent                      *Manager      `json:"-"`
 }
 
 type Options struct {
@@ -183,8 +183,8 @@ func (m *Manager) NewConfig(config *ProxyRelayOptions) string {
 		Timeout:                     config.Timeout,
 		tcpStopChan:                 nil,
 		udpStopChan:                 nil,
-		aTobAccumulatedByteTransfer: aAcc,
-		bToaAccumulatedByteTransfer: bAcc,
+		aTobAccumulatedByteTransfer: &aAcc,
+		bToaAccumulatedByteTransfer: &bAcc,
 		udpClientMap:                sync.Map{},
 		parent:                      m,
 	}

src/mod/streamproxy/tcpprox.go

@@ -174,7 +174,7 @@ func (c *ProxyRelayInstance) Port2host(allowPort string, targetAddress string, s
 				}
 			}
 
-			c.forward(target, conn, &c.aTobAccumulatedByteTransfer, &c.bToaAccumulatedByteTransfer)
+			c.forward(target, conn, c.aTobAccumulatedByteTransfer, c.bToaAccumulatedByteTransfer)
 		}(targetAddress)
 	}
 }