Quellcode

public boolean append(String serverPath, String string) throws IOException, Exception
    {
        
              
        StringBufferInputStream infile = new StringBufferInputStream(string);
        
        boolean success = executeDataCommand("APPE " + serverPath, infile);
        infile.close();
        return success;
        
    }

Quellcode

public boolean executeDataCommand(String command, InputStream in)
        throws IOException
    {
        // Open a data socket on this computer
        ServerSocket serverSocket = new ServerSocket(0);
        if (!setupDataPort(command, serverSocket))
        {System.out.println("Here is the problem");return false;}
        Socket clientSocket = serverSocket.accept();

        // Transfer the data
        OutputStream out = clientSocket.getOutputStream();
        transferData(in, out);

        // Clean up the data structures
        out.close();
        clientSocket.close();
        serverSocket.close();

        return isSuccessfullResponse(getServerResponseCode());    
    }

Quellcode

private boolean setupDataPort(String command, ServerSocket server) throws IOException
    {
        
        if(! openPort(server)) return false;
        outStream.println("type i");
        if(! isSuccessfullResponse(getServerResponseCode()))
        {
            error("Could not set Transfer type");
            return false;
        }
        
        outStream.println(command);
        int i = getServerResponseCode();
        System.out.println(i);
        return isInformationalResponse(i);
    }

Quellcode

private boolean openPort(ServerSocket server) throws IOException
    {
        int localport = server.getLocalPort();
        
        InetAddress inetaddress = server.getInetAddress();
        InetAddress localip;
        
        try
        {
            localip = inetaddress.getLocalHost();
        }
        catch(UnknownHostException e)
        {
            error("Can't get local host");
            return false;
        }
        
        byte[] addrbytes = localip.getAddress();
        short addrshorts[] = new short[4];
        for(int i=0; i<=3; i++)
        {
            addrshorts[i] = addrbytes[i];
            if(addrshorts[i] < 0)
                addrshorts[i] += 256;
        }
        
        outStream.println("port "+addrshorts[0]+","+addrshorts[1]+","+addrshorts[2]+","+addrshorts[3]+","+((localport & 0xff00) >> 8) + "," + (localport & 0x00ff));
        
        return isSuccessfullResponse(getServerResponseCode());
        
    }

Quellcode

private void transferData(InputStream in, OutputStream out) throws IOException
    {
        byte b[] = new byte[4096];
        int amount;
        while((amount = in.read(b)) > 0)
            out.write(b, 0, amount);
    }