Skip to content

Commit

Permalink
Netty connector hang up after repeated buffer overflow errors when wr…
Browse files Browse the repository at this point in the history
…iting data #5753 (#5755)

Signed-off-by: Jorge Bescos Gascon <[email protected]>
  • Loading branch information
jbescos authored Oct 4, 2024
1 parent 683d924 commit 4ba355a
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright (c) 2016, 2019 Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2016, 2024 Oracle and/or its affiliates. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0, which is available at
Expand Down Expand Up @@ -208,10 +208,12 @@ private void write(Provider<ByteBuffer> bufferSupplier) throws IOException {
try {
boolean queued = queue.offer(bufferSupplier.get(), WRITE_TIMEOUT, TimeUnit.MILLISECONDS);
if (!queued) {
close();
throw new IOException("Buffer overflow.");
}

} catch (InterruptedException e) {
close();
throw new IOException(e);
}
}
Expand Down

0 comments on commit 4ba355a

Please sign in to comment.