| Index: tests/DataRefTest.cpp
|
| diff --git a/tests/DataRefTest.cpp b/tests/DataRefTest.cpp
|
| index 4bfbff4638278080d2081a3157216ce997ec1739..002abcbe894a816301db7383c17adb79d10a9880 100644
|
| --- a/tests/DataRefTest.cpp
|
| +++ b/tests/DataRefTest.cpp
|
| @@ -245,7 +245,7 @@
|
| }
|
| }
|
|
|
| -// stream should contain an integral number of copies of gABC.
|
| +// stream should contains an integral number of copies of gABC.
|
| static void check_alphabet_stream(skiatest::Reporter* reporter, SkStream* stream) {
|
| REPORTER_ASSERT(reporter, stream->hasLength());
|
| size_t size = stream->getLength();
|
| @@ -284,8 +284,6 @@
|
| check_abcs(reporter, storage.get(), size);
|
| }
|
|
|
| -#include "SkTaskGroup.h"
|
| -
|
| DEF_TEST(RWBuffer, reporter) {
|
| // Knowing that the default capacity is 4096, choose N large enough so we force it to use
|
| // multiple buffers internally.
|
| @@ -294,31 +292,17 @@
|
| SkStream* streams[N];
|
|
|
| {
|
| - SkTaskGroup tasks;
|
| SkRWBuffer buffer;
|
| for (int i = 0; i < N; ++i) {
|
| buffer.append(gABC, 26);
|
| readers[i] = buffer.newRBufferSnapshot();
|
| streams[i] = buffer.newStreamSnapshot();
|
| - REPORTER_ASSERT(reporter, readers[i]->size() == buffer.size());
|
| - REPORTER_ASSERT(reporter, streams[i]->getLength() == buffer.size());
|
| -
|
| - tasks.add([reporter, i, &readers, &streams] {
|
| - REPORTER_ASSERT(reporter, (i + 1) * 26U == readers[i]->size());
|
| - REPORTER_ASSERT(reporter, streams[i]->getLength() == readers[i]->size());
|
| - check_alphabet_buffer(reporter, readers[i]);
|
| - check_alphabet_stream(reporter, streams[i]);
|
| - REPORTER_ASSERT(reporter, streams[i]->rewind());
|
| - });
|
| }
|
| REPORTER_ASSERT(reporter, N*26 == buffer.size());
|
| - tasks.wait();
|
| - }
|
| -
|
| - // Test again, to verify that the snapshots work even after the SkRWBuffer is gone.
|
| + }
|
| +
|
| for (int i = 0; i < N; ++i) {
|
| REPORTER_ASSERT(reporter, (i + 1) * 26U == readers[i]->size());
|
| - REPORTER_ASSERT(reporter, streams[i]->getLength() == readers[i]->size());
|
| check_alphabet_buffer(reporter, readers[i]);
|
| check_alphabet_stream(reporter, streams[i]);
|
| readers[i]->unref();
|
| @@ -341,27 +325,9 @@
|
| REPORTER_ASSERT(r, 0 == iter.size());
|
| }
|
|
|
| -// Tests that operations (including the destructor) are safe on an SkRWBuffer
|
| -// without any data appended.
|
| +// Tests that it is safe to destruct an SkRWBuffer without appending
|
| +// anything to it.
|
| DEF_TEST(RWBuffer_noAppend, r) {
|
| SkRWBuffer buffer;
|
| REPORTER_ASSERT(r, 0 == buffer.size());
|
| -
|
| - sk_sp<SkROBuffer> roBuffer = sk_sp<SkROBuffer>(buffer.newRBufferSnapshot());
|
| - REPORTER_ASSERT(r, roBuffer);
|
| - if (roBuffer) {
|
| - REPORTER_ASSERT(r, roBuffer->size() == 0);
|
| - SkROBuffer::Iter iter(roBuffer.get());
|
| - REPORTER_ASSERT(r, iter.size() == 0);
|
| - REPORTER_ASSERT(r, !iter.data());
|
| - REPORTER_ASSERT(r, !iter.next());
|
| - }
|
| -
|
| - SkAutoTDelete<SkStream> stream(buffer.newStreamSnapshot());
|
| - REPORTER_ASSERT(r, stream);
|
| - if (stream) {
|
| - REPORTER_ASSERT(r, stream->hasLength());
|
| - REPORTER_ASSERT(r, stream->getLength() == 0);
|
| - REPORTER_ASSERT(r, stream->skip(10) == 0);
|
| - }
|
| -}
|
| +}
|
|
|