diff options
author | reed <reed@google.com> | 2016-09-13 17:25:19 -0700 |
---|---|---|
committer | Commit bot <commit-bot@chromium.org> | 2016-09-13 17:25:19 -0700 |
commit | 7e3ba9f88d64d901243799b61f497319e5970693 (patch) | |
tree | da3ffd0aa8b6c67bd46c0cc16c881bf1e503143c /src/pipe | |
parent | 21cc9950c4b4eb183c315c7d417e36342a9f1cf9 (diff) |
change write-image to use pipeverbs like everyone else, and add test
BUG=skia:
GOLD_TRYBOT_URL= https://gold.skia.org/search?issue=2335973003
Review-Url: https://codereview.chromium.org/2335973003
Diffstat (limited to 'src/pipe')
-rw-r--r-- | src/pipe/SkPipeCanvas.cpp | 11 | ||||
-rw-r--r-- | src/pipe/SkPipeCanvas.h | 5 | ||||
-rw-r--r-- | src/pipe/SkPipeFormat.h | 2 | ||||
-rw-r--r-- | src/pipe/SkPipeReader.cpp | 33 |
4 files changed, 35 insertions, 16 deletions
diff --git a/src/pipe/SkPipeCanvas.cpp b/src/pipe/SkPipeCanvas.cpp index 062d416537..97c31ce57e 100644 --- a/src/pipe/SkPipeCanvas.cpp +++ b/src/pipe/SkPipeCanvas.cpp @@ -1037,9 +1037,13 @@ void SkPipeSerializer::write(SkPicture* picture, SkWStream* stream) { } void SkPipeSerializer::write(SkImage* image, SkWStream* stream) { - stream->write32(kDefineImage_ExtPipeVerb); - SkPipeWriter writer(stream, &fImpl->fDeduper); - writer.writeImage(image); + int index = fImpl->fDeduper.findImage(image); + if (0 == index) { + // Try to define the image + fImpl->fDeduper.setStream(stream); + index = fImpl->fDeduper.findOrDefineImage(image); + } + stream->write32(pack_verb(SkPipeVerb::kWriteImage, index)); } SkCanvas* SkPipeSerializer::beginWrite(const SkRect& cull, SkWStream* stream) { @@ -1053,4 +1057,5 @@ SkCanvas* SkPipeSerializer::beginWrite(const SkRect& cull, SkWStream* stream) { void SkPipeSerializer::endWrite() { fImpl->fCanvas->restoreToCount(1); fImpl->fCanvas.reset(nullptr); + fImpl->fDeduper.setCanvas(nullptr); } diff --git a/src/pipe/SkPipeCanvas.h b/src/pipe/SkPipeCanvas.h index 25353c922f..8dbb83fe20 100644 --- a/src/pipe/SkPipeCanvas.h +++ b/src/pipe/SkPipeCanvas.h @@ -23,7 +23,7 @@ public: void reset() { fArray.reset(); } // returns the found index or 0 - int find(const T& key) { + int find(const T& key) const { const Rec* stop = fArray.end(); for (const Rec* curr = fArray.begin(); curr < stop; ++curr) { if (key == curr->fKey) { @@ -64,6 +64,9 @@ public: void setStream(SkWStream* stream) { fStream = stream; } void setTypefaceSerializer(SkTypefaceSerializer* tfs) { fTFSerializer = tfs; } + // returns 0 if not found + int findImage(SkImage* image) const { return fImages.find(image->uniqueID()); } + int findOrDefineImage(SkImage*) override; int findOrDefinePicture(SkPicture*) override; int findOrDefineTypeface(SkTypeface*) override; diff --git a/src/pipe/SkPipeFormat.h b/src/pipe/SkPipeFormat.h index f521657a7c..539d385fab 100644 --- a/src/pipe/SkPipeFormat.h +++ b/src/pipe/SkPipeFormat.h @@ -11,7 +11,6 @@ #include "SkTypes.h" #define kDefinePicture_ExtPipeVerb SkSetFourByteTag('s', 'k', 'p', 'i') -#define kDefineImage_ExtPipeVerb SkSetFourByteTag('s', 'k', 'i', 'm') enum class SkPipeVerb : uint8_t { kSave, // extra == 0 @@ -57,6 +56,7 @@ enum class SkPipeVerb : uint8_t { kDefineFactory, // extra == factory_index (followed by padded getTypeName string) kDefinePicture, // extra == 0 or forget_index + 1 (0 means we're defining a new picture) kEndPicture, // extra == picture_index + kWriteImage, // extra == image_index }; enum PaintUsage { diff --git a/src/pipe/SkPipeReader.cpp b/src/pipe/SkPipeReader.cpp index d4375486d0..2edc2dff20 100644 --- a/src/pipe/SkPipeReader.cpp +++ b/src/pipe/SkPipeReader.cpp @@ -689,7 +689,7 @@ static sk_sp<SkImage> make_from_encoded(const sk_sp<SkData>& data) { return image; } -static void defineImage_handler(SkPipeReader& reader, uint32_t packedVerb, SkCanvas* canvas) { +static void defineImage_handler(SkPipeReader& reader, uint32_t packedVerb, SkCanvas*) { SkASSERT(SkPipeVerb::kDefineImage == unpack_verb(packedVerb)); SkPipeInflator* inflator = (SkPipeInflator*)reader.getInflator(); uint32_t extra = unpack_verb_extra(packedVerb); @@ -867,21 +867,32 @@ sk_sp<SkPicture> SkPipeDeserializer::readPicture(const void* data, size_t size) sk_sp<SkImage> SkPipeDeserializer::readImage(const void* data, size_t size) { if (size < sizeof(uint32_t)) { + SkDebugf("-------- data length too short for readImage %d\n", size); return nullptr; } - uint32_t header; - memcpy(&header, data, 4); size -= 4; data = (const char*)data + 4; - if (kDefineImage_ExtPipeVerb != header) { + const uint32_t* ptr = (const uint32_t*)data; + uint32_t packedVerb = *ptr++; + size -= 4; + + if (SkPipeVerb::kDefineImage == unpack_verb(packedVerb)) { + SkPipeInflator inflator(&fImpl->fImages, &fImpl->fPictures, + &fImpl->fTypefaces, &fImpl->fFactories, + fImpl->fTFDeserializer); + SkPipeReader reader(this, ptr, size); + reader.setInflator(&inflator); + defineImage_handler(reader, packedVerb, nullptr); + packedVerb = reader.read32(); // read the next verb + } + if (SkPipeVerb::kWriteImage != unpack_verb(packedVerb)) { + SkDebugf("-------- unexpected verb for readImage %d\n", unpack_verb(packedVerb)); return nullptr; } - - SkPipeInflator inflator(&fImpl->fImages, &fImpl->fPictures, - &fImpl->fTypefaces, &fImpl->fFactories, - fImpl->fTFDeserializer); - SkPipeReader reader(this, data, size); - reader.setInflator(&inflator); - return sk_sp<SkImage>(reader.readImage()); + int index = unpack_verb_extra(packedVerb); + if (0 == index) { + return nullptr; // writer failed + } + return sk_ref_sp(fImpl->fImages.get(index - 1)); } static bool do_playback(SkPipeReader& reader, SkCanvas* canvas, int* endPictureIndex) { |