| 151 | } |
| 152 | |
| 153 | func BenchmarkOldRequest(b *testing.B) { |
| 154 | b.StopTimer() |
| 155 | s := RunDefaultServer() |
| 156 | defer s.Shutdown() |
| 157 | nc, err := nats.Connect(nats.DefaultURL, nats.UseOldRequestStyle()) |
| 158 | if err != nil { |
| 159 | b.Fatalf("Failed to connect: %v", err) |
| 160 | } |
| 161 | defer nc.Close() |
| 162 | ok := []byte("ok") |
| 163 | nc.Subscribe("req", func(m *nats.Msg) { |
| 164 | nc.Publish(m.Reply, ok) |
| 165 | }) |
| 166 | b.StartTimer() |
| 167 | b.ReportAllocs() |
| 168 | q := []byte("q") |
| 169 | for i := 0; i < b.N; i++ { |
| 170 | _, err := nc.Request("req", q, 1*time.Second) |
| 171 | if err != nil { |
| 172 | b.Fatalf("Err %v\n", err) |
| 173 | } |
| 174 | } |
| 175 | } |
| 176 | |
| 177 | func BenchmarkPublishValidation(b *testing.B) { |
| 178 | msgPayload := []byte("test") |