lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ClientConnection

Browse Source
This commit is contained in:
redkale
2024-08-16 16:45:55 +08:00
parent 86ea5f8cb9
commit e1a88ef5d9
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/redkale/net/client/ClientConnection.java
View File

@@ -66,12 +66,12 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
} }
}; };
final AtomicBoolean pauseWriting = new AtomicBoolean(); protected final AtomicBoolean pauseWriting = new AtomicBoolean();
final ConcurrentLinkedQueue<ClientFuture> pauseRequests = new ConcurrentLinkedQueue<>(); final ConcurrentLinkedQueue<ClientFuture> pauseRequests = new ConcurrentLinkedQueue<>();
// pauseWriting=true，此字段才会有值; pauseWriting=false，此字段值为null // pauseWriting=true，此字段才会有值; pauseWriting=false，此字段值为null
ClientFuture currHalfWriteFuture; protected ClientFuture currHalfWriteFuture;
@Nonnull @Nonnull
private Client.AddressConnEntry connEntry; private Client.AddressConnEntry connEntry;
@@ -151,7 +151,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
return respFuture; return respFuture;
} }
private void sendRequestInLocking(R request, ClientFuture respFuture) { protected void sendRequestInLocking(R request, ClientFuture respFuture) {
// 发送请求数据包 // 发送请求数据包
writeArray.clear(); writeArray.clear();
request.writeTo(this, writeArray); request.writeTo(this, writeArray);
@@ -209,7 +209,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
return Utility.allOfFutures(respFutures); return Utility.allOfFutures(respFutures);
} }
private void sendRequestInLocking(ClientFuture[] respFutures) { protected void sendRequestInLocking(ClientFuture[] respFutures) {
// 发送请求数据包 // 发送请求数据包
writeArray.clear(); writeArray.clear();
for (ClientFuture respFuture : respFutures) { for (ClientFuture respFuture : respFutures) {