dart::bin::ZLibInflateFilter Class Reference

#include <filter.h>

Inheritance diagram for dart::bin::ZLibInflateFilter:

Public Member Functions
	ZLibInflateFilter (int32_t window_bits, uint8_t *dictionary, intptr_t dictionary_length, bool raw)
virtual	~ZLibInflateFilter ()
virtual bool	Init ()
virtual bool	Process (uint8_t *data, intptr_t length)
virtual intptr_t	Processed (uint8_t *buffer, intptr_t length, bool finish, bool end)
Public Member Functions inherited from dart::bin::Filter
virtual	~Filter ()
virtual bool	Init ()=0
virtual bool	Process (uint8_t *data, intptr_t length)=0
virtual intptr_t	Processed (uint8_t *buffer, intptr_t length, bool finish, bool end)=0
bool	initialized () const
void	set_initialized (bool value)
uint8_t *	processed_buffer ()
intptr_t	processed_buffer_size () const

Additional Inherited Members
Static Public Member Functions inherited from dart::bin::Filter
static Dart_Handle	SetFilterAndCreateFinalizer (Dart_Handle filter, Filter *filter_pointer, intptr_t filter_size)
static Dart_Handle	GetFilterNativeField (Dart_Handle filter, Filter **filter_pointer)
Protected Member Functions inherited from dart::bin::Filter
	Filter ()

Detailed Description

Definition at line 98 of file filter.h.

Constructor & Destructor Documentation

ZLibInflateFilter()

dart::bin::ZLibInflateFilter::ZLibInflateFilter ( int32_t  window_bits, uint8_t *  dictionary, intptr_t  dictionary_length, bool  raw  )

inline

Definition at line 100 of file filter.h.

      : window_bits_(window_bits),
        dictionary_(dictionary),
        dictionary_length_(dictionary_length),
        raw_(raw),
        current_buffer_(nullptr) {}

~ZLibInflateFilter()

dart::bin::ZLibInflateFilter::~ZLibInflateFilter ( )

virtual

Definition at line 371 of file filter.cc.

                                      {
  delete[] dictionary_;
  delete[] current_buffer_;
  if (initialized()) {
    inflateEnd(&stream_);
  }
}

Member Function Documentation

Init()

bool dart::bin::ZLibInflateFilter::Init ( )

virtual

Implements dart::bin::Filter.

Definition at line 379 of file filter.cc.

                             {
  int window_bits =
      raw_ ? -window_bits_ : window_bits_ | kZLibFlagAcceptAnyHeader;
 
  stream_.next_in = Z_NULL;
  stream_.avail_in = 0;
  stream_.zalloc = Z_NULL;
  stream_.zfree = Z_NULL;
  stream_.opaque = Z_NULL;
  int result = inflateInit2(&stream_, window_bits);
  if (result != Z_OK) {
    return false;
  }
  set_initialized(true);
  return true;
}

Process()

bool dart::bin::ZLibInflateFilter::Process ( uint8_t *  data, intptr_t  length  )

virtual

On a successful call to Process, Process will take ownership of data. On successive calls to either Processed or ~Filter, data will be freed with a delete[] call.

Implements dart::bin::Filter.

Definition at line 396 of file filter.cc.

                                                              {
  if (current_buffer_ != nullptr) {
    return false;
  }
  stream_.avail_in = length;
  stream_.next_in = current_buffer_ = data;
  return true;
}

Processed()

intptr_t dart::bin::ZLibInflateFilter::Processed ( uint8_t *  buffer, intptr_t  length, bool  finish, bool  end  )

virtual

Implements dart::bin::Filter.

Definition at line 405 of file filter.cc.

                                                {
  stream_.avail_out = length;
  stream_.next_out = buffer;
  bool error = false;
  int v;
  switch (v = inflate(&stream_, end     ? Z_FINISH
                                : flush ? Z_SYNC_FLUSH
                                        : Z_NO_FLUSH)) {
    case Z_OK:
    case Z_STREAM_END:
    case Z_BUF_ERROR: {
      intptr_t processed = length - stream_.avail_out;
 
      if (v == Z_STREAM_END) {
        // Allow for concatenated compressed blocks. For example:
        // final data = [
        //  ...gzip.encode([1, 2, 3]),
        //  ...gzip.encode([4, 5, 6]),
        // ];
        // final decoded = gzip.decode(data);  // [1, 2, 3, 4, 5, 6]
 
        // The return code for `inflateReset` can be ignored because, if the
        // result is an error, the same error will be returned in the next
        // call to `inflate`.
        inflateReset(&stream_);
      }
      if (processed == 0) {
        break;
      }
      return processed;
    }
 
    case Z_NEED_DICT:
      if (dictionary_ == nullptr) {
        error = true;
      } else {
        int result =
            inflateSetDictionary(&stream_, dictionary_, dictionary_length_);
        delete[] dictionary_;
        dictionary_ = nullptr;
        error = result != Z_OK;
      }
      if (error) {
        break;
      } else {
        return Processed(buffer, length, flush, end);
      }
 
    default:
    case Z_MEM_ERROR:
    case Z_DATA_ERROR:
    case Z_STREAM_ERROR:
      error = true;
  }
 
  delete[] current_buffer_;
  current_buffer_ = nullptr;
  // Either 0 Byte processed or error
  return error ? -1 : 0;
}

---

The documentation for this class was generated from the following files:

• third_party/dart-lang/sdk/runtime/bin/filter.h
• third_party/dart-lang/sdk/runtime/bin/filter.cc