Method run

src/main/java/io/file/transfer/TransferTask.java:373–579

()

    }

    public void run() {
        if (state == IN_ASK) {
            try {
                file = FileIO.createConnection(filePath + fileName);
                os = file.openOutputStream();
            } catch (Exception e) {
                decline();
                return;
            }

            JabberDataBlock accept = new Iq(jid.toString(), Iq.TYPE_RESULT, id);

            JabberDataBlock si = accept.addChildNs("si", TransferDispatcher.NS_SI);

            JabberDataBlock feature = si.addChildNs("feature", "http://jabber.org/protocol/feature-neg");

            JabberDataBlock x = feature.addChildNs("x", DiscoForm.NS_XDATA);
            x.setTypeAttribute("submit");

            JabberDataBlock field = x.addChild("field", null);
            field.setAttribute("var", "stream-method");
            field.addChild("value", method);

            TransferDispatcher.getInstance().send(accept, false);

            state = HANDSHAKE;
            return;

        }
        if (method.equals(TransferDispatcher.NS_IBB)) {
            byte buf[] = new byte[2048];
            int seq = 0;
            try {
                while (true) {
                    int sz = readFile(buf);
                    if (sz == 0) {
                        break;
                    }
                    JabberDataBlock msg = new Message(jid.toString());

                    JabberDataBlock data = msg.addChildNs("data", TransferDispatcher.NS_IBB);
                    data.setAttribute("sid", sid);
                    data.setAttribute("seq", String.valueOf(seq));
                    seq++;
                    data.setText(Strconv.toBase64(buf, sz));

                    JabberDataBlock amp = msg.addChildNs("amp", "http://jabber.org/protocol/amp");

                    JabberDataBlock rule;

                    rule = amp.addChild("rule", null);
                    rule.setAttribute("condition", "deliver-at");
                    rule.setAttribute("value", "stored");
                    rule.setAttribute("action", "error");

                    rule = amp.addChild("rule", null);
                    rule.setAttribute("condition", "match-resource");
                    rule.setAttribute("value", "exact");