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

Commit 8861ef2c authored by Sudheer Shanka's avatar Sudheer Shanka Committed by Automerger Merge Worker
Browse files

Merge "Maintain the fuse buffer pool keyed by inode instead of threadId." into... 

Merge "Maintain the fuse buffer pool keyed by inode instead of threadId." into rvc-dev am: b52a288e

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/11885304

Change-Id: I14a9b532835122e41408aeccc4319eb9e7441514
parents 83c67df9 b52a288e

core/java/com/android/internal/os/FuseAppLoop.java

+9 −9
Original line number Diff line number Diff line
@@ -210,7 +210,7 @@ public class FuseAppLoop implements Handler.Callback { 
                        if (mInstance != 0) {

                            native_replySimple(mInstance, unique, FUSE_OK);

                        }

                        mBytesMap.stopUsing(entry.getThreadId());

                        mBytesMap.stopUsing(inode);

                        recycleLocked(args);

                    }

                    break;
@@ -270,7 +270,7 @@ public class FuseAppLoop implements Handler.Callback { 
                if (mInstance != 0) {

                    native_replyOpen(mInstance, unique, /* fh */ inode);

                    entry.opened = true;

                    return mBytesMap.startUsing(entry.getThreadId());

                    return mBytesMap.startUsing(inode);

                }

            } catch (ErrnoException error) {

                replySimpleLocked(unique, getError(error));
@@ -354,27 +354,27 @@ public class FuseAppLoop implements Handler.Callback { 
    }



    /**

     * Map between Thread ID and byte buffer.

     * Map between inode and byte buffer.

     */

    private static class BytesMap {

        final Map<Long, BytesMapEntry> mEntries = new HashMap<>();



        byte[] startUsing(long threadId) {

            BytesMapEntry entry = mEntries.get(threadId);

        byte[] startUsing(long inode) {

            BytesMapEntry entry = mEntries.get(inode);

            if (entry == null) {

                entry = new BytesMapEntry();

                mEntries.put(threadId, entry);

                mEntries.put(inode, entry);

            }

            entry.counter++;

            return entry.bytes;

        }



        void stopUsing(long threadId) {

            final BytesMapEntry entry = mEntries.get(threadId);

        void stopUsing(long inode) {

            final BytesMapEntry entry = mEntries.get(inode);

            Objects.requireNonNull(entry);

            entry.counter--;

            if (entry.counter <= 0) {

                mEntries.remove(threadId);

                mEntries.remove(inode);

            }

        }