This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/3.0 by this push:
new 6cd738c Fix: heartbeat's timeout will modify consumer's timeout
(#1532)
6cd738c is described below
commit 6cd738cfe4f6414f07bc2bd5764cd27be3571ad7
Author: Jason Peng <[email protected]>
AuthorDate: Mon Oct 25 10:51:49 2021 +0800
Fix: heartbeat's timeout will modify consumer's timeout (#1532)
* improve etcd version and change create to put (#1203)
* fix: CONTRIBUTING.md url error. (#1303)
* add lock (#1304)
* Revert "add lock (#1304)" (#1329)
This reverts commit a10996763e3e1ffa5cdbd80cb49319a4e3626994.
* build(deps): bump github.com/dubbogo/gost from 1.11.14 to 1.11.16 (#1387)
Bumps [github.com/dubbogo/gost](https://github.com/dubbogo/gost) from
1.11.14 to 1.11.16.
- [Release notes](https://github.com/dubbogo/gost/releases)
- [Commits](https://github.com/dubbogo/gost/compare/v1.11.14...v1.11.16)
---
updated-dependencies:
- dependency-name: github.com/dubbogo/gost
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* build(deps): bump google.golang.org/protobuf from 1.26.0 to 1.27.1 (#1386)
Bumps
[google.golang.org/protobuf](https://github.com/protocolbuffers/protobuf-go)
from 1.26.0 to 1.27.1.
- [Release notes](https://github.com/protocolbuffers/protobuf-go/releases)
-
[Changelog](https://github.com/protocolbuffers/protobuf-go/blob/master/release.bash)
-
[Commits](https://github.com/protocolbuffers/protobuf-go/compare/v1.26.0...v1.27.1)
---
updated-dependencies:
- dependency-name: google.golang.org/protobuf
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* build(deps): bump go.etcd.io/etcd/client/v3 from 3.5.0-alpha.0 to 3.5.0
(#1383)
Bumps [go.etcd.io/etcd/client/v3](https://github.com/etcd-io/etcd) from
3.5.0-alpha.0 to 3.5.0.
- [Release notes](https://github.com/etcd-io/etcd/releases)
- [Changelog](https://github.com/etcd-io/etcd/blob/main/CHANGELOG-3.5.md)
- [Commits](https://github.com/etcd-io/etcd/compare/v3.5.0-alpha.0...v3.5.0)
---
updated-dependencies:
- dependency-name: go.etcd.io/etcd/client/v3
dependency-type: direct:production
update-type: version-update:semver-patch
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* Fix: heartbeat's timeout will modify consumer's timeout
Co-authored-by: AlexStocks <[email protected]>
Co-authored-by: randy <[email protected]>
Co-authored-by: LaurenceLiZhixin <[email protected]>
Co-authored-by: Zhiqiang Li <[email protected]>
Co-authored-by: tyltr <[email protected]>
Co-authored-by: Laurence
<[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: yuyu.zx <[email protected]>
Co-authored-by: fangyincheng <[email protected]>
---
remoting/getty/listener.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/remoting/getty/listener.go b/remoting/getty/listener.go
index 622d557..fc9d2f4 100644
--- a/remoting/getty/listener.go
+++ b/remoting/getty/listener.go
@@ -373,7 +373,7 @@ func heartbeat(session getty.Session, timeout
time.Duration, callBack func(err e
req.Event = true
resp := remoting.NewPendingResponse(req.ID)
remoting.AddPendingResponse(resp)
- totalLen, sendLen, err := session.WritePkg(req, 3*time.Second)
+ totalLen, sendLen, err := session.WritePkg(req, -1)
if sendLen != 0 && totalLen != sendLen {
logger.Warnf("start to close the session at heartbeat because
%d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
go session.Close()
