Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 17473255 authored by Ian Kasprzak's avatar Ian Kasprzak Committed by android-build-merger
Browse files

Merge "Revert "Remove a misleading "flush" function.""

am: 952f8ae2

Change-Id: Ic6fafd4ed9bf6dfc001120dced903b14cf907d1d
parents 04ccf9da 952f8ae2
Loading
Loading
Loading
Loading
+12 −0
Original line number Original line Diff line number Diff line
@@ -75,4 +75,16 @@ import java.io.OutputStream;
        }
        }
        mSocket.write(b, offset, count);
        mSocket.write(b, offset, count);
    }
    }

    /**
     * Wait until the data in sending queue is emptied. A polling version
     * for flush implementation. Use it to ensure the writing data afterwards will
     * be packed in the new RFCOMM frame.
     *
     * @throws IOException if an i/o error occurs.
     * @since Android 4.2.3
     */
    public void flush() throws IOException {
        mSocket.flush();
    }
}
}
+14 −0
Original line number Original line Diff line number Diff line
@@ -515,6 +515,20 @@ public final class BluetoothSocket implements Closeable {
        return mSocketIS.available();
        return mSocketIS.available();
    }
    }


    /**
     * Wait until the data in sending queue is emptied. A polling version
     * for flush implementation. Used to ensure the writing data afterwards will
     * be packed in new RFCOMM frame.
     *
     * @throws IOException if an i/o error occurs.
     */
    @UnsupportedAppUsage
    /*package*/ void flush() throws IOException {
        if (mSocketOS == null) throw new IOException("flush is called on null OutputStream");
        if (VDBG) Log.d(TAG, "flush: " + mSocketOS);
        mSocketOS.flush();
    }

    /*package*/ int read(byte[] b, int offset, int length) throws IOException {
    /*package*/ int read(byte[] b, int offset, int length) throws IOException {
        int ret = 0;
        int ret = 0;
        if (VDBG) Log.d(TAG, "read in:  " + mSocketIS + " len: " + length);
        if (VDBG) Log.d(TAG, "read in:  " + mSocketIS + " len: " + length);