ing

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

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

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 {

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