natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
7,588 Commits 16 Branches 144 Tags 129 MiB
Commit Graph

469 Commits

Author SHA1 Message Date
aofall 473ea36b04
fix: Support close the Curator EnsembleTracker (#14281) 2024-06-04 12:54:44 +08:00
Kaiyao Ke 8e2eb332a1
fixed non-idempotent unit tests (#14172) 2024-05-11 00:27:46 +08:00
hanpen24 f03823eec1
Use ExecutorService instead of event loop for Netty connection (#13904) 
* Use ExecutorService instead of event loop for Netty connection

This change addresses the issue of the event loop being blocked for an extended period, improving overall performance and responsiveness.

* fix log getConnectAddress

* applay format

* applay format

* applay format

* applay format

* applay format

* Use an independent ExecutorService

* Use ScheduledExecutorService for scheduling tasks

* delete unnecessary files

* Modify to stop ExecutorService using shutdownNow

* Modify to use ScheduledExecutor managed by FrameworkExecutorRepository

* Synchronize reconnectDuration with HeaderExchangeClient's reconnectDuration

* get framework model directly

use awaitility
 2024-04-07 10:31:23 +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
hyhnet d50adb7c83
fix typos (#13858) 
Co-authored-by: Cyrus <yecity@gmail.com>
 2024-03-10 11:22:59 +08:00
namelessssssssssss 29b0c7298d
Fix port unification issue in triple and dubbo protocol (#13696) 
* Fix issue of tri Portunification

* style fix
 2024-01-31 10:59:25 +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 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 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
Poison 52250b8a20
Fix incorrect timeout message (#13001) 
* Fix incorrect timeout message

* Remove @Disabled annotation to enable unit test
 2023-09-12 12:45:03 +08:00
Albumen Kevin 0bfd54cea4
Cleanup and throw exception if bind failed (#12987) 2023-09-01 13:03:33 +08:00
Albumen Kevin 0de4c395e8
Fix shouldReconnect check (#12949) 2023-08-23 11:27:10 +08:00
Albumen Kevin 630e14ae40
Fix netty close when init count is 0 (#12737) 2023-07-17 11:35:03 +08:00
Albumen Kevin bd76d044ba Disable secure random request id by default 2023-07-16 21:28:38 +08:00
Albumen Kevin 976ffda33b
Support skip use secure random id (#12724) 2023-07-14 11:00:01 +08:00
Albumen Kevin 0138ea87a4 Merge branch 'apache-3.1' into apache-3.2 2023-07-11 10:13:17 +08:00
Albumen Kevin c45ce1974d Use secure random 2023-07-11 10:10:38 +08:00
Albumen Kevin e026b5bb59 Merge branch 'apache-3.1' into apache-3.2 
# Conflicts:
#	dubbo-remoting/dubbo-remoting-api/src/test/java/org/apache/dubbo/remoting/exchange/RequestTest.java
 2023-07-06 17:57:11 +08:00
Albumen Kevin f882cbdd80
Use random id (#12663) 
* Use random id

* Fix uts
 2023-07-06 17:54:47 +08:00
Albumen Kevin 271d5eff29
Update minimal reconnect period (#12639) 2023-07-03 10:27:56 +08:00
Albumen Kevin 6ad735d74a
Fix server shutdown await timeout (#12644) 2023-07-03 10:16:14 +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 e6e68f6b84
Fix channel close event cause hanging thread (#12503) 
* Fix channel close event cause hanging thread

* Fix check

* fix npe

* fix ut

* fix check

* fix uts

* fix testing
 2023-06-13 10:27:38 +08:00
Albumen Kevin e92f85d980
Support client gracefully shutdown (#12504) 
* Support client gracefully shutdown

* fix check

* Fix init
 2023-06-12 20:27:55 +08:00
Albumen Kevin 0f7a62a8ff
Fix long time await in ThreadlessExecutor (#12484) 
* Fix long time await in ThreadlessExecutor

* Fix uts
 2023-06-10 18:14:30 +08:00
wxbty 3d02e9c789
serialization RpcException bug pr rebase (#12357) 
* rebase seri error

* fix style

* wrapper seriation exception by IOException

* fix ci

* use exception

* Multiple encode/decode conversion exceptions

* use wrapper to handle seri exp

* add licence

* move seriExp path

* revert demo

* use static proxy

* fix ci

* fix ci

* Update dubbo-serialization/dubbo-serialization-api/src/main/java/org/apache/dubbo/common/serialize/DefaultSerializationExceptionWrapper.java

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>

* simplefy throwable type

* judge IOException

---------

Co-authored-by: xuziyang <767637918@qq.com>
Co-authored-by: x-shadow-man <1494445739@qq.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
 2023-06-03 14:52:52 +08:00
Albumen Kevin e5d2a5798e
Support config close timeout (#12386) 
* Support config close timeout

* Fix spell

* fix ut
 2023-05-23 14:52:49 +08:00
Albumen Kevin 0a7a960f39
Default heartbeat configurable (#12241) 2023-05-07 20:30:52 +08:00
Albumen Kevin 25a08a2b40
Support offline notify (#12211) 
* Support offline notify

* Add log
 2023-05-02 21:25:11 +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
Albumen Kevin 7facd5be19
Fix memory leak when hashed wheel time re-put (#12022) 2023-04-11 19:00:02 +08:00
Albumen Kevin f0f01c36c3
Fix serializable check & Add test cases (#12054) 
* Add test cases

* Fix uts

* Add fj2 test

* save

* Fix check

* Disable some test cases

* Fix test
 2023-04-11 16:58:55 +08:00
Albumen Kevin bc85a3f29a
Performance Optimization (#11975) 2023-04-11 16:10:06 +08:00
Albumen Kevin 412471a98f
Enhance inconsistent version check (#12038) 
* Enhance inconsistent version check

* Fix seperate

* Fix load

* Fix load

* Fix test

* Update pom.xml

* Print tree

* use zip instead

* Fix test
 2023-04-11 15:14:48 +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
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 741b7854af
Revert "feat: change default mode (#11653)" (#11973) 
This reverts commit feaa530589.
 2023-03-30 19:20:08 +08:00
Mengyang Tang e54494024a
Provider side payload checking (#11885) 
* Provider side payload checking

* Optimize judgment conditions and reduce useless calculations

* bugfix
 2023-03-28 16:43:13 +08:00
Albumen Kevin 27f18c5c53 Merge branch 'apache-3.1' into apache-3.2 2023-03-24 20:23:37 +08:00
Albumen Kevin 7b1199a98e
Reject if response do not match any request (#11882) 2023-03-24 18:15:51 +08:00
aamingaa feaa530589
feat: change default mode (#11653) 2023-03-22 13:25:15 +08:00
Mengyang Tang c8e7ef7892
1. Fix HeaderExchangeChannel close potential bug (#11834) 
2. 'channel != null' must be satisfied, simplify hashCode and equals
 2023-03-16 09:44:53 +08:00
Albumen Kevin d7113006ca Merge branch 'apache-3.1' into apache-3.2 2023-03-06 19:50:19 +08:00
Mengyang Tang a21d04255a
Fix issue 11708 (#11714) 2023-03-06 15:26:15 +08:00
Mengyang Tang a293e7e7c8
Implement service-level payload (#11517) 2023-03-02 20:14:01 +08:00
Albumen Kevin 32ada2487d
Fix heartbeat failed if serialization changed (#11512) 
fixes #11268
 2023-02-27 20:31:00 +08:00
尔等同学 7e51047cb0
delete never thrown exception (#11674) 2023-02-27 20:09:15 +08:00