opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 05:46:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #4751] Optimize NettyRemotingAbstract#processRequestCommand code

Browse Source
This commit is contained in:
mxsm
2022-08-04 08:49:44 +08:00
committed by GitHub
parent c6b3a66ecf
commit 83f64a8b4d
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+2 -3
View File
@@ -110,7 +110,7 @@ public abstract class NettyRemotingAbstract {
* Constructor, specifying capacity of one-way and asynchronous semaphores.
*
* @param permitsOneway Number of permits for one-way requests.
* @param permitsAsync Number of permits for asynchronous requests.
* @param permitsAsync Number of permits for asynchronous requests.
*/
public NettyRemotingAbstract(final int permitsOneway, final int permitsAsync) {
this.semaphoreOneway = new Semaphore(permitsOneway, true);
@@ -210,8 +210,7 @@ public abstract class NettyRemotingAbstract {
if (exception == null) {
response = pair.getObject1().processRequest(ctx, cmd);
} else {
response = RemotingCommand.createResponseCommand(null);
response.setCode(RemotingSysResponseCode.SYSTEM_ERROR);
response = RemotingCommand.createResponseCommand(RemotingSysResponseCode.SYSTEM_ERROR, null);
}
try {