From 63aa2f017cec07586e140f1e562025c64543f608 Mon Sep 17 00:00:00 2001 From: vanitasvitae Date: Mon, 3 Jul 2017 10:13:00 +0200 Subject: [PATCH] Fallback works like a charm --- .../jivesoftware/smackx/jingle_filetransfer/ReceiveTask.java | 5 +++-- .../jivesoftware/smackx/jingle_filetransfer/SendTask.java | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/ReceiveTask.java b/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/ReceiveTask.java index a64a1d956..9d5ed0acd 100644 --- a/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/ReceiveTask.java +++ b/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/ReceiveTask.java @@ -55,13 +55,14 @@ public class ReceiveTask implements Runnable { byte[] filebuf = new byte[transfer.getSize()]; int read = 0; - byte[] bufbuf = new byte[2048]; - LOGGER.log(Level.INFO, "Begin receiving."); + byte[] bufbuf = new byte[4096]; + LOGGER.log(Level.INFO, "Begin receiving bytes."); while (read < filebuf.length) { int r = inputStream.read(bufbuf); if (r >= 0) { System.arraycopy(bufbuf, 0, filebuf, read, r); read += r; + LOGGER.log(Level.INFO, "Read " + r + " (" + read + " of " + filebuf.length + ") bytes."); } else { break; } diff --git a/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/SendTask.java b/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/SendTask.java index cdf52bc31..81dd63964 100644 --- a/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/SendTask.java +++ b/smack-experimental/src/main/java/org/jivesoftware/smackx/jingle_filetransfer/SendTask.java @@ -58,6 +58,7 @@ public class SendTask implements Runnable { LOGGER.log(Level.INFO, "WRITE"); outputStream.write(filebuf); + outputStream.flush(); LOGGER.log(Level.INFO, "WRITING FINISHED"); } catch (IOException e) { @@ -70,7 +71,6 @@ public class SendTask implements Runnable { inputStream.close(); LOGGER.log(Level.INFO, "InputStream closed."); } - } catch (IOException e) { LOGGER.log(Level.SEVERE, "Could not close session.", e); }