fix goroutine leak (#14)

* fix mem leak (#8)

* set conn deadline

* modify balance log level (#11)

* Use github actions for test (#13)

Co-authored-by: Yang Xiufeng <[email protected]>

.github/workflows/go.yml

@@ -0,0 +1,40 @@
+on: [push, pull_request]
+name: GoBeansProxy Test
+jobs:
+  test:
+    strategy:
+      matrix:
+        go-version: [1.12.x, 1.13.x]
+        python-version: [2.x]
+        platform: [ubuntu-latest, macos-latest]
+    runs-on: ${{ matrix.platform }}
+    steps:
+    - name: Install Go
+      uses: actions/setup-go@v1
+      with:
+        go-version: ${{ matrix.go-version }}
+
+    - name: Install Python
+      uses: actions/setup-python@v1
+      with:
+        python-version: ${{ matrix.python-version }}
+
+    - name: Checkout code
+      uses: actions/checkout@v1
+
+    - name: Get test tools
+      run: go get -u -v golang.org/x/tools/cmd/goimports
+
+    - name: Prepare Test
+      run: pip install --user -r tests/pip-req.txt
+
+    - name: Test
+      run: |
+        export PATH=${PATH}:`go env GOPATH`/bin
+        diff <(goimports -d .) <(printf "")
+        go mod vendor
+        go get -u -v github.com/douban/gobeansdb
+        make test
+
+    - name: Install
+      run: make install

Makefile

@@ -17,5 +17,4 @@ pytest:install
 	./tests/run_test.sh
 
 install:
-	GO111MODULE=on go mod vendor
 	go install ./

README.md

@@ -1,4 +1,4 @@
-# GoBeansproxy [![Build Status](https://travis-ci.org/douban/gobeansproxy.svg?branch=master)](https://travis-ci.org/douban/gobeansproxy)
+# GoBeansProxy ![](https://github.com/douban/gobeansproxy/workflows/GoBeansProxy%20Test/badge.svg)
 
 A proxy for [Gobeansdb](https://github.com/douban/gobeansdb).
 
@@ -11,6 +11,7 @@ Supported Go version: > 1.11.0
 ```
 $ git clone http://github.com/douban/gobeansproxy.git
 $ cd gobeansproxy
+$ go mod vendor
 $ make
 ```
 

dstore/bucket.go

@@ -104,7 +104,7 @@ func (bucket *Bucket) balance() {
 		offsetOld = bucket.partition.offsets
 		bucket.partition.reBalance(fromHost, toHost, 1)
 		offsetNew = bucket.partition.offsets
-		logger.Errorf("bucket %d BALANCE: from host-%s-%d to host-%s-%d, make offsets %v to %v ", bucket.ID, bucket.hostsList[fromHost].host.Addr, fromHost, bucket.hostsList[toHost].host.Addr, toHost, offsetOld, offsetNew)
+		logger.Debugf("bucket %d BALANCE: from host-%s-%d to host-%s-%d, make offsets %v to %v ", bucket.ID, bucket.hostsList[fromHost].host.Addr, fromHost, bucket.hostsList[toHost].host.Addr, toHost, offsetOld, offsetNew)
 	}
 }