oss/FrankerFaceZ
oss/FrankerFaceZ
1
0
Fork 0
mirror of https://github.com/FrankerFaceZ/FrankerFaceZ.git synced 2025-08-02 07:58:31 +00:00
Code Wiki Activity

at least pretend to make Statistics thread-safe

Browse source 
reduce websocket read buffers
This commit is contained in:
Kane York 2017-09-15 15:55:42 -07:00
parent 443a658af2
commit e725dc248c
2 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
socketserver/server/handlecore.go
View file

@ -186,7 +186,7 @@ func HTTPSayOK(w http.ResponseWriter, _ *http.Request) {
// SocketUpgrader is the websocket.Upgrader currently in use. // SocketUpgrader is the websocket.Upgrader currently in use.
var SocketUpgrader = websocket.Upgrader{ var SocketUpgrader = websocket.Upgrader{
ReadBufferSize: 1024, ReadBufferSize: 160,
WriteBufferSize: 1024, WriteBufferSize: 1024,
CheckOrigin: func(r *http.Request) bool { CheckOrigin: func(r *http.Request) bool {
return r.Header.Get("Origin") == "" || OriginRegexp.MatchString(r.Header.Get("Origin")) return r.Header.Get("Origin") == "" || OriginRegexp.MatchString(r.Header.Get("Origin"))

5
socketserver/server/stats.go
View file

@ -12,6 +12,8 @@ import (
) )
type StatsData struct { type StatsData struct {
updateMu sync.Mutex
StatsDataVersion int StatsDataVersion int
StartTime time.Time StartTime time.Time
@ -114,6 +116,9 @@ func SetBuildStamp(buildTime, buildHash string) {
} }
func updateStatsIfNeeded() { func updateStatsIfNeeded() {
Statistics.updateMu.Lock()
defer Statistics.updateMu.Unlock()
if time.Now().Add(-2 * time.Second).After(Statistics.CachedStatsLastUpdate) { if time.Now().Add(-2 * time.Second).After(Statistics.CachedStatsLastUpdate) {
updatePeriodicStats() updatePeriodicStats()
} }