From 1d74ed2180e7762a4cac40a5574da446ba8b803e Mon Sep 17 00:00:00 2001 From: crusader Date: Thu, 12 Apr 2018 21:59:29 +0900 Subject: [PATCH] ing --- connection-handler.go | 6 ++++++ readwrite-handler.go | 4 ++++ socket/client-conn-handler.go | 2 ++ socket/readwrite-handler.go | 6 ++++++ 4 files changed, 18 insertions(+) diff --git a/connection-handler.go b/connection-handler.go index 91944bd..9f5d2fe 100644 --- a/connection-handler.go +++ b/connection-handler.go @@ -66,14 +66,20 @@ func (ch *ConnectionHandlers) Clone() *ConnectionHandlers { func (ch *ConnectionHandlers) Validate() error { if ch.Concurrency <= 0 { ch.Concurrency = DefaultConcurrency + } else { + } if ch.KeepAlive <= 0 { ch.KeepAlive = DefaultKeepAlive + } else { + ch.KeepAlive = ch.KeepAlive * time.Second } if ch.HandshakeTimeout <= 0 { ch.HandshakeTimeout = DefaultHandshakeTimeout + } else { + ch.HandshakeTimeout = ch.HandshakeTimeout * time.Second } return nil diff --git a/readwrite-handler.go b/readwrite-handler.go index 3b700ba..16ac929 100644 --- a/readwrite-handler.go +++ b/readwrite-handler.go @@ -78,9 +78,13 @@ func (rwh *ReadWriteHandlers) Validate() error { } if rwh.ReadTimeout <= 0 { rwh.ReadTimeout = DefaultReadTimeout + } else { + rwh.ReadTimeout = rwh.ReadTimeout * time.Second } if rwh.WriteTimeout <= 0 { rwh.WriteTimeout = DefaultWriteTimeout + } else { + rwh.WriteTimeout = rwh.WriteTimeout * time.Second } return nil diff --git a/socket/client-conn-handler.go b/socket/client-conn-handler.go index 1ae18f3..b862bbe 100644 --- a/socket/client-conn-handler.go +++ b/socket/client-conn-handler.go @@ -43,6 +43,8 @@ func (cch *ClientConnHandlers) Validate() error { if cch.ReconnectInterval <= 0 { cch.ReconnectInterval = server.DefaultReconnectInterval + } else { + cch.ReconnectInterval = cch.ReconnectInterval * time.Second } if cch.ReconnectTryTime <= 0 { diff --git a/socket/readwrite-handler.go b/socket/readwrite-handler.go index 4f55862..cc96c17 100644 --- a/socket/readwrite-handler.go +++ b/socket/readwrite-handler.go @@ -55,12 +55,18 @@ func (rwh *ReadWriteHandlers) Validate() error { if rwh.PongTimeout <= 0 { rwh.PongTimeout = server.DefaultPongTimeout + } else { + rwh.PongTimeout = rwh.PongTimeout * time.Second } if rwh.PingTimeout <= 0 { rwh.PingTimeout = server.DefaultPingTimeout + } else { + rwh.PingTimeout = rwh.PingTimeout * time.Second } if rwh.PingPeriod <= 0 { rwh.PingPeriod = (rwh.PingTimeout * 9) / 10 + } else { + rwh.PingPeriod = rwh.PingPeriod * time.Second } return nil