PageContentRepository.java revision 99a82437ed8e0537d9a355a124d2bb30aea46ad8
1/*
2 * Copyright (C) 2014 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 *      http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17package com.android.printspooler.model;
18
19import android.app.ActivityManager;
20import android.content.ComponentName;
21import android.content.Context;
22import android.content.Intent;
23import android.content.ServiceConnection;
24import android.graphics.Bitmap;
25import android.graphics.Color;
26import android.graphics.drawable.BitmapDrawable;
27import android.net.Uri;
28import android.os.AsyncTask;
29import android.os.IBinder;
30import android.os.ParcelFileDescriptor;
31import android.os.RemoteException;
32import android.print.PrintAttributes;
33import android.print.PrintAttributes.MediaSize;
34import android.print.PrintAttributes.Margins;
35import android.print.PrintDocumentInfo;
36import android.util.ArrayMap;
37import android.util.Log;
38import android.view.View;
39import com.android.internal.annotations.GuardedBy;
40import com.android.printspooler.renderer.IPdfRenderer;
41import com.android.printspooler.renderer.PdfManipulationService;
42import com.android.printspooler.util.BitmapSerializeUtils;
43import dalvik.system.CloseGuard;
44import libcore.io.IoUtils;
45
46import java.io.IOException;
47import java.util.Iterator;
48import java.util.LinkedHashMap;
49import java.util.Map;
50
51public final class PageContentRepository {
52    private static final String LOG_TAG = "PageContentRepository";
53
54    private static final boolean DEBUG = false;
55
56    private static final int INVALID_PAGE_INDEX = -1;
57
58    private static final int STATE_CLOSED = 0;
59    private static final int STATE_OPENED = 1;
60    private static final int STATE_DESTROYED = 2;
61
62    private static final int BYTES_PER_PIXEL = 4;
63
64    private static final int BYTES_PER_MEGABYTE = 1048576;
65
66    private final CloseGuard mCloseGuard = CloseGuard.get();
67
68    private final AsyncRenderer mRenderer;
69
70    private RenderSpec mLastRenderSpec;
71
72    private int mScheduledPreloadFirstShownPage = INVALID_PAGE_INDEX;
73    private int mScheduledPreloadLastShownPage = INVALID_PAGE_INDEX;
74
75    private int mState;
76
77    public interface OnPageContentAvailableCallback {
78        public void onPageContentAvailable(BitmapDrawable content);
79    }
80
81    public interface OnMalformedPdfFileListener {
82        public void onMalformedPdfFile();
83    }
84
85    public PageContentRepository(Context context,
86            OnMalformedPdfFileListener malformedPdfFileListener) {
87        mRenderer = new AsyncRenderer(context, malformedPdfFileListener);
88        mState = STATE_CLOSED;
89        if (DEBUG) {
90            Log.i(LOG_TAG, "STATE_CLOSED");
91        }
92        mCloseGuard.open("destroy");
93    }
94
95    public void open(ParcelFileDescriptor source, final Runnable callback) {
96        throwIfNotClosed();
97        mState = STATE_OPENED;
98        if (DEBUG) {
99            Log.i(LOG_TAG, "STATE_OPENED");
100        }
101        mRenderer.open(source, callback);
102    }
103
104    public void close(Runnable callback) {
105        throwIfNotOpened();
106        mState = STATE_CLOSED;
107        if (DEBUG) {
108            Log.i(LOG_TAG, "STATE_CLOSED");
109        }
110
111        mRenderer.close(callback);
112    }
113
114    public void destroy(Runnable callback) {
115        throwIfNotClosed();
116        mState = STATE_DESTROYED;
117        if (DEBUG) {
118            Log.i(LOG_TAG, "STATE_DESTROYED");
119        }
120        doDestroy(callback);
121    }
122
123    public void startPreload(int firstShownPage, int lastShownPage) {
124        // If we do not have a render spec we have no clue what size the
125        // preloaded bitmaps should be, so just take a note for what to do.
126        if (mLastRenderSpec == null) {
127            mScheduledPreloadFirstShownPage = firstShownPage;
128            mScheduledPreloadLastShownPage = lastShownPage;
129        } else if (mState == STATE_OPENED) {
130            mRenderer.startPreload(firstShownPage, lastShownPage, mLastRenderSpec);
131        }
132    }
133
134    public void stopPreload() {
135        mRenderer.stopPreload();
136    }
137
138    public int getFilePageCount() {
139        return mRenderer.getPageCount();
140    }
141
142    public PageContentProvider acquirePageContentProvider(int pageIndex, View owner) {
143        throwIfDestroyed();
144
145        if (DEBUG) {
146            Log.i(LOG_TAG, "Acquiring provider for page: " + pageIndex);
147        }
148
149        return new PageContentProvider(pageIndex, owner);
150    }
151
152    public void releasePageContentProvider(PageContentProvider provider) {
153        throwIfDestroyed();
154
155        if (DEBUG) {
156            Log.i(LOG_TAG, "Releasing provider for page: " + provider.mPageIndex);
157        }
158
159        provider.cancelLoad();
160    }
161
162    @Override
163    protected void finalize() throws Throwable {
164        try {
165            if (mState != STATE_DESTROYED) {
166                mCloseGuard.warnIfOpen();
167                doDestroy(null);
168            }
169        } finally {
170            super.finalize();
171        }
172    }
173
174    private void doDestroy(Runnable callback) {
175        mState = STATE_DESTROYED;
176        if (DEBUG) {
177            Log.i(LOG_TAG, "STATE_DESTROYED");
178        }
179        mRenderer.destroy(callback);
180    }
181
182    private void throwIfNotOpened() {
183        if (mState != STATE_OPENED) {
184            throw new IllegalStateException("Not opened");
185        }
186    }
187
188    private void throwIfNotClosed() {
189        if (mState != STATE_CLOSED) {
190            throw new IllegalStateException("Not closed");
191        }
192    }
193
194    private void throwIfDestroyed() {
195        if (mState == STATE_DESTROYED) {
196            throw new IllegalStateException("Destroyed");
197        }
198    }
199
200    public final class PageContentProvider {
201        private final int mPageIndex;
202        private View mOwner;
203
204        public PageContentProvider(int pageIndex, View owner) {
205            mPageIndex = pageIndex;
206            mOwner = owner;
207        }
208
209        public View getOwner() {
210            return mOwner;
211        }
212
213        public int getPageIndex() {
214            return mPageIndex;
215        }
216
217        public void getPageContent(RenderSpec renderSpec, OnPageContentAvailableCallback callback) {
218            throwIfDestroyed();
219
220            mLastRenderSpec = renderSpec;
221
222            // We tired to preload but didn't know the bitmap size, now
223            // that we know let us do the work.
224            if (mScheduledPreloadFirstShownPage != INVALID_PAGE_INDEX
225                    && mScheduledPreloadLastShownPage != INVALID_PAGE_INDEX) {
226                startPreload(mScheduledPreloadFirstShownPage, mScheduledPreloadLastShownPage);
227                mScheduledPreloadFirstShownPage = INVALID_PAGE_INDEX;
228                mScheduledPreloadLastShownPage = INVALID_PAGE_INDEX;
229            }
230
231            if (mState == STATE_OPENED) {
232                mRenderer.renderPage(mPageIndex, renderSpec, callback);
233            } else {
234                mRenderer.getCachedPage(mPageIndex, renderSpec, callback);
235            }
236        }
237
238        void cancelLoad() {
239            throwIfDestroyed();
240
241            if (mState == STATE_OPENED) {
242                mRenderer.cancelRendering(mPageIndex);
243            }
244        }
245    }
246
247    private static final class PageContentLruCache {
248        private final LinkedHashMap<Integer, RenderedPage> mRenderedPages =
249                new LinkedHashMap<>();
250
251        private final int mMaxSizeInBytes;
252
253        private int mSizeInBytes;
254
255        public PageContentLruCache(int maxSizeInBytes) {
256            mMaxSizeInBytes = maxSizeInBytes;
257        }
258
259        public RenderedPage getRenderedPage(int pageIndex) {
260            return mRenderedPages.get(pageIndex);
261        }
262
263        public RenderedPage removeRenderedPage(int pageIndex) {
264            RenderedPage page = mRenderedPages.remove(pageIndex);
265            if (page != null) {
266                mSizeInBytes -= page.getSizeInBytes();
267            }
268            return page;
269        }
270
271        public RenderedPage putRenderedPage(int pageIndex, RenderedPage renderedPage) {
272            RenderedPage oldRenderedPage = mRenderedPages.remove(pageIndex);
273            if (oldRenderedPage != null) {
274                if (!oldRenderedPage.renderSpec.equals(renderedPage.renderSpec)) {
275                    throw new IllegalStateException("Wrong page size");
276                }
277            } else {
278                final int contentSizeInBytes = renderedPage.getSizeInBytes();
279                if (mSizeInBytes + contentSizeInBytes > mMaxSizeInBytes) {
280                    throw new IllegalStateException("Client didn't free space");
281                }
282
283                mSizeInBytes += contentSizeInBytes;
284            }
285            return mRenderedPages.put(pageIndex, renderedPage);
286        }
287
288        public void invalidate() {
289            for (Map.Entry<Integer, RenderedPage> entry : mRenderedPages.entrySet()) {
290                entry.getValue().state = RenderedPage.STATE_SCRAP;
291            }
292        }
293
294        public RenderedPage removeLeastNeeded() {
295            if (mRenderedPages.isEmpty()) {
296                return null;
297            }
298
299            // First try to remove a rendered page that holds invalidated
300            // or incomplete content, i.e. its render spec is null.
301            for (Map.Entry<Integer, RenderedPage> entry : mRenderedPages.entrySet()) {
302                RenderedPage renderedPage = entry.getValue();
303                if (renderedPage.state == RenderedPage.STATE_SCRAP) {
304                    Integer pageIndex = entry.getKey();
305                    mRenderedPages.remove(pageIndex);
306                    mSizeInBytes -= renderedPage.getSizeInBytes();
307                    return renderedPage;
308                }
309            }
310
311            // If all rendered pages contain rendered content, then use the oldest.
312            final int pageIndex = mRenderedPages.eldest().getKey();
313            RenderedPage renderedPage = mRenderedPages.remove(pageIndex);
314            mSizeInBytes -= renderedPage.getSizeInBytes();
315            return renderedPage;
316        }
317
318        public int getSizeInBytes() {
319            return mSizeInBytes;
320        }
321
322        public int getMaxSizeInBytes() {
323            return mMaxSizeInBytes;
324        }
325
326        public void clear() {
327            Iterator<Map.Entry<Integer, RenderedPage>> iterator =
328                    mRenderedPages.entrySet().iterator();
329            while (iterator.hasNext()) {
330                iterator.next();
331                iterator.remove();
332            }
333        }
334    }
335
336    public static final class RenderSpec {
337        final int bitmapWidth;
338        final int bitmapHeight;
339        final PrintAttributes printAttributes = new PrintAttributes.Builder().build();
340
341        public RenderSpec(int bitmapWidth, int bitmapHeight,
342                MediaSize mediaSize, Margins minMargins) {
343            this.bitmapWidth = bitmapWidth;
344            this.bitmapHeight = bitmapHeight;
345            printAttributes.setMediaSize(mediaSize);
346            printAttributes.setMinMargins(minMargins);
347        }
348
349        @Override
350        public boolean equals(Object obj) {
351            if (this == obj) {
352                return true;
353            }
354            if (obj == null) {
355                return false;
356            }
357            if (getClass() != obj.getClass()) {
358                return false;
359            }
360            RenderSpec other = (RenderSpec) obj;
361            if (bitmapHeight != other.bitmapHeight) {
362                return false;
363            }
364            if (bitmapWidth != other.bitmapWidth) {
365                return false;
366            }
367            if (printAttributes != null) {
368                if (!printAttributes.equals(other.printAttributes)) {
369                    return false;
370                }
371            } else if (other.printAttributes != null) {
372                return false;
373            }
374            return true;
375        }
376
377        public boolean hasSameSize(RenderedPage page) {
378            Bitmap bitmap = page.content.getBitmap();
379            return bitmap.getWidth() == bitmapWidth
380                    && bitmap.getHeight() == bitmapHeight;
381        }
382
383        @Override
384        public int hashCode() {
385            int result = bitmapWidth;
386            result = 31 * result + bitmapHeight;
387            result = 31 * result + (printAttributes != null ? printAttributes.hashCode() : 0);
388            return result;
389        }
390    }
391
392    private static final class RenderedPage {
393        public static final int STATE_RENDERED = 0;
394        public static final int STATE_RENDERING = 1;
395        public static final int STATE_SCRAP = 2;
396
397        final BitmapDrawable content;
398        RenderSpec renderSpec;
399
400        int state = STATE_SCRAP;
401
402        RenderedPage(BitmapDrawable content) {
403            this.content = content;
404        }
405
406        public int getSizeInBytes() {
407            return content.getBitmap().getByteCount();
408        }
409
410        public void erase() {
411            content.getBitmap().eraseColor(Color.WHITE);
412        }
413    }
414
415    private static final class AsyncRenderer implements ServiceConnection {
416        private final Object mLock = new Object();
417
418        private final Context mContext;
419
420        private final PageContentLruCache mPageContentCache;
421
422        private final ArrayMap<Integer, RenderPageTask> mPageToRenderTaskMap = new ArrayMap<>();
423
424        private final OnMalformedPdfFileListener mOnMalformedPdfFileListener;
425
426        private int mPageCount = PrintDocumentInfo.PAGE_COUNT_UNKNOWN;
427
428        @GuardedBy("mLock")
429        private IPdfRenderer mRenderer;
430
431        private boolean mBoundToService;
432
433        public AsyncRenderer(Context context, OnMalformedPdfFileListener malformedPdfFileListener) {
434            mContext = context;
435            mOnMalformedPdfFileListener = malformedPdfFileListener;
436
437            ActivityManager activityManager = (ActivityManager)
438                    mContext.getSystemService(Context.ACTIVITY_SERVICE);
439            final int cacheSizeInBytes = activityManager.getMemoryClass() * BYTES_PER_MEGABYTE / 4;
440            mPageContentCache = new PageContentLruCache(cacheSizeInBytes);
441        }
442
443        @Override
444        public void onServiceConnected(ComponentName name, IBinder service) {
445            mBoundToService = true;
446            synchronized (mLock) {
447                mRenderer = IPdfRenderer.Stub.asInterface(service);
448                mLock.notifyAll();
449            }
450        }
451
452        @Override
453        public void onServiceDisconnected(ComponentName name) {
454            synchronized (mLock) {
455                mRenderer = null;
456            }
457        }
458
459        public void open(final ParcelFileDescriptor source, final Runnable callback) {
460            // Opening a new document invalidates the cache as it has pages
461            // from the last document. We keep the cache even when the document
462            // is closed to show pages while the other side is writing the new
463            // document.
464            mPageContentCache.invalidate();
465
466            new AsyncTask<Void, Void, Integer>() {
467                @Override
468                protected void onPreExecute() {
469                    Intent intent = new Intent(PdfManipulationService.ACTION_GET_RENDERER);
470                    intent.setClass(mContext, PdfManipulationService.class);
471                    intent.setData(Uri.fromParts("fake-scheme", String.valueOf(hashCode()), null));
472                    mContext.bindService(intent, AsyncRenderer.this, Context.BIND_AUTO_CREATE);
473                }
474
475                @Override
476                protected Integer doInBackground(Void... params) {
477                    synchronized (mLock) {
478                        while (mRenderer == null) {
479                            try {
480                                mLock.wait();
481                            } catch (InterruptedException ie) {
482                                /* ignore */
483                            }
484                        }
485                        try {
486                            return mRenderer.openDocument(source);
487                        } catch (RemoteException re) {
488                            Log.e(LOG_TAG, "Cannot open PDF document");
489                            return PdfManipulationService.MALFORMED_PDF_FILE_ERROR;
490                        } finally {
491                            // Close the fd as we passed it to another process
492                            // which took ownership.
493                            IoUtils.closeQuietly(source);
494                        }
495                    }
496                }
497
498                @Override
499                public void onPostExecute(Integer pageCount) {
500                    if (pageCount == PdfManipulationService.MALFORMED_PDF_FILE_ERROR) {
501                        mOnMalformedPdfFileListener.onMalformedPdfFile();
502                        mPageCount = PrintDocumentInfo.PAGE_COUNT_UNKNOWN;
503                    } else {
504                        mPageCount = pageCount;
505                    }
506                    if (callback != null) {
507                        callback.run();
508                    }
509                }
510            }.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
511        }
512
513        public void close(final Runnable callback) {
514            cancelAllRendering();
515
516            new AsyncTask<Void, Void, Void>() {
517                @Override
518                protected Void doInBackground(Void... params) {
519                    synchronized (mLock) {
520                        try {
521                            mRenderer.closeDocument();
522                        } catch (RemoteException re) {
523                            /* ignore */
524                        }
525                    }
526                    return null;
527                }
528
529                @Override
530                public void onPostExecute(Void result) {
531                    mPageCount = PrintDocumentInfo.PAGE_COUNT_UNKNOWN;
532                    if (callback != null) {
533                        callback.run();
534                    }
535                }
536            }.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
537        }
538
539        public void destroy(final Runnable callback) {
540            new AsyncTask<Void, Void, Void>() {
541                @Override
542                protected Void doInBackground(Void... params) {
543                    return null;
544                }
545
546                @Override
547                public void onPostExecute(Void result) {
548                    if (mBoundToService) {
549                        mBoundToService = false;
550                        mContext.unbindService(AsyncRenderer.this);
551                    }
552                    mPageContentCache.invalidate();
553                    mPageContentCache.clear();
554                    if (callback != null) {
555                        callback.run();
556                    }
557
558                }
559            }.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
560        }
561
562        public void startPreload(int firstShownPage, int lastShownPage, RenderSpec renderSpec) {
563            if (DEBUG) {
564                Log.i(LOG_TAG, "Preloading pages around [" + firstShownPage
565                        + "-" + lastShownPage + "]");
566            }
567
568            final int bitmapSizeInBytes = renderSpec.bitmapWidth * renderSpec.bitmapHeight
569                    * BYTES_PER_PIXEL;
570            final int maxCachedPageCount = mPageContentCache.getMaxSizeInBytes()
571                    / bitmapSizeInBytes;
572            final int halfPreloadCount = (maxCachedPageCount
573                    - (lastShownPage - firstShownPage)) / 2 - 1;
574
575            final int excessFromStart;
576            if (firstShownPage - halfPreloadCount < 0) {
577                excessFromStart = halfPreloadCount - firstShownPage;
578            } else {
579                excessFromStart = 0;
580            }
581
582            final int excessFromEnd;
583            if (lastShownPage + halfPreloadCount >= mPageCount) {
584                excessFromEnd = (lastShownPage + halfPreloadCount) - mPageCount;
585            } else {
586                excessFromEnd = 0;
587            }
588
589            final int fromIndex = Math.max(firstShownPage - halfPreloadCount - excessFromEnd, 0);
590            final int toIndex = Math.min(lastShownPage + halfPreloadCount + excessFromStart,
591                    mPageCount - 1);
592
593            for (int i = fromIndex; i <= toIndex; i++) {
594                renderPage(i, renderSpec, null);
595            }
596        }
597
598        public void stopPreload() {
599            final int taskCount = mPageToRenderTaskMap.size();
600            for (int i = 0; i < taskCount; i++) {
601                RenderPageTask task = mPageToRenderTaskMap.valueAt(i);
602                if (task.isPreload() && !task.isCancelled()) {
603                    task.cancel(true);
604                }
605            }
606        }
607
608        public int getPageCount() {
609            return mPageCount;
610        }
611
612        public void getCachedPage(int pageIndex, RenderSpec renderSpec,
613                OnPageContentAvailableCallback callback) {
614            RenderedPage renderedPage = mPageContentCache.getRenderedPage(pageIndex);
615            if (renderedPage != null && renderedPage.state == RenderedPage.STATE_RENDERED
616                    && renderedPage.renderSpec.equals(renderSpec)) {
617                if (DEBUG) {
618                    Log.i(LOG_TAG, "Cache hit for page: " + pageIndex);
619                }
620
621                // Announce if needed.
622                if (callback != null) {
623                    callback.onPageContentAvailable(renderedPage.content);
624                }
625            }
626        }
627
628        public void renderPage(int pageIndex, RenderSpec renderSpec,
629                OnPageContentAvailableCallback callback) {
630            // First, check if we have a rendered page for this index.
631            RenderedPage renderedPage = mPageContentCache.getRenderedPage(pageIndex);
632            if (renderedPage != null && renderedPage.state == RenderedPage.STATE_RENDERED) {
633                // If we have rendered page with same constraints - done.
634                if (renderedPage.renderSpec.equals(renderSpec)) {
635                    if (DEBUG) {
636                        Log.i(LOG_TAG, "Cache hit for page: " + pageIndex);
637                    }
638
639                    // Announce if needed.
640                    if (callback != null) {
641                        callback.onPageContentAvailable(renderedPage.content);
642                    }
643                    return;
644                } else {
645                    // If the constraints changed, mark the page obsolete.
646                    renderedPage.state = RenderedPage.STATE_SCRAP;
647                }
648            }
649
650            // Next, check if rendering this page is scheduled.
651            RenderPageTask renderTask = mPageToRenderTaskMap.get(pageIndex);
652            if (renderTask != null && !renderTask.isCancelled()) {
653                // If not rendered and constraints same....
654                if (renderTask.mRenderSpec.equals(renderSpec)) {
655                    if (renderTask.mCallback != null) {
656                        // If someone else is already waiting for this page - bad state.
657                        if (callback != null && renderTask.mCallback != callback) {
658                            throw new IllegalStateException("Page rendering not cancelled");
659                        }
660                    } else {
661                        // No callback means we are preloading so just let the argument
662                        // callback be attached to our work in progress.
663                        renderTask.mCallback = callback;
664                    }
665                    return;
666                } else {
667                    // If not rendered and constraints changed - cancel rendering.
668                    renderTask.cancel(true);
669                }
670            }
671
672            // Oh well, we will have work to do...
673            renderTask = new RenderPageTask(pageIndex, renderSpec, callback);
674            mPageToRenderTaskMap.put(pageIndex, renderTask);
675            renderTask.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
676        }
677
678        public void cancelRendering(int pageIndex) {
679            RenderPageTask task = mPageToRenderTaskMap.get(pageIndex);
680            if (task != null && !task.isCancelled()) {
681                task.cancel(true);
682            }
683        }
684
685        private void cancelAllRendering() {
686            final int taskCount = mPageToRenderTaskMap.size();
687            for (int i = 0; i < taskCount; i++) {
688                RenderPageTask task = mPageToRenderTaskMap.valueAt(i);
689                if (!task.isCancelled()) {
690                    task.cancel(true);
691                }
692            }
693        }
694
695        private final class RenderPageTask extends AsyncTask<Void, Void, RenderedPage> {
696            final int mPageIndex;
697            final RenderSpec mRenderSpec;
698            OnPageContentAvailableCallback mCallback;
699            RenderedPage mRenderedPage;
700
701            public RenderPageTask(int pageIndex, RenderSpec renderSpec,
702                    OnPageContentAvailableCallback callback) {
703                mPageIndex = pageIndex;
704                mRenderSpec = renderSpec;
705                mCallback = callback;
706            }
707
708            @Override
709            protected void onPreExecute() {
710                mRenderedPage = mPageContentCache.getRenderedPage(mPageIndex);
711                if (mRenderedPage != null && mRenderedPage.state == RenderedPage.STATE_RENDERED) {
712                    throw new IllegalStateException("Trying to render a rendered page");
713                }
714
715                // Reuse bitmap for the page only if the right size.
716                if (mRenderedPage != null && !mRenderSpec.hasSameSize(mRenderedPage)) {
717                    if (DEBUG) {
718                        Log.i(LOG_TAG, "Recycling bitmap for page: " + mPageIndex
719                                + " with different size.");
720                    }
721                    mPageContentCache.removeRenderedPage(mPageIndex);
722                    mRenderedPage = null;
723                }
724
725                final int bitmapSizeInBytes = mRenderSpec.bitmapWidth
726                        * mRenderSpec.bitmapHeight * BYTES_PER_PIXEL;
727
728                // Try to find a bitmap to reuse.
729                while (mRenderedPage == null) {
730
731                    // Fill the cache greedily.
732                    if (mPageContentCache.getSizeInBytes() <= 0
733                            || mPageContentCache.getSizeInBytes() + bitmapSizeInBytes
734                            <= mPageContentCache.getMaxSizeInBytes()) {
735                        break;
736                    }
737
738                    RenderedPage renderedPage = mPageContentCache.removeLeastNeeded();
739
740                    if (!mRenderSpec.hasSameSize(renderedPage)) {
741                        if (DEBUG) {
742                            Log.i(LOG_TAG, "Recycling bitmap for page: " + mPageIndex
743                                   + " with different size.");
744                        }
745                        continue;
746                    }
747
748                    mRenderedPage = renderedPage;
749                    renderedPage.erase();
750
751                    if (DEBUG) {
752                        Log.i(LOG_TAG, "Reused bitmap for page: " + mPageIndex + " cache size: "
753                                + mPageContentCache.getSizeInBytes() + " bytes");
754                    }
755
756                    break;
757                }
758
759                if (mRenderedPage == null) {
760                    if (DEBUG) {
761                        Log.i(LOG_TAG, "Created bitmap for page: " + mPageIndex + " cache size: "
762                                + mPageContentCache.getSizeInBytes() + " bytes");
763                    }
764                    Bitmap bitmap = Bitmap.createBitmap(mRenderSpec.bitmapWidth,
765                            mRenderSpec.bitmapHeight, Bitmap.Config.ARGB_8888);
766                    bitmap.eraseColor(Color.WHITE);
767                    BitmapDrawable content = new BitmapDrawable(mContext.getResources(), bitmap);
768                    mRenderedPage = new RenderedPage(content);
769                }
770
771                mRenderedPage.renderSpec = mRenderSpec;
772                mRenderedPage.state = RenderedPage.STATE_RENDERING;
773
774                mPageContentCache.putRenderedPage(mPageIndex, mRenderedPage);
775            }
776
777            @Override
778            protected RenderedPage doInBackground(Void... params) {
779                if (isCancelled()) {
780                    return mRenderedPage;
781                }
782
783                Bitmap bitmap = mRenderedPage.content.getBitmap();
784
785                ParcelFileDescriptor[] pipe = null;
786                try {
787                    pipe = ParcelFileDescriptor.createPipe();
788                    ParcelFileDescriptor source = pipe[0];
789                    ParcelFileDescriptor destination = pipe[1];
790
791                    mRenderer.renderPage(mPageIndex, bitmap.getWidth(), bitmap.getHeight(),
792                            mRenderSpec.printAttributes, destination);
793
794                    // We passed the file descriptor to the other side which took
795                    // ownership, so close our copy for the write to complete.
796                    destination.close();
797
798                    BitmapSerializeUtils.readBitmapPixels(bitmap, source);
799                } catch (IOException|RemoteException e) {
800                    Log.e(LOG_TAG, "Error rendering page:" + mPageIndex, e);
801                } finally {
802                    IoUtils.closeQuietly(pipe[0]);
803                    IoUtils.closeQuietly(pipe[1]);
804                }
805
806                return mRenderedPage;
807            }
808
809            @Override
810            public void onPostExecute(RenderedPage renderedPage) {
811                if (DEBUG) {
812                    Log.i(LOG_TAG, "Completed rendering page: " + mPageIndex);
813                }
814
815                // This task is done.
816                mPageToRenderTaskMap.remove(mPageIndex);
817
818                // Take a note that the content is rendered.
819                renderedPage.state = RenderedPage.STATE_RENDERED;
820
821                // Announce success if needed.
822                if (mCallback != null) {
823                    mCallback.onPageContentAvailable(renderedPage.content);
824                }
825            }
826
827            @Override
828            protected void onCancelled(RenderedPage renderedPage) {
829                if (DEBUG) {
830                    Log.i(LOG_TAG, "Cancelled rendering page: " + mPageIndex);
831                }
832
833                // This task is done.
834                mPageToRenderTaskMap.remove(mPageIndex);
835
836                // If canceled before on pre-execute.
837                if (renderedPage == null) {
838                    return;
839                }
840
841                // Take a note that the content is not rendered.
842                renderedPage.state = RenderedPage.STATE_SCRAP;
843            }
844
845            public boolean isPreload() {
846                return mCallback == null;
847            }
848        }
849    }
850}
851