This is an automated email from the ASF dual-hosted git repository. ggregory pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/commons-net.git
commit 1a4e54ce63e73c92850fcd6fca69b7bd46fe7bf4 Author: Gary D. Gregory <garydgreg...@gmail.com> AuthorDate: Sun Feb 16 11:13:21 2025 -0500 Use String.join() - Use Java style, not C - Reduce vertical whitespace --- src/main/java/org/apache/commons/net/ftp/FTP.java | 33 ++-------------------- .../apache/commons/net/ftp/FTPListParseEngine.java | 2 -- 2 files changed, 3 insertions(+), 32 deletions(-) diff --git a/src/main/java/org/apache/commons/net/ftp/FTP.java b/src/main/java/org/apache/commons/net/ftp/FTP.java index 68cdd738..4f87dde1 100644 --- a/src/main/java/org/apache/commons/net/ftp/FTP.java +++ b/src/main/java/org/apache/commons/net/ftp/FTP.java @@ -518,17 +518,13 @@ public class FTP extends SocketClient { public int eprt(final InetAddress host, final int port) throws IOException { final int num; final StringBuilder info = new StringBuilder(); - String h; - // If IPv6, trim the zone index - h = host.getHostAddress(); + String h = host.getHostAddress(); num = h.indexOf('%'); if (num > 0) { h = h.substring(0, num); } - info.append("|"); - if (host instanceof Inet4Address) { info.append("1"); } else if (host instanceof Inet6Address) { @@ -539,7 +535,6 @@ public class FTP extends SocketClient { info.append("|"); info.append(port); info.append("|"); - return sendCommand(FTPCmd.EPRT, info.toString()); } @@ -603,23 +598,18 @@ public class FTP extends SocketClient { private int getReply(final boolean reportReply) throws IOException { final int length; - _newReplyString = true; _replyLines.clear(); - String line = _controlInput_.readLine(); - if (line == null) { throw new FTPConnectionClosedException("Connection closed without indication."); } - // In case we run into an anomaly we don't want fatal index exceptions // to be thrown. length = line.length(); if (length < REPLY_CODE_LEN) { throw new MalformedServerReplyException("Truncated server reply: " + line); } - String code; try { code = line.substring(0, REPLY_CODE_LEN); @@ -627,9 +617,7 @@ public class FTP extends SocketClient { } catch (final NumberFormatException e) { throw new MalformedServerReplyException("Could not parse response code.\nServer Reply: " + line); } - _replyLines.add(line); - // Check the server reply type if (length > REPLY_CODE_LEN) { final char sep = line.charAt(REPLY_CODE_LEN); @@ -637,18 +625,14 @@ public class FTP extends SocketClient { if (sep == '-') { do { line = _controlInput_.readLine(); - if (line == null) { throw new FTPConnectionClosedException("Connection closed without indication."); } - _replyLines.add(line); - // The length() check handles problems that could arise from readLine() // returning too soon after encountering a naked CR or some other // anomaly. } while (isStrictMultilineParsing() ? strictCheck(line, code) : lenientCheck(line)); - } else if (isStrictReplyParsing()) { if (length == REPLY_CODE_LEN + 1) { // expecting some text throw new MalformedServerReplyException("Truncated server reply: '" + line + "'"); @@ -660,11 +644,9 @@ public class FTP extends SocketClient { } else if (isStrictReplyParsing()) { throw new MalformedServerReplyException("Truncated server reply: '" + line + "'"); } - if (reportReply) { fireReplyReceived(_replyCode, getReplyString()); } - if (_replyCode == FTPReply.SERVICE_NOT_AVAILABLE) { throw new FTPConnectionClosedException("FTP response 421 received. Server closed connection."); } @@ -690,13 +672,8 @@ public class FTP extends SocketClient { if (!_newReplyString) { return _replyString; } - final StringBuilder buffer = new StringBuilder(256); - for (final String line : _replyLines) { - buffer.append(line); - buffer.append(NETASCII_EOL); - } _newReplyString = false; - return _replyString = buffer.toString(); + return _replyString = String.join(NETASCII_EOL, _replyLines); } /** @@ -1027,17 +1004,14 @@ public class FTP extends SocketClient { * @throws IOException If an I/O error occurs while either sending the command or receiving the server reply. */ public int port(final InetAddress host, final int port) throws IOException { - int num; final StringBuilder info = new StringBuilder(24); - info.append(host.getHostAddress().replace('.', ',')); - num = port >>> 8; + int num = port >>> 8; info.append(','); info.append(num); info.append(','); num = port & 0xff; info.append(num); - return sendCommand(FTPCmd.PORT, info.toString()); } @@ -1489,7 +1463,6 @@ public class FTP extends SocketClient { } else { arg.append(modeCharAt(formatOrByteSize)); } - return sendCommand(FTPCmd.TYPE, arg.toString()); } diff --git a/src/main/java/org/apache/commons/net/ftp/FTPListParseEngine.java b/src/main/java/org/apache/commons/net/ftp/FTPListParseEngine.java index 95041e3f..a947fdaa 100644 --- a/src/main/java/org/apache/commons/net/ftp/FTPListParseEngine.java +++ b/src/main/java/org/apache/commons/net/ftp/FTPListParseEngine.java @@ -241,9 +241,7 @@ public class FTPListParseEngine { */ private void read(final InputStream inputStream, final String charsetName) throws IOException { try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, Charsets.toCharset(charsetName)))) { - String line = parser.readNextEntry(reader); - while (line != null) { entries.add(line); line = parser.readNextEntry(reader);