RDMAChannel add isWritable API 2019/5/24 18:23

Tjcug · May 24, 2019 · 0eb09f4 · 0eb09f4
1 parent 78a4094
commit 0eb09f4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rdmachannel-core/src/main/java/com/basic/rdmachannel/channel/RdmaChannel.java b/rdmachannel-core/src/main/java/com/basic/rdmachannel/channel/RdmaChannel.java
@@ -1203,6 +1203,9 @@ public void stop() throws InterruptedException, IOException {
     public boolean isConnected() { return rdmaChannelState.get() == RdmaChannelState.CONNECTED.ordinal(); }
     public boolean isError() { return rdmaChannelState.get() == RdmaChannelState.ERROR.ordinal(); }
 
+    public boolean isWritable(){
+        return sendBudgetSemaphore.availablePermits()>0;
+    }
     @Override
     public String toString() {
         String str ="";