Remove on_device_shape and logical_on_device_shape

WORKSPACE

@@ -42,6 +42,7 @@ http_archive(
         "//openxla_patches:f16_abi_clang.diff",
         "//openxla_patches:gpu_race_condition.diff",
         "//openxla_patches:constexpr_return.diff",
+        "//openxla_patches:pjrt_c_api_dynamic_dimensions.diff",
     ],
     strip_prefix = "xla-7a371ed44aba34f83d6d3d1159d2e6d0d327c603",
     urls = [

openxla_patches/pjrt_c_api_dynamic_dimensions.diff

@@ -0,0 +1,74 @@
+diff --git a/xla/pjrt/pjrt_c_api_client.cc b/xla/pjrt/pjrt_c_api_client.cc
+index d45b9377c..92d244750 100644
+--- a/xla/pjrt/pjrt_c_api_client.cc
++++ b/xla/pjrt/pjrt_c_api_client.cc
+@@ -1489,6 +1489,34 @@ bool PjRtCApiBuffer::has_dynamic_dimensions() const {
+   return args.num_dynamic_dims > 0;
+ }
+
++absl::Span<const bool> PjRtCApiBuffer::is_dynamic_dimension() const {
++  {
++    absl::MutexLock lock(&mu_);
++    if (!is_dynamic_dimension_.has_value()) {
++      absl::InlinedVector<bool, InlineRank()>& is_dynamic_dimension_value =
++          is_dynamic_dimension_.emplace();
++      is_dynamic_dimension_value.assign(dimensions().size(), false);
++
++      PJRT_Buffer_DynamicDimensionIndices_Args args;
++      args.struct_size = PJRT_Buffer_DynamicDimensionIndices_Args_STRUCT_SIZE;
++      args.priv = nullptr;
++      args.buffer = buffer_.get();
++      const PJRT_Api* api = pjrt_c_api();
++      std::unique_ptr<PJRT_Error, pjrt::PJRT_ErrorDeleter> error(
++          api->PJRT_Buffer_DynamicDimensionIndices(&args),
++          pjrt::MakeErrorDeleter(api));
++      if (error && pjrt::GetErrorCode(error.get(), api) ==
++                       PJRT_Error_Code_UNIMPLEMENTED) {
++        return *is_dynamic_dimension_;
++      }
++      for (int i = 0; i < args.num_dynamic_dims; ++i) {
++        is_dynamic_dimension_value[args.dynamic_dim_indices[i]] = true;
++      }
++    }
++  }
++  return *is_dynamic_dimension_;
++}
++
+ StatusOr<std::vector<int64_t>> PjRtCApiBuffer::logical_dimensions() {
+   PJRT_Buffer_UnpaddedDimensions_Args args;
+   args.struct_size = PJRT_Buffer_UnpaddedDimensions_Args_STRUCT_SIZE;
+diff --git a/xla/pjrt/pjrt_c_api_client.h b/xla/pjrt/pjrt_c_api_client.h
+index b9597f923..5101b09a9 100644
+--- a/xla/pjrt/pjrt_c_api_client.h
++++ b/xla/pjrt/pjrt_c_api_client.h
+@@ -23,6 +23,7 @@ limitations under the License.
+ #include <utility>
+ #include <vector>
+
++#include "absl/container/inlined_vector.h"
+ #include "xla/pjrt/c/pjrt_c_api.h"
+ #include "xla/pjrt/c/pjrt_c_api_helpers.h"
+ #include "xla/pjrt/pjrt_client.h"
+@@ -320,11 +321,7 @@ class PjRtCApiBuffer : public PjRtBuffer {
+
+   bool has_dynamic_dimensions() const override;
+
+-  absl::Span<const bool> is_dynamic_dimension() const override {
+-    LOG(FATAL) << "PjRtCApiBuffer::is_dynamic_dimension() not implemented. "
+-               << "Considering using has_dynamic_dimensions() or "
+-                  "logical_dimensions() if applicable.";
+-  }
++  absl::Span<const bool> is_dynamic_dimension() const override;
+
+   StatusOr<std::vector<int64_t>> logical_dimensions() override;
+
+@@ -407,6 +404,9 @@ class PjRtCApiBuffer : public PjRtBuffer {
+   std::shared_ptr<PjRtFuture<Status>::Promise> readiness_promise_;
+   // Set and cached the first time layout() is called.
+   mutable std::optional<xla::Layout> layout_;
++  // Set and cached the first time is_dynamic_dimension() is called.
++  mutable std::optional<absl::InlinedVector<bool, InlineRank()>>
++      is_dynamic_dimension_;
+   // Used to synchronize concurrent setting of cached values.
+   mutable absl::Mutex mu_;
+ };

torch_xla/csrc/runtime/pjrt_computation_client.cc

@@ -70,6 +70,15 @@ std::unordered_map<int, int> build_index_map(
   return device_index;
 }
 
+// Builds the xla::Shape of the output xla::Literal on the host.
+xla::Shape host_output_shape(xla::PjRtBuffer* buffer) {
+  xla::Shape shape = xla::ShapeUtil::MakeShape(
+      buffer->element_type(), buffer->logical_dimensions().value());
+  *shape.mutable_layout() = buffer->layout();
+
+  return xla::ShapeUtil::DeviceShapeToHostShape(shape);
+}
+
 }  // namespace
 
 std::string PjRtComputationClient::PjRtDeviceToString(
@@ -424,9 +433,8 @@ std::vector<xla::Literal> PjRtComputationClient::TransferFromServer(
     auto new_handle = ReplicateShardedData(handle);
     const PjRtData& pjrt_data = dynamic_cast<const PjRtData&>(*new_handle);
 
-    xla::Shape target_shape = xla::ShapeUtil::DeviceShapeToHostShape(
-        pjrt_data.buffer->logical_on_device_shape().value());
-    auto& literal = literals.emplace_back(target_shape);
+    auto& literal =
+        literals.emplace_back(host_output_shape(pjrt_data.buffer.get()));
     XLA_CHECK_OK(pjrt_data.buffer->ToLiteralSync(&literal));
 
     total_size += literal.size_bytes();
@@ -569,8 +577,8 @@ PjRtComputationClient::ExecuteComputation(
   for (auto& result : results) {
     std::unique_ptr<xla::PjRtBuffer> buffer = std::move(result);
 
-    std::shared_ptr<PjRtData> data = std::make_shared<PjRtData>(
-        device, buffer->on_device_shape(), std::move(buffer));
+    std::shared_ptr<PjRtData> data =
+        std::make_shared<PjRtData>(device, std::move(buffer));
 
     datas.push_back(data);
   }
@@ -697,8 +705,8 @@ PjRtComputationClient::ExecuteReplicated(
             << "Exepcted device: " << pjrt_device->DebugString()
             << " vs. actual device: " << buffer->device()->DebugString();
 
-        std::shared_ptr<PjRtData> data = std::make_shared<PjRtData>(
-            devices[i], buffer->on_device_shape(), std::move(buffer));
+        std::shared_ptr<PjRtData> data =
+            std::make_shared<PjRtData>(devices[i], std::move(buffer));
         datas.push_back(data);
       }
       data_handles.push_back(datas);

torch_xla/csrc/runtime/pjrt_computation_client.h

@@ -164,6 +164,12 @@ class PjRtComputationClient : public ComputationClient {
              std::shared_ptr<xla::PjRtBuffer> buffer)
         : Data(std::move(device), std::move(device_shape)), buffer(buffer) {}
 
+    PjRtData(std::string device, std::shared_ptr<xla::PjRtBuffer> buffer)
+        : Data(std::move(device),
+               xla::Shape(buffer->element_type(), buffer->dimensions(),
+                          buffer->is_dynamic_dimension(), {})),
+          buffer(buffer) {}
+
     OpaqueHandle GetOpaqueHandle() override {
       XLA_CHECK(HasValue())
           << "buffer with shape " << shape().ToString() << " on device "