[GitHub] flink pull request #5423: [FLINK-8581] Improve performance for low latency n...

[StefanRRichter]

Github user StefanRRichter commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5423#discussion_r167879211
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
 ---
    @@ -220,6 +273,19 @@ private void writeAndFlushNextMessageIfPossible(final 
Channel channel) throws IO
                }
        }
     
    +   private void registerAvailableReader(NetworkSequenceViewReader reader) {
    +           availableReaders.add(reader);
    +           reader.setRegisteredAsAvailable(true);
    +   }
    +
    +   private NetworkSequenceViewReader poolAvailableReader() {
    --- End diff --
    
    This should probably be `pollAvailableReader()`


---