test: add slow test in golang test env

Author: pypeng

.github/workflows/golang.yml

@@ -25,8 +25,14 @@ jobs:
       uses: actions/setup-go@v2
       with:
         go-version: ${{ matrix.gover }}
+    - name: Set up Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: 3.13
     - name: Start memcached servers
       run: ./misc/memcached_server start
+    - name: Start slow memcached server
+      run: ./misc/slow_server.sh
     - name: Run gotest
       run: |
         if [[ ${{ matrix.compiler }} = "gcc" ]]; then export CC=gcc CXX=g++; fi

misc/slow_server.sh

@@ -0,0 +1,7 @@
+#!/bin/sh
+set -ex
+
+python tests/shabby/slow_memcached_server.py &
+pid=$!
+echo "pid of slow memcached server: $pid"
+

src/golibmc_test.go

@@ -1,6 +1,7 @@
 package golibmc
 
 import (
+	"sync"
 	"context"
 	"fmt"
 	"strconv"
@@ -1002,3 +1003,79 @@ func testFlushAll(mc *Client, t *testing.T) {
 	}
 
 }
+
+func getSlowMc() *Client {
+	servers := make([]string, 1)
+	servers[0] = fmt.Sprintf("localhost:%d", 8965)
+	noreply := false
+	hashFunc := HashCRC32
+	failover := false
+	disableLock := false
+
+	mc := New(servers, noreply, "", hashFunc, failover, disableLock)
+
+	// slow mc response in 500ms, larger than default poll (300ms)
+	mc.ConfigTimeout(PollTimeout, 800*time.Millisecond)
+	return mc
+
+}
+
+func TestSlowMemcacheStuck(t *testing.T) {
+	mc := getSlowMc()
+
+	key := "key"
+	mc.Set(context.Background(), &Item{Key: key, Value: []byte("99")})
+
+	var wg sync.WaitGroup
+	for i := 1; i < 10; i++ {
+		wg.Add(1)
+		go func(mc *Client, key string, counter int, wg *sync.WaitGroup) {
+			startTime := time.Now()
+			_, err := mc.Get(context.Background(), key)
+			elapsedTime := time.Since(startTime) // Calculate the elapsed time
+			fmt.Printf("%d runs in: %s\n", counter, elapsedTime)
+			if err != nil {
+				t.Errorf("%d mc get error: %s\n", counter, err)
+			} else if counter > 1 && elapsedTime < 1*time.Second {
+				t.Errorf("%d runs fast: %s\n", counter, elapsedTime)
+			}
+			wg.Done()
+		}(mc, key, i, &wg)
+		// give a go for prev goroutine
+		time.Sleep(10 * time.Millisecond)
+	}
+	wg.Wait()
+}
+
+func TestSlowMemcache(t *testing.T) {
+	mc := getSlowMc()
+
+	key := "key"
+	mc.Set(context.Background(), &Item{Key: key, Value: []byte("99")})
+
+	var wg sync.WaitGroup
+	for i := 1; i < 10; i++ {
+		wg.Add(1)
+		go func(mc *Client, key string, counter int, wg *sync.WaitGroup) {
+			startTime := time.Now()
+			ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
+			defer cancel()
+			_, err := mc.Get(ctx, key)
+			elapsedTime := time.Since(startTime) // Calculate the elapsed time
+			if err == nil {
+				if counter != 1 {
+					t.Errorf("%d mc get value within time: %s\n", counter, elapsedTime)
+				}
+			} else {
+				if elapsedTime > 420*time.Millisecond {
+					t.Errorf("%d stuck fast: %s\n", counter, elapsedTime)
+				}
+
+			}
+			wg.Done()
+		}(mc, key, i, &wg)
+		// give a go for prev goroutine
+		time.Sleep(10 * time.Millisecond)
+	}
+	wg.Wait()
+}