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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
// Copyright (c) 2006-2008 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// SdchFilter applies open_vcdiff content decoding to a datastream.
// This decoding uses a pre-cached dictionary of text fragments to decode
// (expand) the stream back to its original contents.
//
// This SdchFilter internally uses open_vcdiff/vcdec library to do decoding.
//
// SdchFilter is also a subclass of Filter. See the latter's header file
// filter.h for sample usage.
#ifndef NET_BASE_SDCH_FILTER_H_
#define NET_BASE_SDCH_FILTER_H_
#pragma once
#include <string>
#include "base/scoped_ptr.h"
#include "net/base/filter.h"
#include "net/base/sdch_manager.h"
class SafeOutputStringInterface;
namespace open_vcdiff {
class VCDiffStreamingDecoder;
}
class SdchFilter : public Filter {
public:
explicit SdchFilter(const FilterContext& filter_context);
virtual ~SdchFilter();
// Initializes filter decoding mode and internal control blocks.
bool InitDecoding(Filter::FilterType filter_type);
// Decode the pre-filter data and writes the output into |dest_buffer|
// The function returns FilterStatus. See filter.h for its description.
//
// Upon entry, *dest_len is the total size (in number of chars) of the
// destination buffer. Upon exit, *dest_len is the actual number of chars
// written into the destination buffer.
virtual FilterStatus ReadFilteredData(char* dest_buffer, int* dest_len);
private:
// Internal status. Once we enter an error state, we stop processing data.
enum DecodingStatus {
DECODING_UNINITIALIZED,
WAITING_FOR_DICTIONARY_SELECTION,
DECODING_IN_PROGRESS,
DECODING_ERROR,
META_REFRESH_RECOVERY, // Decoding error being handled by a meta-refresh.
PASS_THROUGH, // Non-sdch content being passed without alteration.
};
// Identify the suggested dictionary, and initialize underlying decompressor.
Filter::FilterStatus InitializeDictionary();
// Move data that was internally buffered (after decompression) to the
// specified dest_buffer.
int OutputBufferExcess(char* const dest_buffer, size_t available_space);
// Tracks the status of decoding.
// This variable is initialized by InitDecoding and updated only by
// ReadFilteredData.
DecodingStatus decoding_status_;
// The underlying decoder that processes data.
// This data structure is initialized by InitDecoding and updated in
// ReadFilteredData.
scoped_ptr<open_vcdiff::VCDiffStreamingDecoder> vcdiff_streaming_decoder_;
// In case we need to assemble the hash piecemeal, we have a place to store
// a part of the hash until we "get all 8 bytes plus a null."
std::string dictionary_hash_;
// After assembling an entire dictionary hash (the first 9 bytes of the
// sdch payload, we check to see if it is plausible, meaning it has a null
// termination, and has 8 characters that are possible in a net-safe base64
// encoding. If the hash is not plausible, then the payload is probably not
// an SDCH encoded bundle, and various error recovery strategies can be
// attempted.
bool dictionary_hash_is_plausible_;
// We hold an in-memory copy of the dictionary during the entire decoding, as
// it is used directly by the VC-DIFF decoding system.
// That char* data is part of the dictionary_ we hold a reference to.
scoped_refptr<SdchManager::Dictionary> dictionary_;
// The decoder may demand a larger output buffer than the target of
// ReadFilteredData so we buffer the excess output between calls.
std::string dest_buffer_excess_;
// To avoid moving strings around too much, we save the index into
// dest_buffer_excess_ that has the next byte to output.
size_t dest_buffer_excess_index_;
// To get stats on activities, we keep track of source and target bytes.
// Visit about:histograms/Sdch to see histogram data.
size_t source_bytes_;
size_t output_bytes_;
// Error recovery in content type may add an sdch filter type, in which case
// we should gracefully perform pass through if the format is incorrect, or
// an applicable dictionary can't be found.
bool possible_pass_through_;
// The URL that is currently being filtered.
// This is used to restrict use of a dictionary to a specific URL or path.
GURL url_;
// To facilitate error recovery, allow filter to know if content is text/html
// by checking within this mime type (we may do a meta-refresh via html).
std::string mime_type_;
DISALLOW_COPY_AND_ASSIGN(SdchFilter);
};
#endif // NET_BASE_SDCH_FILTER_H_
|
