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.
#ifndef THIRD_PARTY_BLINK_RENDERER_MODULES_COMPRESSION_INFLATE_TRANSFORMER_H_
#define THIRD_PARTY_BLINK_RENDERER_MODULES_COMPRESSION_INFLATE_TRANSFORMER_H_
#include "base/types/strong_alias.h"
#include "third_party/blink/renderer/core/streams/transform_stream_transformer.h"
#include "third_party/blink/renderer/core/typed_arrays/dom_typed_array.h"
#include "third_party/blink/renderer/platform/heap/collection_support/heap_vector.h"
#include "third_party/blink/renderer/platform/wtf/vector.h"
#include "third_party/zlib/zlib.h"
namespace blink {
enum class CompressionFormat;
class InflateTransformer final : public TransformStreamTransformer {
public:
InflateTransformer(ScriptState*, CompressionFormat);
InflateTransformer(const InflateTransformer&) = delete;
InflateTransformer& operator=(const InflateTransformer&) = delete;
~InflateTransformer() override;
ScriptPromise<IDLUndefined> Transform(v8::Local<v8::Value> chunk,
TransformStreamDefaultController*,
ExceptionState&) override;
ScriptPromise<IDLUndefined> Flush(TransformStreamDefaultController*,
ExceptionState&) override;
ScriptState* GetScriptState() override { return script_state_.Get(); }
void Trace(Visitor*) const override;
private:
using IsFinished = base::StrongAlias<class IsFinishedTag, bool>;
void Inflate(const uint8_t*,
wtf_size_t,
IsFinished,
TransformStreamDefaultController*,
ExceptionState&);
void EnqueueBuffers(TransformStreamDefaultController*,
HeapVector<Member<DOMUint8Array>, 1u> buffers,
ExceptionState&);
Member<ScriptState> script_state_;
z_stream stream_;
Vector<uint8_t> out_buffer_;
bool was_flush_called_ = false;
bool reached_end_ = false;
// This buffer size has been experimentally verified to be optimal.
static constexpr wtf_size_t kBufferSize = 65536;
};
} // namespace blink
#endif // THIRD_PARTY_BLINK_RENDERER_MODULES_COMPRESSION_INFLATE_TRANSFORMER_H_
|
