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 index fd5e54e..f9d5c0d 100644 --- 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 ="";