gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

version bump to next beta

Browse Source
This commit is contained in:
Derek Collison
2016-06-15 11:10:50 -07:00
parent 86e883ce7d
commit 27ac524daf
2 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/const.go
View File

@@ -8,7 +8,7 @@ import (
const (
// VERSION is the current version for the server.
VERSION = "0.8.1"
VERSION = "0.8.2.beta"
// DEFAULT_PORT is the default port for client connections.
DEFAULT_PORT = 4222

17
test/bench_test.go
View File

@@ -72,44 +72,47 @@ func sizedString(sz int) string {
return string(sizedBytes(sz))
}
// Publish subject for pub benchmarks.
var psub = "a"
func Benchmark____PubNo_Payload(b *testing.B) {
benchPub(b, "a", "")
benchPub(b, psub, "")
}
func Benchmark____Pub8b_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(8)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func Benchmark___Pub32b_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(32)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func Benchmark__Pub256B_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(256)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func Benchmark____Pub1K_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(1024)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func Benchmark____Pub4K_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(4 * 1024)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func Benchmark____Pub8K_Payload(b *testing.B) {
b.StopTimer()
s := sizedString(8 * 1024)
benchPub(b, "a", s)
benchPub(b, psub, s)
}
func drainConnection(b *testing.B, c net.Conn, ch chan bool, expected int) {