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
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/390223051): Remove C-library calls to fix the errors.
#pragma allow_unsafe_libc_calls
#endif
#include "storage/browser/test/fake_blob_data_handle.h"
#include "base/containers/span.h"
#include "base/functional/bind.h"
#include "base/numerics/safe_conversions.h"
#include "net/base/net_errors.h"
namespace storage {
FakeBlobDataHandle::FakeBlobDataHandle(std::string body_data,
std::string side_data)
: body_data_(std::move(body_data)), side_data_(std::move(side_data)) {}
uint64_t FakeBlobDataHandle::GetSize() const {
return body_data_.size();
}
void FakeBlobDataHandle::Read(mojo::ScopedDataPipeProducerHandle producer,
uint64_t src_offset,
uint64_t bytes_to_read,
base::OnceCallback<void(int)> callback) {
if (src_offset >= body_data_.size()) {
std::move(callback).Run(net::ERR_FAILED);
return;
}
base::span<const uint8_t> bytes = base::as_byte_span(body_data_);
bytes = bytes.subspan(static_cast<size_t>(src_offset));
bytes = bytes.first(base::checked_cast<size_t>(bytes_to_read));
MojoResult result = producer->WriteAllData(bytes);
// This should all succeed.
DCHECK_EQ(MOJO_RESULT_OK, result);
// The callback expects a `net::Error` only and not the number of bytes read.
std::move(callback).Run(net::OK);
}
uint64_t FakeBlobDataHandle::GetSideDataSize() const {
return side_data_.size();
}
void FakeBlobDataHandle::ReadSideData(
base::OnceCallback<void(int, mojo_base::BigBuffer)> callback) {
if (side_data_.size() == 0) {
std::move(callback).Run(side_data_.size(), mojo_base::BigBuffer());
return;
}
mojo_base::BigBuffer buffer(side_data_.size());
memcpy(buffer.data(), side_data_.data(), side_data_.size());
std::move(callback).Run(side_data_.size(), std::move(buffer));
}
FakeBlobDataHandle::~FakeBlobDataHandle() = default;
} // namespace storage
|
