Commit Graph

284 Commits

Author SHA1 Message Date
aofall ca7151e531
fix: Bytebuf resource leak (#14071) 2024-04-16 14:24:28 +08:00
caoyanan666 95439fb23c
fix(3.2): triple AbstractServerCallListener NPE (#14009)
* fix NPE

* Optimize the handling of exceptions in response

---------

Co-authored-by: caoyanan <caoyanan@growingio.com>
2024-04-07 14:56:35 +08:00
jean pierre Lerbscher 00812ce41c
Fix Sonar issue s2293 The diamond operator ('<>') should be used (#14005) 2024-03-29 11:40:06 +08:00
aofall 36e0cf5490
fix(#13305): RpcContext local address info get null on custom filter (#13751)
* fix(#13305): RpcContext local address info get null on custom filter

* fix ci build failed

* fix ci build failed
2024-03-11 14:00:16 +08:00
icodening 2cf54f7947
Close the connection but not the client (#13600)
* Close the connection but not the client

* Close the connection but not the client
2024-01-19 18:19:57 +08:00
宝宝爸师 1368e21d9b
optimize isProtobufClass method impl (#13557)
* optimize isProtobufClass method impl

* build error for unknown reason

* fix build error
2023-12-26 17:31:44 +08:00
kaze 5554706256
Fix streamobserver actual type (#13446)
* fix:obtain actual type in StreamObserver.

* format code

---------

Co-authored-by: kaze <kaze-official@foxmail.com>
2023-12-06 10:57:09 +08:00
Albumen Kevin 3e1310bea8
Fix TriRpcStatus not implements Serializable (#13453)
* Fix TriRpcStatus not implements Serializable

* Fix TriRpcStatus not implements Serializable
2023-12-04 12:48:27 +08:00
Albumen Kevin d552cfca51
Fix generic invoke failed for triple (#13442) 2023-12-01 10:25:03 +08:00
Albumen Kevin 5df704b67c
Fix go away handler (#13376) 2023-11-16 15:26:33 +08:00
huazhongming 730695a7a2
[3.2]Use spotless to format the code (#13320)
* Use spotless to format the code

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* Support develop with JDK 21

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

---------

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2023-11-07 15:40:13 +08:00
Albumen Kevin aa631cd362
Revert "Protobuf method not allow override (#13155)" (#13295)
This reverts commit 416374cd78.
2023-11-01 19:34:44 +08:00
宝宝爸师 416374cd78
Protobuf method not allow override (#13155)
* pb method not allow override

* pb method not allow override

* remove wildcard import

* if judgement split into 2 simple

* add pb method override ut&it

* modify pb method override exception msg

* update pb method override test case

* format code

* format code

* optimize import

* Optimize the isProtobufClass method

* fix sonarLint problems

* fix sonar problem

* use ProtobufUtils.class ClassLoader to load Protobuf Message

* format code

* protobufUtils add log

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: earthchen <earthchen1996@gmail.com>
2023-10-19 12:31:59 +08:00
Albumen Kevin 91594eccfa
Enhance logs following up #13228 (#13229) 2023-10-18 11:51:40 +08:00
Albumen Kevin f995ef506c
Fix triple method override (#13224)
* Fix triple method override

* Fix server

* Fix test
2023-10-18 11:39:33 +08:00
Albumen Kevin 02e486a1dc
Fix unable to receive go away frame (#13228)
* Fix unable to receive go away frame

* Rename

* rename
2023-10-18 11:38:57 +08:00
TomlongTK c10d95b56a
Fix RejectException (#12950)
* fix RejectException null

* fix reference

* use isTerminated judge Executor

* use isShutdown judge Executor

---------

Co-authored-by: earthchen <earthchen1996@gmail.com>
2023-10-11 23:32:30 +08:00
TomlongTK 069fd5e1ce
Fix triple client stream executor (#13178)
* Fix error stream executor

* add ping pong for tri protocol (#12955)

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* Revert "add ping pong for tri protocol (#12955)"

This reverts commit 5a3be17bf1.

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: icodening <cleverbn96@gmail.com>
2023-10-11 23:23:25 +08:00
icodening b84c1386bb
add ping pong for tri protocol (#12955)
* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol
2023-10-11 11:17:41 +08:00
TomlongTK 3ca35045a0
Release ByteBuf when handle onData failed (#13102)
* Release ByteBuf when handle onData failed

* Runnable with clean function

* Fix license

* Release ByteBuf in onData method, and refactor some sonar issue.

* Remove unused dependency

---------

Co-authored-by: earthchen <earthchen1996@gmail.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2023-10-10 10:28:15 +08:00
gzhao9 49dd3d0236
Update StubInvocationUtilTest.java (#13174) 2023-10-10 10:12:19 +08:00
TomlongTK 2697652e74
Fix concurrency problem when receive ResetFrame and HeadFrame (#13062) 2023-09-20 10:19:16 +08:00
Albumen Kevin fe7c8eedb5
Fix triple generic invoke (#13021) 2023-09-08 10:29:15 +08:00
icodening 90325f2fe6
fix triple npe (#12918) 2023-08-17 13:19:08 +08:00
icodening 521b3e0146
fix memory leak (#12805)
* fix memory leak

* fix ut
2023-08-02 17:30:32 +08:00
TomlongTK f7c9042e3b
Make sure method name when sendMessage error (#12830) 2023-08-02 17:23:27 +08:00
icodening 1355b28734
fix throw RejectedExecutionException (#12674)
* fix throw RejectedExecutionException

* fix throw RejectedExecutionException when ThreadlessExecutor has been shutdown
2023-07-06 12:40:45 +08:00
yuzang 5d76667808
Clear future in RpcContext when calling sync (#12493) (#12534)
* Clear future in RpcContext when calling sync (#12493)

* skip set futureContext in sync situation

* fix

* add setFutureWhenSync

---------

Co-authored-by: 解立强 <xieliqiang@kkworld.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2023-06-30 20:33:17 +08:00
Albumen Kevin 9577d464a0
Triple set resolve fallback enable as default (#12575)
* Triple set resolve fallback enable as default

* use throw
2023-06-21 13:22:27 +08:00
Albumen Kevin 5f39404b07
Support set actual content length to inv/res attributes (#12521) 2023-06-13 21:42:27 +08:00
Albumen Kevin e07e5e294b
Fix get method name from invocation (#12519)
* Fix get method name from invocation

* fix compile
2023-06-13 20:25:25 +08:00
icodening eba976fec6
reset all active stream on connection close (#12451)
* reset all active stream on connection close

* reset all active stream on connection close
2023-06-07 11:03:26 +08:00
icodening 00d8a46cd5
support catch actual exception (#12446) 2023-06-07 11:01:33 +08:00
TomlongTK fa8e09201f
packable method extension (#12199)
* packable method extension

* support content-type

* packable method extension

* support content-type

* get packable factory type from configuration

* Add new SPI to dubbo-all(dubbo-distribution/dubbo-all/pom.xml in shade plugin) to being transformed

* At present, Use CONTENT_PROTO as content-type, while support customize content-type, need fix it

* remove unused import class

---------

Co-authored-by: longqiang02 <longqiang02@maoyan.com>
2023-04-28 10:55:01 +08:00
earthchen 1729d5b69e
fix npe (#12146) 2023-04-20 16:24:54 +08:00
earthchen 43bbf9f727
Refactor pb version (#12109)
* refactor pb version

* fix

* fix

* fix

* fix
2023-04-18 10:04:52 +08:00
dependabot[bot] f618016656
Bump protobuf-java from 3.22.2 to 3.22.3 (#12102)
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.22.2 to 3.22.3.
- [Release notes](https://github.com/protocolbuffers/protobuf/releases)
- [Changelog](https://github.com/protocolbuffers/protobuf/blob/main/generate_changelog.py)
- [Commits](https://github.com/protocolbuffers/protobuf/compare/v3.22.2...v3.22.3)

---
updated-dependencies:
- dependency-name: com.google.protobuf:protobuf-java
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-04-17 14:14:03 +08:00
Albumen Kevin 7e3064f9b6
Deny allow (#12068)
* Deny allow

* Fix test

* Fix test

* trust metadata info

* trust hessian

* Fix compile

* Fix compile

* Fix test

* Fix test

* Fix test
2023-04-12 00:15:07 +08:00
Albumen Kevin bc34399771 Merge branch 'apache-3.1' into apache-3.2 2023-04-11 22:58:05 +08:00
earthchen 6b1de07b91
remove unused code (#11459) 2023-04-11 22:57:21 +08:00
aamingaa 718bdc1a65
feat: triple exception self (#12039)
* feat: triple exception self

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: change protobuf version

* fix compile

* feat: fix equals

* feat: fix ut。。。

* feat: deserialize

* feat: remove unuse

* Revert "feat: remove unuse"

This reverts commit e72f713319.

* remove unused code

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: earthchen <earthchen@apache.org>
2023-04-11 22:56:58 +08:00
earthchen 85e1f97116
change headerfilter scope (#12058)
* change headerfilter scope

* fix

* fix import
2023-04-11 14:03:41 +08:00
KamTo Hung f05662a66d
optimize JsonUtils (#12057) 2023-04-11 11:24:55 +08:00
icodening 3134056ac0
optimize ThreadlessExecutor (#11965)
* 1. optimize ThreadlessExecutor
2. tri response works on user threads

* 1. optimize ThreadlessExecutor
2. tri response works on user threads

* 1. optimize ThreadlessExecutor
2. tri response works on user threads

* 1. optimize ThreadlessExecutor
2. tri response works on user threads

* 1.optimize ThreadlessExecutor
2.tri response works on user threads

* threadless only sync mode

* threadless only sync mode

---------

Co-authored-by: earthchen <earthchen1996@gmail.com>
2023-04-11 10:52:59 +08:00
dependabot[bot] 9b01940d30
Bump os-maven-plugin from 1.6.2 to 1.7.1 (#12048)
Bumps [os-maven-plugin](https://github.com/trustin/os-maven-plugin) from 1.6.2 to 1.7.1.
- [Release notes](https://github.com/trustin/os-maven-plugin/releases)
- [Commits](https://github.com/trustin/os-maven-plugin/compare/os-maven-plugin-1.6.2...os-maven-plugin-1.7.1)

---
updated-dependencies:
- dependency-name: kr.motd.maven:os-maven-plugin
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-04-10 19:13:05 +08:00
earthchen bd57066e71
tri serial check (#12029)
* serial check

* fix checkstyle

* fix

* fix instance address url
2023-04-08 16:49:20 +08:00
Albumen Kevin e3053618dd Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/CodecSupport.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ReflectionPackableMethod.java
2023-04-06 19:33:34 +08:00
earthchen 03647452d5
triple serialize check (#11984)
* no wrap

* remove unused code

* fix ut

* fix ut
2023-04-06 19:32:21 +08:00
earthchen 7b9e65ed06
Revert "optimize performance. decode in user thread (#11879)" (#11917)
This reverts commit 95865b0461.
2023-03-24 23:35:13 +08:00
icodening 92421ba634
triple server batch flush (#11723)
Co-authored-by: earthchen <earthchen1996@gmail.com>
2023-03-24 14:04:53 +08:00