blob: 6fa8e5861c67404fc0406c50473693212ae40efe [file] [log] [blame]
/*
* Copyright (C) 2014 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef ART_RUNTIME_TRANSACTION_H_
#define ART_RUNTIME_TRANSACTION_H_
#include "base/scoped_arena_containers.h"
#include "base/macros.h"
#include "base/mutex.h"
#include "base/safe_map.h"
#include "base/value_object.h"
#include "dex/dex_file_types.h"
#include "dex/primitive.h"
#include "gc_root.h"
#include "offsets.h"
#include <list>
#include <map>
namespace art {
namespace gc {
class Heap;
} // namespace gc
namespace mirror {
class Array;
class Class;
class DexCache;
class Object;
class String;
} // namespace mirror
class InternTable;
template<class MirrorType> class ObjPtr;
class Transaction final {
public:
static constexpr const char* kAbortExceptionDescriptor = "Ldalvik/system/TransactionAbortError;";
Transaction(bool strict, mirror::Class* root, ArenaStack* arena_stack, ArenaPool* arena_pool);
~Transaction();
ArenaStack* GetArenaStack() {
return allocator_.GetArenaStack();
}
void Abort(const std::string& abort_message)
REQUIRES_SHARED(Locks::mutator_lock_);
void ThrowAbortError(Thread* self, const std::string* abort_message)
REQUIRES_SHARED(Locks::mutator_lock_);
bool IsAborted() const {
return aborted_;
}
// If the transaction is rollbacking. Transactions will set this flag when they start rollbacking,
// because the nested transaction should be disabled when rollbacking to restore the memory.
bool IsRollingBack() const {
return rolling_back_;
}
// If the transaction is in strict mode, then all access of static fields will be constrained,
// one class's clinit will not be allowed to read or modify another class's static fields, unless
// the transaction is aborted.
bool IsStrict() const {
return strict_;
}
// Record object field changes.
void RecordWriteFieldBoolean(mirror::Object* obj,
MemberOffset field_offset,
uint8_t value,
bool is_volatile);
void RecordWriteFieldByte(mirror::Object* obj,
MemberOffset field_offset,
int8_t value,
bool is_volatile);
void RecordWriteFieldChar(mirror::Object* obj,
MemberOffset field_offset,
uint16_t value,
bool is_volatile);
void RecordWriteFieldShort(mirror::Object* obj,
MemberOffset field_offset,
int16_t value,
bool is_volatile);
void RecordWriteField32(mirror::Object* obj,
MemberOffset field_offset,
uint32_t value,
bool is_volatile);
void RecordWriteField64(mirror::Object* obj,
MemberOffset field_offset,
uint64_t value,
bool is_volatile);
void RecordWriteFieldReference(mirror::Object* obj,
MemberOffset field_offset,
mirror::Object* value,
bool is_volatile);
// Record array change.
void RecordWriteArray(mirror::Array* array, size_t index, uint64_t value)
REQUIRES_SHARED(Locks::mutator_lock_);
// Record intern string table changes.
void RecordStrongStringInsertion(ObjPtr<mirror::String> s)
REQUIRES(Locks::intern_table_lock_);
void RecordWeakStringInsertion(ObjPtr<mirror::String> s)
REQUIRES(Locks::intern_table_lock_);
void RecordStrongStringRemoval(ObjPtr<mirror::String> s)
REQUIRES(Locks::intern_table_lock_);
void RecordWeakStringRemoval(ObjPtr<mirror::String> s)
REQUIRES(Locks::intern_table_lock_);
// Record resolve string.
void RecordResolveString(ObjPtr<mirror::DexCache> dex_cache, dex::StringIndex string_idx)
REQUIRES_SHARED(Locks::mutator_lock_);
// Record resolve method type.
void RecordResolveMethodType(ObjPtr<mirror::DexCache> dex_cache, dex::ProtoIndex proto_idx)
REQUIRES_SHARED(Locks::mutator_lock_);
// Abort transaction by undoing all recorded changes.
void Rollback()
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitRoots(RootVisitor* visitor)
REQUIRES_SHARED(Locks::mutator_lock_);
bool ReadConstraint(ObjPtr<mirror::Object> obj) const
REQUIRES_SHARED(Locks::mutator_lock_);
bool WriteConstraint(ObjPtr<mirror::Object> obj) const
REQUIRES_SHARED(Locks::mutator_lock_);
bool WriteValueConstraint(ObjPtr<mirror::Object> value) const
REQUIRES_SHARED(Locks::mutator_lock_);
private:
class ObjectLog : public ValueObject {
public:
void LogBooleanValue(MemberOffset offset, uint8_t value, bool is_volatile);
void LogByteValue(MemberOffset offset, int8_t value, bool is_volatile);
void LogCharValue(MemberOffset offset, uint16_t value, bool is_volatile);
void LogShortValue(MemberOffset offset, int16_t value, bool is_volatile);
void Log32BitsValue(MemberOffset offset, uint32_t value, bool is_volatile);
void Log64BitsValue(MemberOffset offset, uint64_t value, bool is_volatile);
void LogReferenceValue(MemberOffset offset, mirror::Object* obj, bool is_volatile);
void Undo(mirror::Object* obj) const REQUIRES_SHARED(Locks::mutator_lock_);
void VisitRoots(RootVisitor* visitor) REQUIRES_SHARED(Locks::mutator_lock_);
size_t Size() const {
return field_values_.size();
}
explicit ObjectLog(ScopedArenaAllocator* allocator)
: field_values_(std::less<uint32_t>(), allocator->Adapter(kArenaAllocTransaction)) {}
ObjectLog(ObjectLog&& log) = default;
private:
enum FieldValueKind {
kBoolean,
kByte,
kChar,
kShort,
k32Bits,
k64Bits,
kReference
};
struct FieldValue : public ValueObject {
// TODO use JValue instead ?
uint64_t value;
FieldValueKind kind;
bool is_volatile;
FieldValue() : value(0), kind(FieldValueKind::kBoolean), is_volatile(false) {}
FieldValue(FieldValue&& log) = default;
private:
DISALLOW_COPY_AND_ASSIGN(FieldValue);
};
void LogValue(FieldValueKind kind, MemberOffset offset, uint64_t value, bool is_volatile);
void UndoFieldWrite(mirror::Object* obj,
MemberOffset field_offset,
const FieldValue& field_value) const REQUIRES_SHARED(Locks::mutator_lock_);
// Maps field's offset to its value.
ScopedArenaSafeMap<uint32_t, FieldValue> field_values_;
DISALLOW_COPY_AND_ASSIGN(ObjectLog);
};
class ArrayLog : public ValueObject {
public:
void LogValue(size_t index, uint64_t value);
void Undo(mirror::Array* obj) const REQUIRES_SHARED(Locks::mutator_lock_);
size_t Size() const {
return array_values_.size();
}
explicit ArrayLog(ScopedArenaAllocator* allocator)
: array_values_(std::less<size_t>(), allocator->Adapter(kArenaAllocTransaction)) {}
ArrayLog(ArrayLog&& log) = default;
private:
void UndoArrayWrite(mirror::Array* array,
Primitive::Type array_type,
size_t index,
uint64_t value) const REQUIRES_SHARED(Locks::mutator_lock_);
// Maps index to value.
// TODO use JValue instead ?
ScopedArenaSafeMap<size_t, uint64_t> array_values_;
DISALLOW_COPY_AND_ASSIGN(ArrayLog);
};
class InternStringLog : public ValueObject {
public:
enum StringKind {
kStrongString,
kWeakString
};
enum StringOp {
kInsert,
kRemove
};
InternStringLog(ObjPtr<mirror::String> s, StringKind kind, StringOp op);
void Undo(InternTable* intern_table) const
REQUIRES_SHARED(Locks::mutator_lock_)
REQUIRES(Locks::intern_table_lock_);
void VisitRoots(RootVisitor* visitor) REQUIRES_SHARED(Locks::mutator_lock_);
// Only the move constructor is supported.
InternStringLog() = delete;
InternStringLog(const InternStringLog& log) = delete;
InternStringLog& operator=(const InternStringLog& log) = delete;
InternStringLog(InternStringLog&& log) = default;
InternStringLog& operator=(InternStringLog&& log) = delete;
private:
mutable GcRoot<mirror::String> str_;
const StringKind string_kind_;
const StringOp string_op_;
};
class ResolveStringLog : public ValueObject {
public:
ResolveStringLog(ObjPtr<mirror::DexCache> dex_cache, dex::StringIndex string_idx);
void Undo() const REQUIRES_SHARED(Locks::mutator_lock_);
void VisitRoots(RootVisitor* visitor) REQUIRES_SHARED(Locks::mutator_lock_);
private:
GcRoot<mirror::DexCache> dex_cache_;
const dex::StringIndex string_idx_;
DISALLOW_COPY_AND_ASSIGN(ResolveStringLog);
};
class ResolveMethodTypeLog : public ValueObject {
public:
ResolveMethodTypeLog(ObjPtr<mirror::DexCache> dex_cache, dex::ProtoIndex proto_idx);
void Undo() const REQUIRES_SHARED(Locks::mutator_lock_);
void VisitRoots(RootVisitor* visitor) REQUIRES_SHARED(Locks::mutator_lock_);
private:
GcRoot<mirror::DexCache> dex_cache_;
const dex::ProtoIndex proto_idx_;
DISALLOW_COPY_AND_ASSIGN(ResolveMethodTypeLog);
};
void LogInternedString(InternStringLog&& log)
REQUIRES(Locks::intern_table_lock_);
void UndoObjectModifications()
REQUIRES_SHARED(Locks::mutator_lock_);
void UndoArrayModifications()
REQUIRES_SHARED(Locks::mutator_lock_);
void UndoInternStringTableModifications()
REQUIRES(Locks::intern_table_lock_)
REQUIRES_SHARED(Locks::mutator_lock_);
void UndoResolveStringModifications()
REQUIRES_SHARED(Locks::mutator_lock_);
void UndoResolveMethodTypeModifications()
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitObjectLogs(RootVisitor* visitor, ArenaStack* arena_stack)
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitArrayLogs(RootVisitor* visitor, ArenaStack* arena_stack)
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitInternStringLogs(RootVisitor* visitor)
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitResolveStringLogs(RootVisitor* visitor)
REQUIRES_SHARED(Locks::mutator_lock_);
void VisitResolveMethodTypeLogs(RootVisitor* visitor)
REQUIRES_SHARED(Locks::mutator_lock_);
const std::string& GetAbortMessage() const;
ObjectLog& GetOrCreateObjectLog(mirror::Object* obj);
// The top-level transaction creates an `ArenaStack` which is then
// passed down to nested transactions.
std::optional<ArenaStack> arena_stack_;
// The allocator uses the `ArenaStack` from the top-level transaction.
ScopedArenaAllocator allocator_;
ScopedArenaSafeMap<mirror::Object*, ObjectLog> object_logs_;
ScopedArenaSafeMap<mirror::Array*, ArrayLog> array_logs_;
ScopedArenaForwardList<InternStringLog> intern_string_logs_;
ScopedArenaForwardList<ResolveStringLog> resolve_string_logs_;
ScopedArenaForwardList<ResolveMethodTypeLog> resolve_method_type_logs_;
bool aborted_;
bool rolling_back_; // Single thread, no race.
gc::Heap* const heap_;
const bool strict_;
std::string abort_message_;
mirror::Class* root_;
const char* assert_no_new_records_reason_;
friend class ScopedAssertNoNewTransactionRecords;
DISALLOW_COPY_AND_ASSIGN(Transaction);
};
class ScopedAssertNoNewTransactionRecords {
public:
explicit ScopedAssertNoNewTransactionRecords(const char* reason)
: transaction_(kIsDebugBuild ? InstallAssertion(reason) : nullptr) {}
~ScopedAssertNoNewTransactionRecords() {
if (kIsDebugBuild && transaction_ != nullptr) {
RemoveAssertion(transaction_);
}
}
private:
static Transaction* InstallAssertion(const char* reason);
static void RemoveAssertion(Transaction* transaction);
Transaction* transaction_;
};
} // namespace art
#endif // ART_RUNTIME_TRANSACTION_H_