You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by zhijiangW <gi...@git.apache.org> on 2017/10/02 12:04:47 UTC
[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r142120202
--- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java ---
@@ -131,6 +136,63 @@ public void recycle(MemorySegment segment) {
availableMemorySegments.add(segment);
}
+ public List<MemorySegment> requestMemorySegments(int numRequiredBuffers) throws IOException {
+ checkArgument(numRequiredBuffers > 0, "The number of required buffers should be larger than 0.");
+
+ synchronized (factoryLock) {
+ if (isDestroyed) {
+ throw new IllegalStateException("Network buffer pool has already been destroyed.");
+ }
+
+ if (numTotalRequiredBuffers + numRequiredBuffers > totalNumberOfMemorySegments) {
+ throw new IOException(String.format("Insufficient number of network buffers: " +
--- End diff --
yes, I think it can be addressed in a separate JIRA. :)
---