import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * private method through which all listFiles() and
 * initiateListParsing methods pass once a parser is determined.
 *
 * @exception FTPConnectionClosedException
 *                   If the FTP server prematurely closes the connection as a result
 *                   of the client being idle or some other reason causing the server
 *                   to send FTP reply code 421.  This exception may be caught either
 *                   as an IOException or independently as itself.
 * @exception java.io.IOException
 *                   If an I/O error occurs while either sending a
 *                   command to the server or receiving a reply from the server.
 * @see FTPListParseEngine
 */
private FTPListParseEngine initiateListParsing(
        FTPFileEntryParser parser, String pathname)
throws IOException
{
    Socket socket = _openDataConnection_(FTPCmd.LIST, getListArguments(pathname));

    FTPListParseEngine engine = new FTPListParseEngine(parser);
    if (socket == null)
    {
        return engine;
    }

    try {
        engine.readServerList(socket.getInputStream(), getControlEncoding());
    }
    finally {
        Util.closeQuietly(socket);
    }

    completePendingCommand();
    return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * Initiate list parsing for MLSD listings.
 *
 * @param pathname
 * @return the engine
 * @throws java.io.IOException
 */
private FTPListParseEngine initiateMListParsing(String pathname) throws IOException
{
    Socket socket = _openDataConnection_(FTPCmd.MLSD, pathname);
    FTPListParseEngine engine = new FTPListParseEngine(MLSxEntryParser.getInstance());
    if (socket == null)
    {
        return engine;
    }

    try {
        engine.readServerList(socket.getInputStream(), getControlEncoding());
    }
    finally {
        Util.closeQuietly(socket);
        completePendingCommand();
    }
    return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
private void __initDefaults()
{
    __dataConnectionMode = ACTIVE_LOCAL_DATA_CONNECTION_MODE;
    __passiveHost        = null;
    __passivePort        = -1;
    __activeExternalHost = null;
    __reportActiveExternalHost = null;
    __activeMinPort = 0;
    __activeMaxPort = 0;
    __fileType           = FTP.ASCII_FILE_TYPE;
    __fileStructure      = FTP.FILE_STRUCTURE;
    __fileFormat         = FTP.NON_PRINT_TEXT_FORMAT;
    __fileTransferMode   = FTP.STREAM_TRANSFER_MODE;
    __restartOffset      = 0;
    __systemName         = null;
    __entryParser        = null;
    __entryParserKey    = "";
    __bufferSize         = Util.DEFAULT_COPY_BUFFER_SIZE;
    __featuresMap = null;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * private method through which all listFiles() and
 * initiateListParsing methods pass once a parser is determined.
 *
 * @exception FTPConnectionClosedException
 *                   If the FTP server prematurely closes the connection as a result
 *                   of the client being idle or some other reason causing the server
 *                   to send FTP reply code 421.  This exception may be caught either
 *                   as an IOException or independently as itself.
 * @exception IOException
 *                   If an I/O error occurs while either sending a
 *                   command to the server or receiving a reply from the server.
 * @see FTPListParseEngine
 */
private FTPListParseEngine initiateListParsing(
        FTPFileEntryParser parser, String pathname)
throws IOException
{
    Socket socket = _openDataConnection_(FTPCommand.LIST, getListArguments(pathname));

    FTPListParseEngine engine = new FTPListParseEngine(parser);
    if (socket == null)
    {
        return engine;
    }

    try {
        engine.readServerList(socket.getInputStream(), getControlEncoding());
    }
    finally {
        Util.closeQuietly(socket);
    }

    completePendingCommand();
    return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * Initiate list parsing for MLSD listings.
 *
 * @param pathname
 * @return the engine
 * @throws IOException
 */
private FTPListParseEngine initiateMListParsing(String pathname) throws IOException
{
    Socket socket = _openDataConnection_(FTPCommand.MLSD, pathname);
    FTPListParseEngine engine = new FTPListParseEngine(MLSxEntryParser.getInstance());
    if (socket == null)
    {
        return engine;
    }

    try {
        engine.readServerList(socket.getInputStream(), getControlEncoding());
    }
    finally {
        Util.closeQuietly(socket);
        completePendingCommand();
    }
    return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
private FTPListParseEngine initiateListParsing(FTPFileEntryParser parser, String pathname) throws IOException {
   Socket socket = this._openDataConnection_(26, this.getListArguments(pathname));
   FTPListParseEngine engine = new FTPListParseEngine(parser);
   if(socket == null) {
      return engine;
   } else {
      try {
         engine.readServerList(socket.getInputStream(), this.getControlEncoding());
      } finally {
         Util.closeQuietly(socket);
      }

      this.completePendingCommand();
      return engine;
   }
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
private FTPListParseEngine initiateMListParsing(String pathname) throws IOException {
   Socket socket = this._openDataConnection_(38, pathname);
   FTPListParseEngine engine = new FTPListParseEngine(MLSxEntryParser.getInstance());
   if(socket == null) {
      return engine;
   } else {
      try {
         engine.readServerList(socket.getInputStream(), this.getControlEncoding());
      } finally {
         Util.closeQuietly(socket);
         this.completePendingCommand();
      }

      return engine;
   }
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * private method through which all listFiles() and
 * initiateListParsing methods pass once a parser is determined.
 *
 * @throws FTPConnectionClosedException If the FTP server prematurely closes the connection as a
 * result
 * of the client being idle or some other reason causing the server
 * to send FTP reply code 421.  This exception may be caught either
 * as an IOException or independently as itself.
 * @throws IOException If an I/O error occurs while either sending a
 * command to the server or receiving a reply from the server.
 * @see FTPListParseEngine
 */
private FTPListParseEngine initiateListParsing(FTPFileEntryParser parser, String pathname)
    throws IOException {
  Socket socket = _openDataConnection_(FTPCmd.LIST, getListArguments(pathname));

  FTPListParseEngine engine = new FTPListParseEngine(parser, __configuration);
  if (socket == null) {
    return engine;
  }

  try {
    engine.readServerList(socket.getInputStream(), getControlEncoding());
  } finally {
    Util.closeQuietly(socket);
  }

  completePendingCommand();
  return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * Initiate list parsing for MLSD listings.
 *
 * @return the engine
 * @throws IOException
 */
private FTPListParseEngine initiateMListParsing(String pathname) throws IOException {
  Socket socket = _openDataConnection_(FTPCmd.MLSD, pathname);
  FTPListParseEngine engine =
      new FTPListParseEngine(MLSxEntryParser.getInstance(), __configuration);
  if (socket == null) {
    return engine;
  }

  try {
    engine.readServerList(socket.getInputStream(), getControlEncoding());
  } finally {
    Util.closeQuietly(socket);
    completePendingCommand();
  }
  return engine;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
private static KeyStore loadStore(String storeType, File storePath, String storePass)
    throws KeyStoreException, IOException, GeneralSecurityException {
  KeyStore ks = KeyStore.getInstance(storeType);
  FileInputStream stream = null;
  try {
    stream = new FileInputStream(storePath);
    ks.load(stream, storePass.toCharArray());
  } finally {
    Util.closeQuietly(stream);
  }
  return ks;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
private static KeyStore loadStore(String storeType, File storePath, String storePass)
    throws KeyStoreException,  IOException, GeneralSecurityException {
    KeyStore ks = KeyStore.getInstance(storeType);
    FileInputStream stream = null;
    try {
        stream = new FileInputStream(storePath);
        ks.load(stream, storePass.toCharArray());
    } finally {
        Util.closeQuietly(stream);
    }
    return ks;
}
 

import org.apache.commons.net.io.Util; //导入依赖的package包/类
/**
 * Get the buffer size, with default set to Util.DEFAULT_COPY_BUFFER_SIZE.
 * @return the buffer size.
 */
private int getDefaultedBufferSize() {
    return __bufferSize > 0 ? __bufferSize : Util.DEFAULT_COPY_BUFFER_SIZE;
}