diff options
Diffstat (limited to 'runtime/lambda/closure_builder.cc')
-rw-r--r-- | runtime/lambda/closure_builder.cc | 210 |
1 files changed, 0 insertions, 210 deletions
diff --git a/runtime/lambda/closure_builder.cc b/runtime/lambda/closure_builder.cc deleted file mode 100644 index 739e965238..0000000000 --- a/runtime/lambda/closure_builder.cc +++ /dev/null @@ -1,210 +0,0 @@ -/* - * Copyright (C) 2015 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. - */ -#include "lambda/closure_builder.h" - -#include "base/macros.h" -#include "base/value_object.h" -#include "lambda/art_lambda_method.h" -#include "lambda/closure.h" -#include "lambda/shorty_field_type.h" -#include "runtime/mirror/object_reference.h" - -#include <stdint.h> -#include <vector> - -namespace art { -namespace lambda { - -/* - * GC support TODOs: - * (Although there's some code for storing objects, it is UNIMPLEMENTED(FATAL) because it is - * incomplete). - * - * 1) GC needs to be able to traverse the Closure and visit any references. - * It might be possible to get away with global roots in the short term. - * - * 2) Add brooks read barrier support. We can store the black/gray/white bits - * in the lower 2 bits of the lambda art method pointer. Whenever a closure is copied - * [to the stack] we'd need to add a cold path to turn it black. - * (since there's only 3 colors, I can use the 4th value to indicate no-refs). - * e.g. 0x0 = gray, 0x1 = white, 0x2 = black, 0x3 = no-nested-references - * - Alternatively the GC can mark reference-less closures as always-black, - * although it would need extra work to check for references. - */ - -void ClosureBuilder::CaptureVariableObject(mirror::Object* object) { - auto compressed_reference = mirror::CompressedReference<mirror::Object>::FromMirrorPtr(object); - ShortyFieldTypeTraits::MaxType storage = 0; - - static_assert(sizeof(storage) >= sizeof(compressed_reference), - "not enough room to store a compressed reference"); - memcpy(&storage, &compressed_reference, sizeof(compressed_reference)); - - values_.push_back(storage); - size_ += kObjectReferenceSize; - - static_assert(kObjectReferenceSize == sizeof(compressed_reference), "reference size mismatch"); - - // TODO: needs more work to support concurrent GC - if (kIsDebugBuild) { - if (kUseReadBarrier) { - UNIMPLEMENTED(FATAL) << "can't yet safely capture objects with read barrier"; - } - } - - shorty_types_ += ShortyFieldType::kObject; -} - -void ClosureBuilder::CaptureVariableLambda(Closure* closure) { - DCHECK(closure != nullptr); // null closures not allowed, target method must be null instead. - values_.push_back(reinterpret_cast<ShortyFieldTypeTraits::MaxType>(closure)); - - if (LIKELY(is_dynamic_size_ == false)) { - // Write in the extra bytes to store the dynamic size the first time. - is_dynamic_size_ = true; - size_ += sizeof(Closure::captured_[0].dynamic_.size_); - } - - // A closure may be sized dynamically, so always query it for the true size. - size_ += closure->GetSize(); - - shorty_types_ += ShortyFieldType::kLambda; -} - -size_t ClosureBuilder::GetSize() const { - return size_; -} - -size_t ClosureBuilder::GetCaptureCount() const { - DCHECK_EQ(values_.size(), shorty_types_.size()); - return values_.size(); -} - -const std::string& ClosureBuilder::GetCapturedVariableShortyTypes() const { - DCHECK_EQ(values_.size(), shorty_types_.size()); - return shorty_types_; -} - -Closure* ClosureBuilder::CreateInPlace(void* memory, ArtLambdaMethod* target_method) const { - DCHECK(memory != nullptr); - DCHECK(target_method != nullptr); - DCHECK_EQ(is_dynamic_size_, target_method->IsDynamicSize()); - - CHECK_EQ(target_method->GetNumberOfCapturedVariables(), values_.size()) - << "number of variables captured at runtime does not match " - << "number of variables captured at compile time"; - - Closure* closure = new (memory) Closure; - closure->lambda_info_ = target_method; - - static_assert(offsetof(Closure, captured_) == kInitialSize, "wrong initial size"); - - size_t written_size; - if (UNLIKELY(is_dynamic_size_)) { - // The closure size must be set dynamically (i.e. nested lambdas). - closure->captured_[0].dynamic_.size_ = GetSize(); - size_t header_size = offsetof(Closure, captured_[0].dynamic_.variables_); - DCHECK_LE(header_size, GetSize()); - size_t variables_size = GetSize() - header_size; - written_size = - WriteValues(target_method, - closure->captured_[0].dynamic_.variables_, - header_size, - variables_size); - } else { - // The closure size is known statically (i.e. no nested lambdas). - DCHECK(GetSize() == target_method->GetStaticClosureSize()); - size_t header_size = offsetof(Closure, captured_[0].static_variables_); - DCHECK_LE(header_size, GetSize()); - size_t variables_size = GetSize() - header_size; - written_size = - WriteValues(target_method, - closure->captured_[0].static_variables_, - header_size, - variables_size); - } - - DCHECK_EQ(written_size, closure->GetSize()); - - return closure; -} - -size_t ClosureBuilder::WriteValues(ArtLambdaMethod* target_method, - uint8_t variables[], - size_t header_size, - size_t variables_size) const { - size_t total_size = header_size; - const char* shorty_types = target_method->GetCapturedVariablesShortyTypeDescriptor(); - DCHECK_STREQ(shorty_types, shorty_types_.c_str()); - - size_t variables_offset = 0; - size_t remaining_size = variables_size; - - const size_t shorty_count = target_method->GetNumberOfCapturedVariables(); - DCHECK_EQ(shorty_count, GetCaptureCount()); - - for (size_t i = 0; i < shorty_count; ++i) { - ShortyFieldType shorty{shorty_types[i]}; // NOLINT [readability/braces] [4] - - size_t var_size; - if (LIKELY(shorty.IsStaticSize())) { - // TODO: needs more work to support concurrent GC, e.g. read barriers - if (kUseReadBarrier == false) { - if (UNLIKELY(shorty.IsObject())) { - UNIMPLEMENTED(FATAL) << "can't yet safely write objects with read barrier"; - } - } else { - if (UNLIKELY(shorty.IsObject())) { - UNIMPLEMENTED(FATAL) << "writing objects not yet supported, no GC support"; - } - } - - var_size = shorty.GetStaticSize(); - DCHECK_LE(var_size, sizeof(values_[i])); - - // Safe even for objects (non-read barrier case) if we never suspend - // while the ClosureBuilder is live. - // FIXME: Need to add GC support for references in a closure. - memcpy(&variables[variables_offset], &values_[i], var_size); - } else { - DCHECK(shorty.IsLambda()) - << " don't support writing dynamically sized types other than lambda"; - - ShortyFieldTypeTraits::MaxType closure_raw = values_[i]; - Closure* nested_closure = reinterpret_cast<Closure*>(closure_raw); - - DCHECK(nested_closure != nullptr); - nested_closure->CopyTo(&variables[variables_offset], remaining_size); - - var_size = nested_closure->GetSize(); - } - - total_size += var_size; - DCHECK_GE(remaining_size, var_size); - remaining_size -= var_size; - - variables_offset += var_size; - } - - DCHECK_EQ('\0', shorty_types[shorty_count]); - DCHECK_EQ(variables_offset, variables_size); - - return total_size; -} - - -} // namespace lambda -} // namespace art |