42 #include "../my_config.h"
55 #define ESCAPE_FIXED_SEQUENCE_NORMAL 0xAD
56 #define ESCAPE_FIXED_SEQUENCE_SPARSE_FILE 0xAE
58 #define MAX_BUFFER_SIZE 102400
60 #if SSIZE_MAX < MAX_BUFFER_SIZE
61 #undef MAX_BUFFER_SIZE
62 #define MAX_BUFFER_SIZE SSIZE_MAX
72 class escape :
public generic_file
105 escape(generic_file *below,
106 const std::set<sequence_type> & x_unjumpable);
107 escape(
const escape & ref) :
generic_file(ref) { copy_from(ref); };
108 escape(escape && ref) noexcept :
generic_file(std::move(ref)) { nullifyptr(); move_from(std::move(ref)); };
109 escape & operator = (
const escape & ref);
110 escape & operator = (escape && ref) noexcept {
generic_file::operator = (std::move(ref)); move_from(std::move(ref));
return *
this; };
115 void add_mark_at_current_position(sequence_type t);
123 bool skip_to_next_mark(sequence_type t,
bool jump);
124 bool next_to_read_is_mark(sequence_type t);
125 bool next_to_read_is_which_mark(sequence_type & t);
127 void add_unjumpable_mark(sequence_type t) {
if(
is_terminated())
throw SRC_BUG; unjumpable.insert(t); };
128 void remove_unjumpable_mark(sequence_type t);
129 bool is_unjumpable_mark(sequence_type t)
const {
return unjumpable.find(t) != unjumpable.end(); };
130 void clear_all_unjumpable_marks() { unjumpable.clear(); };
138 virtual bool skippable(skippability direction,
const infinint & amount)
override;
139 virtual bool skip(
const infinint & pos)
override;
140 virtual bool skip_to_eof()
override;
141 virtual bool skip_relative(S_I x)
override;
142 virtual infinint get_position()
const override;
145 virtual void inherited_read_ahead(
const infinint & amount)
override;
146 virtual U_I inherited_read(
char *a, U_I size)
override;
147 virtual void inherited_write(
const char *a, U_I size)
override;
148 virtual void inherited_sync_write()
override { flush_write(); };
149 virtual void inherited_flush_read()
override { flush_write(); clean_read(); };
150 virtual void inherited_terminate()
override { flush_or_clean(); };
152 void change_fixed_escape_sequence(
unsigned char value) { fixed_sequence[0] = value; };
153 bool has_escaped_data_since_last_skip()
const {
return escaped_data_count_since_last_skip > 0; };
160 static constexpr U_I ESCAPE_SEQUENCE_LENGTH = 6;
161 static constexpr U_I WRITE_BUFFER_SIZE = 2*ESCAPE_SEQUENCE_LENGTH;
162 static constexpr U_I READ_BUFFER_SIZE = MAX_BUFFER_SIZE;
163 static const infinint READ_BUFFER_SIZE_INFININT;
172 static const unsigned char usual_fixed_sequence[ESCAPE_SEQUENCE_LENGTH];
177 U_I write_buffer_size;
178 char write_buffer[WRITE_BUFFER_SIZE];
179 U_I read_buffer_size;
183 U_I escape_seq_offset_in_buffer;
184 char read_buffer[READ_BUFFER_SIZE];
185 std::set<sequence_type> unjumpable;
186 unsigned char fixed_sequence[ESCAPE_SEQUENCE_LENGTH];
187 infinint escaped_data_count_since_last_skip;
188 infinint below_position;
192 void set_fixed_sequence_for(sequence_type t) { fixed_sequence[ESCAPE_SEQUENCE_LENGTH - 1] = type2char(t); };
193 void check_below()
const {
if(x_below ==
nullptr)
throw SRC_BUG; };
196 void flush_or_clean()
211 void nullifyptr() noexcept { x_below =
nullptr; };
212 void copy_from(
const escape & ref);
213 void move_from(escape && ref) noexcept;
214 bool mini_read_buffer();
219 static char type2char(sequence_type x);
220 static sequence_type char2type(
char x);
228 static U_I trouve_amorce(
const char *a, U_I size,
const unsigned char escape_sequence[ESCAPE_SEQUENCE_LENGTH]);
238 static U_I remove_data_marks_and_stop_at_first_real_mark(
char *a, U_I size, U_I &
delta,
const unsigned char escape_sequence[ESCAPE_SEQUENCE_LENGTH]);