DXR is a code search and navigation tool aimed at making sense of large projects. It supports full-text and regex searches as well as structural queries.

Header

Mercurial (5b81998bb7ab)

VCS Links

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "gfxReusableSurfaceWrapper.h"
#include "gfxImageSurface.h"
#include "pratom.h"

gfxReusableSurfaceWrapper::gfxReusableSurfaceWrapper(gfxImageSurface* aSurface)
  : mSurface(aSurface)
  , mFormat(aSurface->Format())
  , mSurfaceData(aSurface->Data())
  , mReadCount(0)
{
  MOZ_COUNT_CTOR(gfxReusableSurfaceWrapper);
}

gfxReusableSurfaceWrapper::~gfxReusableSurfaceWrapper()
{
  NS_ABORT_IF_FALSE(mReadCount == 0, "Should not be locked when released");
  MOZ_COUNT_DTOR(gfxReusableSurfaceWrapper);
  if (!NS_IsMainThread()) {
    class DeleteImageOnMainThread : public nsRunnable {
    public:
      DeleteImageOnMainThread(gfxImageSurface *aImage)
        : mImage(aImage)
      {}

      NS_IMETHOD Run()
      {
        return NS_OK;
      }
    private:
      nsRefPtr<gfxImageSurface> mImage;
    };
    NS_DispatchToMainThread(new DeleteImageOnMainThread(mSurface));
  }
}

void
gfxReusableSurfaceWrapper::ReadLock()
{
  NS_CheckThreadSafe(_mOwningThread.GetThread(), "Only the owner thread can call ReadOnlyLock");
  PR_ATOMIC_INCREMENT(&mReadCount);
}

void
gfxReusableSurfaceWrapper::ReadUnlock()
{
  PR_ATOMIC_DECREMENT(&mReadCount);
  NS_ABORT_IF_FALSE(mReadCount >= 0, "Should not be negative");
}

gfxReusableSurfaceWrapper*
gfxReusableSurfaceWrapper::GetWritable(gfxImageSurface** aSurface)
{
  NS_CheckThreadSafe(_mOwningThread.GetThread(), "Only the owner thread can call GetWritable");

  if (mReadCount == 0) {
    *aSurface = mSurface;
    return this;
  }

  // Something else is reading the surface, copy it
  gfxImageSurface* copySurface = new gfxImageSurface(mSurface->GetSize(), mSurface->Format(), false);
  copySurface->CopyFrom(mSurface);
  *aSurface = copySurface;

  // We need to create a new wrapper since this wrapper has a read only lock.
  gfxReusableSurfaceWrapper* wrapper = new gfxReusableSurfaceWrapper(copySurface);
  return wrapper;
}