Skip to content

Adding Close selector to prevent FD/FIFO leaks #3707

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 12 commits into from
Closed

Adding Close selector to prevent FD/FIFO leaks #3707

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
178b94b
Close selector
shvo123 Jan 2, 2022
d78baf4
Make sure selector is null after closing it
shvo123 Jan 3, 2022
d3f94ec
make sure selector is closed to prevent FD leak
shvo123 Jan 3, 2022
5ffda69
Close ChannelOutputStream and its selector prevent leaks
shvo123 Jan 3, 2022
7794f3a
Make sure selector is closed to prevent FD/pipes leak
shvo123 Jan 3, 2022
71341c2
Make sure OutputStream is closed to avoid FD leak
shvo123 Jan 3, 2022
409b3b1
Close selector
shvo123 Jan 4, 2022
4428d41
prevent FD leak by closing ChannelOutputStreamre and its selector
shvo123 Jan 4, 2022
7b80ef3
style correction
shvo123 Jan 4, 2022
9175d0e
Removing flush, ChannelOutputStream.close() throws exception
shvo123 Jan 4, 2022
e7703ff
Remove redundant catch clause and redundant file
shvo123 Jan 4, 2022
76a166f
Make sure internal output stream would close even if selector.close()…
shvo123 Jan 5, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions ...-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -662,6 +662,7 @@ protected synchronized void doWrite(ByteBuffer buffer) throws IOException {
TcpNioConnection.this.socketChannel.write(buffer);
remaining = buffer.remaining();
}
selector.close();
}

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is wrong: every member (even last method) of the class has to be surrounded with blank lines.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

not sure where this empty line is missing

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just bring it back and push!
It is not a problem though: we can clean it up on merge.
Just letting you to know what is our code style: https://github.com/spring-projects/spring-integration/wiki/Spring-Integration-Framework-Code-Style !

}
Expand Down