This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch 1.4
in repository https://gitbox.apache.org/repos/asf/dubbo-getty.git
commit 8296ef87a7d5241418381763b32fb1e1f89928f8
Author: yuyu <yuyu...@alipay.com>
AuthorDate: Wed Dec 2 16:50:03 2020 +0800
Rem: session.SetRQLen
---
client_test.go | 1 -
demo/hello/tcp/config.go | 1 -
demo/hello/tls/config.go | 1 -
getty.go | 3 ---
go.mod | 2 +-
session.go | 3 ---
6 files changed, 1 insertion(+), 10 deletions(-)
diff --git a/client_test.go b/client_test.go
index 4c6841e..8c3ba2f 100644
--- a/client_test.go
+++ b/client_test.go
@@ -87,7 +87,6 @@ func newSessionCallback(session Session, handler
*MessageHandler) error {
session.SetMaxMsgLen(1024)
session.SetPkgHandler(&pkgHandler)
session.SetEventListener(handler)
- session.SetRQLen(4)
session.SetWQLen(32)
session.SetReadTimeout(3e9)
session.SetWriteTimeout(3e9)
diff --git a/demo/hello/tcp/config.go b/demo/hello/tcp/config.go
index b000c8d..9bfa00a 100644
--- a/demo/hello/tcp/config.go
+++ b/demo/hello/tcp/config.go
@@ -63,7 +63,6 @@ func InitialSession(session getty.Session) (err error) {
session.SetName("hello")
session.SetMaxMsgLen(128)
- // session.SetRQLen(1024)
session.SetWQLen(512)
session.SetReadTimeout(time.Second)
session.SetWriteTimeout(5 * time.Second)
diff --git a/demo/hello/tls/config.go b/demo/hello/tls/config.go
index 01db739..dce29e6 100644
--- a/demo/hello/tls/config.go
+++ b/demo/hello/tls/config.go
@@ -43,7 +43,6 @@ func InitialSession(session getty.Session) (err error) {
if ok {
session.SetName("hello")
session.SetMaxMsgLen(128)
- // session.SetRQLen(1024)
session.SetWQLen(512)
session.SetReadTimeout(time.Second)
session.SetWriteTimeout(5 * time.Second)
diff --git a/getty.go b/getty.go
index 5aaad1e..050483e 100644
--- a/getty.go
+++ b/getty.go
@@ -163,9 +163,6 @@ type Session interface {
SetWriter(Writer)
SetCronPeriod(int)
- // Deprecated: don't use read queue.
- SetRQLen(int)
-
SetWQLen(int)
SetWaitTime(time.Duration)
// Deprecated: don't use SetTaskPool, move to endpoints layer.
diff --git a/go.mod b/go.mod
index 870fc1c..f2a5a39 100644
--- a/go.mod
+++ b/go.mod
@@ -3,7 +3,7 @@ module github.com/apache/dubbo-getty
go 1.14
require (
- github.com/dubbogo/gost v1.9.6
+ github.com/dubbogo/gost v1.9.7
github.com/golang/snappy v0.0.1
github.com/gorilla/websocket v1.4.2
github.com/pkg/errors v0.9.1
diff --git a/session.go b/session.go
index 005430d..a718bd3 100644
--- a/session.go
+++ b/session.go
@@ -299,9 +299,6 @@ func (s *session) SetCronPeriod(period int) {
s.period = time.Duration(period) * time.Millisecond
}
-// Deprecated: don't use read queue.
-func (s *session) SetRQLen(readQLen int) {}
-
// set @session's Write queue size
func (s *session) SetWQLen(writeQLen int) {
if writeQLen < 1 {
