You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/04/23 07:41:15 UTC

[rocketmq-client-go] branch master updated (7cd7fa9 -> 40242bc)

This is an automated email from the ASF dual-hosted git repository.

jianhaixu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


    from 7cd7fa9  [ISSUE #807] fix code style (#808)
     new b3ce4dc  1. add tcp conn write and read deadline to avoid long time block socket ops when remote endpoint crash. 2. enable tcp keep alive.
     new f1913d6  1. remove request from responseTable when sendAsync 2. change default read/write Deadline to 120 sec. 3. close connection when set deadline fail.
     new 9ebb5ba  1. add log when close socket.
     new 55b7717  1. make tcp relate param configurable
     new b140046  1. fix ci
     new 40242bc  Merge pull request #816 from WJL3333/fix_tcp_write_block

The 408 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 admin/admin.go                        |  2 +-
 consumer/pull_consumer.go             |  2 +-
 consumer/push_consumer.go             |  2 +-
 internal/client.go                    | 36 ++++++++++---------
 internal/namesrv.go                   |  4 +--
 internal/namesrv_test.go              |  2 +-
 internal/remote/remote_client.go      | 65 ++++++++++++++++++++++++++++++++---
 internal/remote/remote_client_test.go | 10 +++---
 internal/remote/tcp_conn.go           |  7 +++-
 internal/route_test.go                |  2 +-
 internal/trace.go                     |  4 +--
 producer/producer.go                  |  2 +-
 12 files changed, 100 insertions(+), 38 deletions(-)