X-Git-Url: http://git.scottworley.com/reliable-chat/blobdiff_plain/7d92df123c1cb82e40f99b2f3febec687adb9ce4..549a590ff61432e3148005a31bcc2d1b663ab4e1:/server/server.go?ds=sidebyside diff --git a/server/server.go b/server/server.go index 74a1da2..74e116f 100644 --- a/server/server.go +++ b/server/server.go @@ -34,6 +34,7 @@ var speak_count = expvar.NewInt("speak_count") var fetch_count = expvar.NewInt("fetch_count") var fetch_wait_count = expvar.NewInt("fetch_wait_count") var fetch_wake_count = expvar.NewInt("fetch_wake_count") +var drop_due_to_limit_count = expvar.NewInt("drop_due_to_limit_count") type Message struct { Time time.Time @@ -76,6 +77,7 @@ main: message_count++ } else { messages.Remove(messages.Front()) + drop_due_to_limit_count.Add(1) } case request, ok := <-store.Get: if !ok {