finalizable_data.h

Go to the documentation of this file.

// Copyright (c) 2018, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
 
#ifndef RUNTIME_VM_FINALIZABLE_DATA_H_
#define RUNTIME_VM_FINALIZABLE_DATA_H_
 
#include "include/dart_api.h"
#include "platform/growable_array.h"
#include "vm/globals.h"
 
namespace dart {
 
struct FinalizableData {
  void* data;
  void* peer;
  Dart_HandleFinalizer callback;
  Dart_HandleFinalizer successful_write_callback;
};
 
class MessageFinalizableData {
 public:
  MessageFinalizableData()
      : records_(0), get_position_(0), take_position_(0), external_size_(0) {}
 
  ~MessageFinalizableData() {
    for (intptr_t i = take_position_; i < records_.length(); i++) {
      records_[i].callback(nullptr, records_[i].peer);
    }
  }
 
  /// If [successful_write_callback] is provided, it's invoked when message
  /// was serialized successfully.
  /// [callback] is invoked when serialization failed.
  void Put(intptr_t external_size,
           void* data,
           void* peer,
           Dart_HandleFinalizer callback,
           Dart_HandleFinalizer successful_write_callback = nullptr) {
    FinalizableData finalizable_data;
    finalizable_data.data = data;
    finalizable_data.peer = peer;
    finalizable_data.callback = callback;
    finalizable_data.successful_write_callback = successful_write_callback;
    records_.Add(finalizable_data);
    external_size_ += external_size;
  }
 
  // Retrieve the next FinalizableData, but still run its finalizer when |this|
  // is destroyed.
  FinalizableData Get() {
    ASSERT(get_position_ < records_.length());
    return records_[get_position_++];
  }
 
  // Retrieve the next FinalizableData, and skip its finalizer when |this| is
  // destroyed.
  FinalizableData Take() {
    ASSERT(take_position_ < records_.length());
    return records_[take_position_++];
  }
 
  void SerializationSucceeded() {
    for (intptr_t i = 0; i < records_.length(); i++) {
      if (records_[i].successful_write_callback != nullptr) {
        records_[i].successful_write_callback(nullptr, records_[i].peer);
      }
    }
  }
 
  void DropFinalizers() {
    records_.Clear();
    get_position_ = 0;
    take_position_ = 0;
    external_size_ = 0;
  }
 
  intptr_t external_size() const { return external_size_; }
 
 private:
  MallocGrowableArray<FinalizableData> records_;
  intptr_t get_position_;
  intptr_t take_position_;
  intptr_t external_size_;
 
  DISALLOW_COPY_AND_ASSIGN(MessageFinalizableData);
};
 
}  // namespace dart
 
#endif  // RUNTIME_VM_FINALIZABLE_DATA_H_