1cb93a386Sopenharmony_ci/*
2cb93a386Sopenharmony_ci * Copyright 2011 Google Inc.
3cb93a386Sopenharmony_ci *
4cb93a386Sopenharmony_ci * Use of this source code is governed by a BSD-style license that can be
5cb93a386Sopenharmony_ci * found in the LICENSE file.
6cb93a386Sopenharmony_ci */
7cb93a386Sopenharmony_ci
8cb93a386Sopenharmony_ci#include "include/core/SkData.h"
9cb93a386Sopenharmony_ci#include "include/core/SkStream.h"
10cb93a386Sopenharmony_ci#include "include/private/SkOnce.h"
11cb93a386Sopenharmony_ci#include "src/core/SkOSFile.h"
12cb93a386Sopenharmony_ci#include "src/core/SkReadBuffer.h"
13cb93a386Sopenharmony_ci#include "src/core/SkWriteBuffer.h"
14cb93a386Sopenharmony_ci#include <new>
15cb93a386Sopenharmony_ci
16cb93a386Sopenharmony_ciSkData::SkData(const void* ptr, size_t size, ReleaseProc proc, void* context)
17cb93a386Sopenharmony_ci    : fReleaseProc(proc)
18cb93a386Sopenharmony_ci    , fReleaseProcContext(context)
19cb93a386Sopenharmony_ci    , fPtr(ptr)
20cb93a386Sopenharmony_ci    , fSize(size)
21cb93a386Sopenharmony_ci    , fNativeBuffer(nullptr)
22cb93a386Sopenharmony_ci{}
23cb93a386Sopenharmony_ci
24cb93a386Sopenharmony_ciSkData::SkData(const void* ptr, size_t size, OH_NativeBuffer* nativeBuffer, ReleaseProc proc, void* context)
25cb93a386Sopenharmony_ci    : fReleaseProc(proc)
26cb93a386Sopenharmony_ci    , fReleaseProcContext(context)
27cb93a386Sopenharmony_ci    , fPtr(ptr)
28cb93a386Sopenharmony_ci    , fSize(size)
29cb93a386Sopenharmony_ci    , fNativeBuffer(nativeBuffer)
30cb93a386Sopenharmony_ci{}
31cb93a386Sopenharmony_ci
32cb93a386Sopenharmony_ci/** This constructor means we are inline with our fPtr's contents.
33cb93a386Sopenharmony_ci *  Thus we set fPtr to point right after this.
34cb93a386Sopenharmony_ci */
35cb93a386Sopenharmony_ciSkData::SkData(size_t size)
36cb93a386Sopenharmony_ci    : fReleaseProc(nullptr)
37cb93a386Sopenharmony_ci    , fReleaseProcContext(nullptr)
38cb93a386Sopenharmony_ci    , fPtr((const char*)(this + 1))
39cb93a386Sopenharmony_ci    , fSize(size)
40cb93a386Sopenharmony_ci    , fNativeBuffer(nullptr)
41cb93a386Sopenharmony_ci{}
42cb93a386Sopenharmony_ci
43cb93a386Sopenharmony_ciSkData::~SkData() {
44cb93a386Sopenharmony_ci    if (fReleaseProc) {
45cb93a386Sopenharmony_ci        fReleaseProc(fPtr, fReleaseProcContext);
46cb93a386Sopenharmony_ci    }
47cb93a386Sopenharmony_ci}
48cb93a386Sopenharmony_ci
49cb93a386Sopenharmony_cibool SkData::equals(const SkData* other) const {
50cb93a386Sopenharmony_ci    if (this == other) {
51cb93a386Sopenharmony_ci        return true;
52cb93a386Sopenharmony_ci    }
53cb93a386Sopenharmony_ci    if (nullptr == other) {
54cb93a386Sopenharmony_ci        return false;
55cb93a386Sopenharmony_ci    }
56cb93a386Sopenharmony_ci    return fSize == other->fSize && !sk_careful_memcmp(fPtr, other->fPtr, fSize);
57cb93a386Sopenharmony_ci}
58cb93a386Sopenharmony_ci
59cb93a386Sopenharmony_cisize_t SkData::copyRange(size_t offset, size_t length, void* buffer) const {
60cb93a386Sopenharmony_ci    size_t available = fSize;
61cb93a386Sopenharmony_ci    if (offset >= available || 0 == length) {
62cb93a386Sopenharmony_ci        return 0;
63cb93a386Sopenharmony_ci    }
64cb93a386Sopenharmony_ci    available -= offset;
65cb93a386Sopenharmony_ci    if (length > available) {
66cb93a386Sopenharmony_ci        length = available;
67cb93a386Sopenharmony_ci    }
68cb93a386Sopenharmony_ci    SkASSERT(length > 0);
69cb93a386Sopenharmony_ci
70cb93a386Sopenharmony_ci    memcpy(buffer, this->bytes() + offset, length);
71cb93a386Sopenharmony_ci    return length;
72cb93a386Sopenharmony_ci}
73cb93a386Sopenharmony_ci
74cb93a386Sopenharmony_civoid SkData::operator delete(void* p) {
75cb93a386Sopenharmony_ci    ::operator delete(p);
76cb93a386Sopenharmony_ci}
77cb93a386Sopenharmony_ci
78cb93a386Sopenharmony_cisk_sp<SkData> SkData::PrivateNewWithCopy(const void* srcOrNull, size_t length) {
79cb93a386Sopenharmony_ci    if (0 == length) {
80cb93a386Sopenharmony_ci        return SkData::MakeEmpty();
81cb93a386Sopenharmony_ci    }
82cb93a386Sopenharmony_ci
83cb93a386Sopenharmony_ci    const size_t actualLength = length + sizeof(SkData);
84cb93a386Sopenharmony_ci    SkASSERT_RELEASE(length < actualLength);  // Check for overflow.
85cb93a386Sopenharmony_ci
86cb93a386Sopenharmony_ci    void* storage = ::operator new (actualLength);
87cb93a386Sopenharmony_ci    sk_sp<SkData> data(new (storage) SkData(length));
88cb93a386Sopenharmony_ci    if (srcOrNull) {
89cb93a386Sopenharmony_ci        memcpy(data->writable_data(), srcOrNull, length);
90cb93a386Sopenharmony_ci    }
91cb93a386Sopenharmony_ci    return data;
92cb93a386Sopenharmony_ci}
93cb93a386Sopenharmony_ci
94cb93a386Sopenharmony_civoid SkData::NoopReleaseProc(const void*, void*) {}
95cb93a386Sopenharmony_ci
96cb93a386Sopenharmony_ci///////////////////////////////////////////////////////////////////////////////
97cb93a386Sopenharmony_ci
98cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeEmpty() {
99cb93a386Sopenharmony_ci    static SkOnce once;
100cb93a386Sopenharmony_ci    static SkData* empty;
101cb93a386Sopenharmony_ci
102cb93a386Sopenharmony_ci    once([]{ empty = new SkData(nullptr, 0, nullptr, nullptr); });
103cb93a386Sopenharmony_ci    return sk_ref_sp(empty);
104cb93a386Sopenharmony_ci}
105cb93a386Sopenharmony_ci
106cb93a386Sopenharmony_ci// assumes fPtr was allocated via sk_malloc
107cb93a386Sopenharmony_cistatic void sk_free_releaseproc(const void* ptr, void*) {
108cb93a386Sopenharmony_ci    sk_free((void*)ptr);
109cb93a386Sopenharmony_ci}
110cb93a386Sopenharmony_ci
111cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromMalloc(const void* data, size_t length) {
112cb93a386Sopenharmony_ci    return sk_sp<SkData>(new SkData(data, length, sk_free_releaseproc, nullptr));
113cb93a386Sopenharmony_ci}
114cb93a386Sopenharmony_ci
115cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeWithCopy(const void* src, size_t length) {
116cb93a386Sopenharmony_ci    SkASSERT(src);
117cb93a386Sopenharmony_ci    return PrivateNewWithCopy(src, length);
118cb93a386Sopenharmony_ci}
119cb93a386Sopenharmony_ci
120cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeUninitialized(size_t length) {
121cb93a386Sopenharmony_ci    return PrivateNewWithCopy(nullptr, length);
122cb93a386Sopenharmony_ci}
123cb93a386Sopenharmony_ci
124cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeWithProc(const void* ptr, size_t length, ReleaseProc proc, void* ctx) {
125cb93a386Sopenharmony_ci    return sk_sp<SkData>(new SkData(ptr, length, proc, ctx));
126cb93a386Sopenharmony_ci}
127cb93a386Sopenharmony_ci
128cb93a386Sopenharmony_ci// assumes fPtr was allocated with sk_fmmap
129cb93a386Sopenharmony_cistatic void sk_mmap_releaseproc(const void* addr, void* ctx) {
130cb93a386Sopenharmony_ci    size_t length = reinterpret_cast<size_t>(ctx);
131cb93a386Sopenharmony_ci    sk_fmunmap(addr, length);
132cb93a386Sopenharmony_ci}
133cb93a386Sopenharmony_ci
134cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromFILE(FILE* f) {
135cb93a386Sopenharmony_ci    size_t size;
136cb93a386Sopenharmony_ci    void* addr = sk_fmmap(f, &size);
137cb93a386Sopenharmony_ci    if (nullptr == addr) {
138cb93a386Sopenharmony_ci        return nullptr;
139cb93a386Sopenharmony_ci    }
140cb93a386Sopenharmony_ci
141cb93a386Sopenharmony_ci    return SkData::MakeWithProc(addr, size, sk_mmap_releaseproc, reinterpret_cast<void*>(size));
142cb93a386Sopenharmony_ci}
143cb93a386Sopenharmony_ci
144cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromFileName(const char path[]) {
145cb93a386Sopenharmony_ci    FILE* f = path ? sk_fopen(path, kRead_SkFILE_Flag) : nullptr;
146cb93a386Sopenharmony_ci    if (nullptr == f) {
147cb93a386Sopenharmony_ci        return nullptr;
148cb93a386Sopenharmony_ci    }
149cb93a386Sopenharmony_ci    auto data = MakeFromFILE(f);
150cb93a386Sopenharmony_ci    sk_fclose(f);
151cb93a386Sopenharmony_ci    return data;
152cb93a386Sopenharmony_ci}
153cb93a386Sopenharmony_ci
154cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromFD(int fd) {
155cb93a386Sopenharmony_ci    size_t size;
156cb93a386Sopenharmony_ci    void* addr = sk_fdmmap(fd, &size);
157cb93a386Sopenharmony_ci    if (nullptr == addr) {
158cb93a386Sopenharmony_ci        return nullptr;
159cb93a386Sopenharmony_ci    }
160cb93a386Sopenharmony_ci    return SkData::MakeWithProc(addr, size, sk_mmap_releaseproc, reinterpret_cast<void*>(size));
161cb93a386Sopenharmony_ci}
162cb93a386Sopenharmony_ci
163cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromOHNativeBuffer(OH_NativeBuffer* nativeBuffer, size_t size) {
164cb93a386Sopenharmony_ci    return sk_sp<SkData>(new SkData(nullptr, size, nativeBuffer, nullptr, nullptr));
165cb93a386Sopenharmony_ci}
166cb93a386Sopenharmony_ci
167cb93a386Sopenharmony_ci// assumes context is a SkData
168cb93a386Sopenharmony_cistatic void sk_dataref_releaseproc(const void*, void* context) {
169cb93a386Sopenharmony_ci    SkData* src = reinterpret_cast<SkData*>(context);
170cb93a386Sopenharmony_ci    src->unref();
171cb93a386Sopenharmony_ci}
172cb93a386Sopenharmony_ci
173cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeSubset(const SkData* src, size_t offset, size_t length) {
174cb93a386Sopenharmony_ci    /*
175cb93a386Sopenharmony_ci        We could, if we wanted/need to, just make a deep copy of src's data,
176cb93a386Sopenharmony_ci        rather than referencing it. This would duplicate the storage (of the
177cb93a386Sopenharmony_ci        subset amount) but would possibly allow src to go out of scope sooner.
178cb93a386Sopenharmony_ci     */
179cb93a386Sopenharmony_ci
180cb93a386Sopenharmony_ci    size_t available = src->size();
181cb93a386Sopenharmony_ci    if (offset >= available || 0 == length) {
182cb93a386Sopenharmony_ci        return SkData::MakeEmpty();
183cb93a386Sopenharmony_ci    }
184cb93a386Sopenharmony_ci    available -= offset;
185cb93a386Sopenharmony_ci    if (length > available) {
186cb93a386Sopenharmony_ci        length = available;
187cb93a386Sopenharmony_ci    }
188cb93a386Sopenharmony_ci    SkASSERT(length > 0);
189cb93a386Sopenharmony_ci
190cb93a386Sopenharmony_ci    src->ref(); // this will be balanced in sk_dataref_releaseproc
191cb93a386Sopenharmony_ci    return sk_sp<SkData>(new SkData(src->bytes() + offset, length, sk_dataref_releaseproc,
192cb93a386Sopenharmony_ci                                    const_cast<SkData*>(src)));
193cb93a386Sopenharmony_ci}
194cb93a386Sopenharmony_ci
195cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeWithCString(const char cstr[]) {
196cb93a386Sopenharmony_ci    size_t size;
197cb93a386Sopenharmony_ci    if (nullptr == cstr) {
198cb93a386Sopenharmony_ci        cstr = "";
199cb93a386Sopenharmony_ci        size = 1;
200cb93a386Sopenharmony_ci    } else {
201cb93a386Sopenharmony_ci        size = strlen(cstr) + 1;
202cb93a386Sopenharmony_ci    }
203cb93a386Sopenharmony_ci    return MakeWithCopy(cstr, size);
204cb93a386Sopenharmony_ci}
205cb93a386Sopenharmony_ci
206cb93a386Sopenharmony_ci///////////////////////////////////////////////////////////////////////////////
207cb93a386Sopenharmony_ci
208cb93a386Sopenharmony_cisk_sp<SkData> SkData::MakeFromStream(SkStream* stream, size_t size) {
209cb93a386Sopenharmony_ci    sk_sp<SkData> data(SkData::MakeUninitialized(size));
210cb93a386Sopenharmony_ci    if (stream->read(data->writable_data(), size) != size) {
211cb93a386Sopenharmony_ci        return nullptr;
212cb93a386Sopenharmony_ci    }
213cb93a386Sopenharmony_ci    return data;
214cb93a386Sopenharmony_ci}
215