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

Commit c68b9df8 authored by Daichi Hirono's avatar Daichi Hirono Committed by Android (Google) Code Review
Browse files

Merge "Fix member naming style in PipeManagerTest."

parents 03a09659 84dfb054

packages/MtpDocumentsProvider/tests/src/com/android/mtp/PipeManagerTest.java

+10 −10
Original line number Original line Diff line number Diff line
@@ -31,26 +31,26 @@ public class PipeManagerTest extends AndroidTestCase { 
    private static final byte[] HELLO_BYTES = new byte[] { 'h', 'e', 'l', 'l', 'o' };

    private static final byte[] HELLO_BYTES = new byte[] { 'h', 'e', 'l', 'l', 'o' };





    private TestMtpManager mtpManager;

    private TestMtpManager mtpManager;

    private ExecutorService executor;

    private ExecutorService mExecutor;

    private PipeManager pipeManager;

    private PipeManager mPipeManager;





    @Override

    @Override

    public void setUp() {

    public void setUp() {

        mtpManager = new TestMtpManager(getContext());

        mtpManager = new TestMtpManager(getContext());

        executor = Executors.newSingleThreadExecutor();

        mExecutor = Executors.newSingleThreadExecutor();

        pipeManager = new PipeManager(executor);

        mPipeManager = new PipeManager(mExecutor);

    }

    }





    public void testReadDocument_basic() throws Exception {

    public void testReadDocument_basic() throws Exception {

        mtpManager.setImportFileBytes(0, 1, HELLO_BYTES);

        mtpManager.setImportFileBytes(0, 1, HELLO_BYTES);

        final ParcelFileDescriptor descriptor = pipeManager.readDocument(

        final ParcelFileDescriptor descriptor = mPipeManager.readDocument(

                mtpManager, new Identifier(0, 0, 1));

                mtpManager, new Identifier(0, 0, 1));

        assertDescriptor(descriptor, HELLO_BYTES);

        assertDescriptor(descriptor, HELLO_BYTES);

    }

    }





    public void testReadDocument_error() throws Exception {

    public void testReadDocument_error() throws Exception {

        final ParcelFileDescriptor descriptor =

        final ParcelFileDescriptor descriptor =

                pipeManager.readDocument(mtpManager, new Identifier(0, 0, 1));

                mPipeManager.readDocument(mtpManager, new Identifier(0, 0, 1));

        assertDescriptorError(descriptor);

        assertDescriptorError(descriptor);

    }

    }
@@ -91,20 +91,20 @@ public class PipeManagerTest extends AndroidTestCase { 




    public void testReadThumbnail_basic() throws Exception {

    public void testReadThumbnail_basic() throws Exception {

        mtpManager.setThumbnail(0, 1, HELLO_BYTES);

        mtpManager.setThumbnail(0, 1, HELLO_BYTES);

        final ParcelFileDescriptor descriptor = pipeManager.readThumbnail(

        final ParcelFileDescriptor descriptor = mPipeManager.readThumbnail(

                mtpManager, new Identifier(0, 0, 1));

                mtpManager, new Identifier(0, 0, 1));

        assertDescriptor(descriptor, HELLO_BYTES);

        assertDescriptor(descriptor, HELLO_BYTES);

    }

    }





    public void testReadThumbnail_error() throws Exception {

    public void testReadThumbnail_error() throws Exception {

        final ParcelFileDescriptor descriptor =

        final ParcelFileDescriptor descriptor =

                pipeManager.readThumbnail(mtpManager, new Identifier(0, 0, 1));

                mPipeManager.readThumbnail(mtpManager, new Identifier(0, 0, 1));

        assertDescriptorError(descriptor);

        assertDescriptorError(descriptor);

    }

    }





    private void assertDescriptor(ParcelFileDescriptor descriptor, byte[] expectedBytes)

    private void assertDescriptor(ParcelFileDescriptor descriptor, byte[] expectedBytes)

            throws IOException, InterruptedException {

            throws IOException, InterruptedException {

        executor.awaitTermination(1000, TimeUnit.MILLISECONDS);

        mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS);

        try (final ParcelFileDescriptor.AutoCloseInputStream stream =

        try (final ParcelFileDescriptor.AutoCloseInputStream stream =

                new ParcelFileDescriptor.AutoCloseInputStream(descriptor)) {

                new ParcelFileDescriptor.AutoCloseInputStream(descriptor)) {

            byte[] results = new byte[100];

            byte[] results = new byte[100];
@@ -117,7 +117,7 @@ public class PipeManagerTest extends AndroidTestCase { 




    private void assertDescriptorError(ParcelFileDescriptor descriptor)

    private void assertDescriptorError(ParcelFileDescriptor descriptor)

            throws InterruptedException {

            throws InterruptedException {

        executor.awaitTermination(1000, TimeUnit.MILLISECONDS);

        mExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS);

        try {

        try {

            descriptor.checkError();

            descriptor.checkError();

            fail();

            fail();