(b *testing.B)
| 9 | ) |
| 10 | |
| 11 | func BenchmarkMemcacheSetGet(b *testing.B) { |
| 12 | n, err := defaultTestNode() |
| 13 | if err != nil { |
| 14 | b.Fatalf("defaultTestNode() failed: %v", err) |
| 15 | } |
| 16 | defer tearDownNodes([]*Node{n}) |
| 17 | |
| 18 | b.ResetTimer() |
| 19 | b.RunParallel(func(pb *testing.PB) { |
| 20 | conn, err := net.Dial("tcp", n.listener.Addr().String()) |
| 21 | if err != nil { |
| 22 | b.Fatalf("couldn't make connection to node: %v", err) |
| 23 | } |
| 24 | defer conn.Close() |
| 25 | buf := bufio.NewReader(conn) |
| 26 | |
| 27 | for pb.Next() { |
| 28 | r := rand.Int63() |
| 29 | kv := fmt.Sprintf("%d", r%10000) |
| 30 | |
| 31 | if r%2 == 0 { |
| 32 | fmt.Fprintf(conn, "GET %v\r\n", kv) |
| 33 | if _, _, err := buf.ReadLine(); err != nil { |
| 34 | b.Errorf("couldn't read response: %v", err) |
| 35 | } |
| 36 | } else { |
| 37 | f := r % 10000 |
| 38 | ttl := r % 100 |
| 39 | s := len(kv) |
| 40 | fmt.Fprintf(conn, "SET %v %d %d %d\r\n%v\r\n", kv, f, ttl, s, kv) |
| 41 | if _, _, err := buf.ReadLine(); err != nil { |
| 42 | b.Errorf("couldn't read response: %v", err) |
| 43 | } |
| 44 | } |
| 45 | } |
| 46 | }) |
| 47 | } |
| 48 | |
| 49 | func BenchmarkMemcacheSetGetReplicated(b *testing.B) { |
| 50 | nodes, err := connectedTestNodes(2, 2) |
nothing calls this directly
no test coverage detected