tensorflow/core/framework/tensor_util.cc - platform/external/tensorflow - Git at Google

 /* Copyright 2015 The TensorFlow Authors. All Rights Reserved.

 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 "tensorflow/core/framework/tensor_util.h"

 #include <cmath>
 #include <vector>

 #include "tensorflow/core/framework/tensor.h"
 #include "tensorflow/core/framework/type_traits.h"
 #include "tensorflow/core/framework/variant.h"
 #include "tensorflow/core/lib/core/stringpiece.h"
 #include "tensorflow/core/platform/protobuf.h"
 #include "tensorflow/core/platform/tensor_coding.h"
 #include "tensorflow/core/platform/types.h"

 namespace tensorflow {
 namespace tensor {

 Tensor DeepCopy(const Tensor& other) {
   Tensor tmp = Tensor(other.dtype(), other.shape());
   DeepCopy(other, &tmp);
   return tmp;
 }

 void DeepCopy(const Tensor& input, Tensor* output) {
   if (DataTypeCanUseMemcpy(input.dtype())) {
     if (input.NumElements() > 0) {
       StringPiece input_data = input.tensor_data();

       // We use StringPiece as a convenient map over the tensor buffer,
       // but we cast the type to get to the underlying buffer to do the
       // copy.
       StringPiece output_data = output->tensor_data();
       memcpy(const_cast<char*>(output_data.data()), input_data.data(),
              input_data.size());
     }
   } else if (input.dtype() == DT_STRING) {
     output->unaligned_flat<tstring>() = input.unaligned_flat<tstring>();
   } else {
     CHECK_EQ(DT_VARIANT, input.dtype());
     output->unaligned_flat<Variant>() = input.unaligned_flat<Variant>();
   }
 }

 Status Concat(const gtl::ArraySlice<Tensor>& tensors, Tensor* result) {
   if (tensors.empty()) {
     return errors::InvalidArgument("Cannot concatenate zero tensors");
   }
   int64 total_dim0_size = 0;
   for (const Tensor& tensor : tensors) {
     if (tensor.dims() == 0) {
       return errors::InvalidArgument(
           "Cannot concatenate a zero-dimensional tensor");
     }
     total_dim0_size += tensor.dim_size(0);
   }
   TensorShape shape = tensors[0].shape();
   shape.set_dim(0, total_dim0_size);

   const DataType dtype = tensors[0].dtype();
   for (int i = 1; i < tensors.size(); ++i) {
     if (tensors[i].dtype() != dtype) {
       return errors::InvalidArgument(
           "Cannot concatenate tensors that have different data types");
     }
   }
   *result = Tensor(dtype, shape);

   // We use StringPiece as a convenient map over the tensor buffer,
   // but we cast the type to get to the underlying buffer to do the
   // copy.
   StringPiece to_data = result->tensor_data();

   if (DataTypeCanUseMemcpy(dtype)) {
     int64 offset = 0;
     for (const Tensor& tensor : tensors) {
       StringPiece from_data = tensor.tensor_data();
       CHECK_LE(offset + from_data.size(), to_data.size());
       memcpy(const_cast<char*>(to_data.data()) + offset, from_data.data(),
              from_data.size());

       offset += from_data.size();
     }
   } else {
     if (dtype != DT_STRING) {
       return errors::Internal("Unexpected data type");
     }
     tstring* to_strings =
         reinterpret_cast<tstring*>(const_cast<char*>(to_data.data()));

     int64 offset = 0;
     for (const Tensor& tensor : tensors) {
       auto from_strings = tensor.flat<tstring>();
       CHECK_LE(offset + tensor.NumElements(), result->NumElements());
       for (int i = 0; i < tensor.NumElements(); ++i) {
         to_strings[offset + i] = from_strings(i);
       }

       offset += tensor.NumElements();
     }
   }

   return Status::OK();
 }

 Status Split(const Tensor& tensor, const gtl::ArraySlice<int64>& sizes,
              std::vector<Tensor>* result) {
   if (tensor.dims() == 0) {
     return errors::InvalidArgument("Cannot split a zero-dimensional tensor");
   }
   int64 total_size = 0;
   for (int64 size : sizes) {
     total_size += size;
   }
   if (total_size != tensor.dim_size(0)) {
     return errors::InvalidArgument(
         "The values in 'sizes' do not sum to the zeroth-dimension size of "
         "'tensor'");
   }

   StringPiece from_data = tensor.tensor_data();

   if (DataTypeCanUseMemcpy(tensor.dtype())) {
     int64 offset = 0;
     for (int64 size : sizes) {
       TensorShape shape = tensor.shape();
       shape.set_dim(0, size);
       result->emplace_back(tensor.dtype(), shape);
       Tensor* split = &(*result)[result->size() - 1];

       // We use StringPiece as a convenient map over the tensor buffer,
       // but we cast the type to get to the underlying buffer to do the
       // copy.
       StringPiece to_data = split->tensor_data();
       CHECK_LE(offset + to_data.size(), from_data.size());
       memcpy(const_cast<char*>(to_data.data()), from_data.data() + offset,
              to_data.size());

       offset += to_data.size();
     }
   } else {
     if (tensor.dtype() != DT_STRING) {
       return errors::Internal("Unexpected data type");
     }
     auto from_strings = tensor.flat<tstring>();

     int64 offset = 0;
     for (int64 size : sizes) {
       TensorShape shape = tensor.shape();
       shape.set_dim(0, size);
       result->emplace_back(tensor.dtype(), shape);
       Tensor& split = (*result)[result->size() - 1];
       tstring* to_strings = reinterpret_cast<tstring*>(
           const_cast<char*>(split.tensor_data().data()));

       CHECK_LE(offset + split.NumElements(), tensor.NumElements());
       for (int i = 0; i < split.NumElements(); ++i) {
         to_strings[i] = from_strings(offset + i);
       }

       offset += split.NumElements();
     }
   }

   return Status::OK();
 }

 namespace internal {
 void SetTensorProtoShape(std::vector<size_t> shape,
                          TensorShapeProto* shape_proto) {
   for (auto dim : shape) {
     shape_proto->mutable_dim()->Add()->set_size(dim);
   }
 }

 template <typename T>
 bool CompressTensorContent(float min_compression_ratio,
                            const TensorShape& shape, TensorProto* tensor) {
   using TypeHelper = internal::TensorProtoHelper<T>;
   using FieldType = typename internal::TensorProtoHelper<T>::FieldType;
   const int64 num_tensor_values = shape.num_elements();
   const int64 num_bytes = tensor->tensor_content().size();
   const int64 num_raw_values = num_bytes / sizeof(T);
   if (num_raw_values != num_tensor_values) {
     // Invalid or too small.
     return false;
   }
   int64 last_offset = num_bytes - 1;
   int64 prev_offset = last_offset - sizeof(T);
   // Inspect individual raw bytes sizeof(T) bytes apart in adjacent elements,
   // starting from the end, to find the last pair of elements that are not
   // identical.
   while (prev_offset >= 0) {
     if (tensor->tensor_content()[prev_offset] !=
         tensor->tensor_content()[last_offset]) {
       break;
     }
     --last_offset;
     --prev_offset;
   }
   // Round up to the next whole number of element of type T.
   const int64 new_num_values = last_offset / sizeof(T) + 1;
   if (new_num_values * (is_complex<T>::value ? 2 : 1) * sizeof(FieldType) >
       static_cast<int64>(num_bytes / min_compression_ratio)) {
     return false;
   }
   // Copy values to truncated repeated field.
   if (sizeof(FieldType) == sizeof(T)) {
     FieldType* dst_ptr =
         TypeHelper::AppendUninitialized(new_num_values, tensor);
     port::CopySubrangeToArray(tensor->tensor_content(), 0,
                               new_num_values * sizeof(T),
                               reinterpret_cast<char*>(dst_ptr));
     tensor->clear_tensor_content();
   } else if (sizeof(T) > 1) {
     // Copy raw bytes to temp array first, then cast.
     gtl::InlinedVector<T, 64> tmp(new_num_values);
     port::CopySubrangeToArray(tensor->tensor_content(), 0,
                               new_num_values * sizeof(T),
                               reinterpret_cast<char*>(tmp.data()));
     tensor->clear_tensor_content();
     const T* begin = tmp.begin();
     const T* end = tmp.end();
     TypeHelper::AddValues(begin, end, tensor);
   } else {
     // Copy and cast, one byte at a time.
     for (int64 i = 0; i < new_num_values; ++i) {
       char c = tensor->tensor_content()[i];
       TypeHelper::AddValue(static_cast<T>(c), tensor);
     }
     tensor->clear_tensor_content();
   }
   return true;
 }

 template <typename T>
 inline bool PackedValuesNotEqual(T a, T b) {
   return a != b;
 }
 template <>
 inline bool PackedValuesNotEqual(float a, float b) {
   return reinterpret_cast<int32_t&>(a) != reinterpret_cast<int32_t&>(b);
 }
 template <>
 inline bool PackedValuesNotEqual(double a, double b) {
   return reinterpret_cast<int64_t&>(a) != reinterpret_cast<int64_t&>(b);
 }
 template <typename RealType>
 inline bool PackedValuesNotEqual(const std::complex<RealType>& a,
                                  const std::complex<RealType>& b) {
   return PackedValuesNotEqual(a.real(), b.real()) ||
          PackedValuesNotEqual(a.imag(), b.imag());
 }

 template <typename T>
 bool CompressRepeatedField(float min_compression_ratio,
                            const TensorShape& shape, TensorProto* tensor) {
   using TypeHelper = internal::TensorProtoHelper<T>;
   using FieldType = typename internal::TensorProtoHelper<T>::FieldType;
   const int64 num_tensor_values = shape.num_elements();
   // Notice that for complex types the tensor is stored as an array of up to
   // 2 * num_tensor_values real values (real and imaginary parts), possibly
   // truncated.
   const int64 num_proto_values = TypeHelper::NumValues(*tensor);
   if (num_proto_values != num_tensor_values) {
     // Already compressed or invalid.
     return false;
   }
   const T last_value = TypeHelper::GetValue(num_proto_values - 1, *tensor);
   int64 last_index = 0;
   for (int64 i = num_proto_values - 2; i >= 0 && last_index == 0; --i) {
     const T cur_value = TypeHelper::GetValue(i, *tensor);
     if (PackedValuesNotEqual(cur_value, last_value)) {
       last_index = i + 1;
     }
   }
   const int64 num_truncated_proto_values = last_index + 1;
   const int64 num_bytes_as_field =
       num_truncated_proto_values * sizeof(FieldType);
   const int64 num_bytes_as_tensor_content = num_tensor_values * sizeof(T);
   const int64 num_bytes_before = num_proto_values * sizeof(FieldType);
   if (std::min(num_bytes_as_field, num_bytes_as_tensor_content) >
       static_cast<int64>(num_bytes_before / min_compression_ratio)) {
     return false;
   }
   if (num_bytes_as_field <= num_bytes_as_tensor_content) {
     TypeHelper::Truncate(num_truncated_proto_values, tensor);
   } else {
     gtl::InlinedVector<T, 64> tmp(num_tensor_values);
     TypeHelper::CopyValues(tmp.begin(), *tensor);
     TypeHelper::Truncate(0, tensor);
     port::CopyFromArray(tensor->mutable_tensor_content(),
                         reinterpret_cast<const char*>(tmp.data()),
                         num_bytes_as_tensor_content);
   }
   return true;
 }

 template <typename T>
 bool CompressTensorProtoInPlaceImpl(int64 min_num_elements,
                                     float min_compression_ratio,
                                     TensorProto* tensor) {
   const TensorShape shape(tensor->tensor_shape());
   const int64 num_tensor_values = shape.num_elements();
   if (num_tensor_values < min_num_elements) {
     return false;
   }
   if (tensor->tensor_content().empty()) {
     return CompressRepeatedField<T>(min_compression_ratio, shape, tensor);
   } else {
     return CompressTensorContent<T>(min_compression_ratio, shape, tensor);
   }
   return true;
 }

 }  // namespace internal

 #define HANDLE_COMPRESS_CASE(TF_TYPE)                                  \
   case TF_TYPE:                                                        \
     return internal::CompressTensorProtoInPlaceImpl<                   \
         EnumToDataType<TF_TYPE>::Type>(min_num_elements,               \
                                        min_compression_ratio, tensor); \
     break

 bool CompressTensorProtoInPlace(int64 min_num_elements,
                                 float min_compression_ratio,
                                 TensorProto* tensor) {
   switch (tensor->dtype()) {
     HANDLE_COMPRESS_CASE(DT_FLOAT);
     HANDLE_COMPRESS_CASE(DT_DOUBLE);
     HANDLE_COMPRESS_CASE(DT_COMPLEX64);
     HANDLE_COMPRESS_CASE(DT_COMPLEX128);
     HANDLE_COMPRESS_CASE(DT_UINT8);
     HANDLE_COMPRESS_CASE(DT_INT8);
     HANDLE_COMPRESS_CASE(DT_UINT16);
     HANDLE_COMPRESS_CASE(DT_INT16);
     HANDLE_COMPRESS_CASE(DT_UINT32);
     HANDLE_COMPRESS_CASE(DT_INT32);
     HANDLE_COMPRESS_CASE(DT_UINT64);
     HANDLE_COMPRESS_CASE(DT_INT64);
     HANDLE_COMPRESS_CASE(DT_BOOL);
     HANDLE_COMPRESS_CASE(DT_QUINT8);
     HANDLE_COMPRESS_CASE(DT_QINT8);
     HANDLE_COMPRESS_CASE(DT_QUINT16);
     HANDLE_COMPRESS_CASE(DT_QINT16);
     HANDLE_COMPRESS_CASE(DT_QINT32);
     HANDLE_COMPRESS_CASE(DT_HALF);
     HANDLE_COMPRESS_CASE(DT_BFLOAT16);
     default:
       return false;
   }
 }

 #undef HANDLE_COMPRESS_CASE

 }  // namespace tensor
 }  // namespace tensorflow
	/* Copyright 2015 The TensorFlow Authors. All Rights Reserved.

	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 "tensorflow/core/framework/tensor_util.h"

	#include <cmath>
	#include <vector>

	#include "tensorflow/core/framework/tensor.h"
	#include "tensorflow/core/framework/type_traits.h"
	#include "tensorflow/core/framework/variant.h"
	#include "tensorflow/core/lib/core/stringpiece.h"
	#include "tensorflow/core/platform/protobuf.h"
	#include "tensorflow/core/platform/tensor_coding.h"
	#include "tensorflow/core/platform/types.h"

	namespace tensorflow {
	namespace tensor {

	Tensor DeepCopy(const Tensor& other) {
	Tensor tmp = Tensor(other.dtype(), other.shape());
	DeepCopy(other, &tmp);
	return tmp;
	}

	void DeepCopy(const Tensor& input, Tensor* output) {
	if (DataTypeCanUseMemcpy(input.dtype())) {
	if (input.NumElements() > 0) {
	StringPiece input_data = input.tensor_data();

	// We use StringPiece as a convenient map over the tensor buffer,
	// but we cast the type to get to the underlying buffer to do the
	// copy.
	StringPiece output_data = output->tensor_data();
	memcpy(const_cast<char*>(output_data.data()), input_data.data(),
	input_data.size());
	}
	} else if (input.dtype() == DT_STRING) {
	output->unaligned_flat<tstring>() = input.unaligned_flat<tstring>();
	} else {
	CHECK_EQ(DT_VARIANT, input.dtype());
	output->unaligned_flat<Variant>() = input.unaligned_flat<Variant>();
	}
	}

	Status Concat(const gtl::ArraySlice<Tensor>& tensors, Tensor* result) {
	if (tensors.empty()) {
	return errors::InvalidArgument("Cannot concatenate zero tensors");
	}
	int64 total_dim0_size = 0;
	for (const Tensor& tensor : tensors) {
	if (tensor.dims() == 0) {
	return errors::InvalidArgument(
	"Cannot concatenate a zero-dimensional tensor");
	}
	total_dim0_size += tensor.dim_size(0);
	}
	TensorShape shape = tensors[0].shape();
	shape.set_dim(0, total_dim0_size);

	const DataType dtype = tensors[0].dtype();
	for (int i = 1; i < tensors.size(); ++i) {
	if (tensors[i].dtype() != dtype) {
	return errors::InvalidArgument(
	"Cannot concatenate tensors that have different data types");
	}
	}
	*result = Tensor(dtype, shape);

	// We use StringPiece as a convenient map over the tensor buffer,
	// but we cast the type to get to the underlying buffer to do the
	// copy.
	StringPiece to_data = result->tensor_data();

	if (DataTypeCanUseMemcpy(dtype)) {
	int64 offset = 0;
	for (const Tensor& tensor : tensors) {
	StringPiece from_data = tensor.tensor_data();
	CHECK_LE(offset + from_data.size(), to_data.size());
	memcpy(const_cast<char*>(to_data.data()) + offset, from_data.data(),
	from_data.size());

	offset += from_data.size();
	}
	} else {
	if (dtype != DT_STRING) {
	return errors::Internal("Unexpected data type");
	}
	tstring* to_strings =
	reinterpret_cast<tstring>(const_cast<char>(to_data.data()));

	int64 offset = 0;
	for (const Tensor& tensor : tensors) {
	auto from_strings = tensor.flat<tstring>();
	CHECK_LE(offset + tensor.NumElements(), result->NumElements());
	for (int i = 0; i < tensor.NumElements(); ++i) {
	to_strings[offset + i] = from_strings(i);
	}

	offset += tensor.NumElements();
	}
	}

	return Status::OK();
	}

	Status Split(const Tensor& tensor, const gtl::ArraySlice<int64>& sizes,
	std::vector<Tensor>* result) {
	if (tensor.dims() == 0) {
	return errors::InvalidArgument("Cannot split a zero-dimensional tensor");
	}
	int64 total_size = 0;
	for (int64 size : sizes) {
	total_size += size;
	}
	if (total_size != tensor.dim_size(0)) {
	return errors::InvalidArgument(
	"The values in 'sizes' do not sum to the zeroth-dimension size of "
	"'tensor'");
	}

	StringPiece from_data = tensor.tensor_data();

	if (DataTypeCanUseMemcpy(tensor.dtype())) {
	int64 offset = 0;
	for (int64 size : sizes) {
	TensorShape shape = tensor.shape();
	shape.set_dim(0, size);
	result->emplace_back(tensor.dtype(), shape);
	Tensor* split = &(*result)[result->size() - 1];

	// We use StringPiece as a convenient map over the tensor buffer,
	// but we cast the type to get to the underlying buffer to do the
	// copy.
	StringPiece to_data = split->tensor_data();
	CHECK_LE(offset + to_data.size(), from_data.size());
	memcpy(const_cast<char*>(to_data.data()), from_data.data() + offset,
	to_data.size());

	offset += to_data.size();
	}
	} else {
	if (tensor.dtype() != DT_STRING) {
	return errors::Internal("Unexpected data type");
	}
	auto from_strings = tensor.flat<tstring>();

	int64 offset = 0;
	for (int64 size : sizes) {
	TensorShape shape = tensor.shape();
	shape.set_dim(0, size);
	result->emplace_back(tensor.dtype(), shape);
	Tensor& split = (*result)[result->size() - 1];
	tstring* to_strings = reinterpret_cast<tstring*>(
	const_cast<char*>(split.tensor_data().data()));

	CHECK_LE(offset + split.NumElements(), tensor.NumElements());
	for (int i = 0; i < split.NumElements(); ++i) {
	to_strings[i] = from_strings(offset + i);
	}

	offset += split.NumElements();
	}
	}

	return Status::OK();
	}

	namespace internal {
	void SetTensorProtoShape(std::vector<size_t> shape,
	TensorShapeProto* shape_proto) {
	for (auto dim : shape) {
	shape_proto->mutable_dim()->Add()->set_size(dim);
	}
	}

	template <typename T>
	bool CompressTensorContent(float min_compression_ratio,
	const TensorShape& shape, TensorProto* tensor) {
	using TypeHelper = internal::TensorProtoHelper<T>;
	using FieldType = typename internal::TensorProtoHelper<T>::FieldType;
	const int64 num_tensor_values = shape.num_elements();
	const int64 num_bytes = tensor->tensor_content().size();
	const int64 num_raw_values = num_bytes / sizeof(T);
	if (num_raw_values != num_tensor_values) {
	// Invalid or too small.
	return false;
	}
	int64 last_offset = num_bytes - 1;
	int64 prev_offset = last_offset - sizeof(T);
	// Inspect individual raw bytes sizeof(T) bytes apart in adjacent elements,
	// starting from the end, to find the last pair of elements that are not
	// identical.
	while (prev_offset >= 0) {
	if (tensor->tensor_content()[prev_offset] !=
	tensor->tensor_content()[last_offset]) {
	break;
	}
	--last_offset;
	--prev_offset;
	}
	// Round up to the next whole number of element of type T.
	const int64 new_num_values = last_offset / sizeof(T) + 1;
	if (new_num_values * (is_complex<T>::value ? 2 : 1) * sizeof(FieldType) >
	static_cast<int64>(num_bytes / min_compression_ratio)) {
	return false;
	}
	// Copy values to truncated repeated field.
	if (sizeof(FieldType) == sizeof(T)) {
	FieldType* dst_ptr =
	TypeHelper::AppendUninitialized(new_num_values, tensor);
	port::CopySubrangeToArray(tensor->tensor_content(), 0,
	new_num_values * sizeof(T),
	reinterpret_cast<char*>(dst_ptr));
	tensor->clear_tensor_content();
	} else if (sizeof(T) > 1) {
	// Copy raw bytes to temp array first, then cast.
	gtl::InlinedVector<T, 64> tmp(new_num_values);
	port::CopySubrangeToArray(tensor->tensor_content(), 0,
	new_num_values * sizeof(T),
	reinterpret_cast<char*>(tmp.data()));
	tensor->clear_tensor_content();
	const T* begin = tmp.begin();
	const T* end = tmp.end();
	TypeHelper::AddValues(begin, end, tensor);
	} else {
	// Copy and cast, one byte at a time.
	for (int64 i = 0; i < new_num_values; ++i) {
	char c = tensor->tensor_content()[i];
	TypeHelper::AddValue(static_cast<T>(c), tensor);
	}
	tensor->clear_tensor_content();
	}
	return true;
	}

	template <typename T>
	inline bool PackedValuesNotEqual(T a, T b) {
	return a != b;
	}
	template <>
	inline bool PackedValuesNotEqual(float a, float b) {
	return reinterpret_cast<int32_t&>(a) != reinterpret_cast<int32_t&>(b);
	}
	template <>
	inline bool PackedValuesNotEqual(double a, double b) {
	return reinterpret_cast<int64_t&>(a) != reinterpret_cast<int64_t&>(b);
	}
	template <typename RealType>
	inline bool PackedValuesNotEqual(const std::complex<RealType>& a,
	const std::complex<RealType>& b) {
	return PackedValuesNotEqual(a.real(), b.real()) \|\|
	PackedValuesNotEqual(a.imag(), b.imag());
	}

	template <typename T>
	bool CompressRepeatedField(float min_compression_ratio,
	const TensorShape& shape, TensorProto* tensor) {
	using TypeHelper = internal::TensorProtoHelper<T>;
	using FieldType = typename internal::TensorProtoHelper<T>::FieldType;
	const int64 num_tensor_values = shape.num_elements();
	// Notice that for complex types the tensor is stored as an array of up to
	// 2 * num_tensor_values real values (real and imaginary parts), possibly
	// truncated.
	const int64 num_proto_values = TypeHelper::NumValues(*tensor);
	if (num_proto_values != num_tensor_values) {
	// Already compressed or invalid.
	return false;
	}
	const T last_value = TypeHelper::GetValue(num_proto_values - 1, *tensor);
	int64 last_index = 0;
	for (int64 i = num_proto_values - 2; i >= 0 && last_index == 0; --i) {
	const T cur_value = TypeHelper::GetValue(i, *tensor);
	if (PackedValuesNotEqual(cur_value, last_value)) {
	last_index = i + 1;
	}
	}
	const int64 num_truncated_proto_values = last_index + 1;
	const int64 num_bytes_as_field =
	num_truncated_proto_values * sizeof(FieldType);
	const int64 num_bytes_as_tensor_content = num_tensor_values * sizeof(T);
	const int64 num_bytes_before = num_proto_values * sizeof(FieldType);
	if (std::min(num_bytes_as_field, num_bytes_as_tensor_content) >
	static_cast<int64>(num_bytes_before / min_compression_ratio)) {
	return false;
	}
	if (num_bytes_as_field <= num_bytes_as_tensor_content) {
	TypeHelper::Truncate(num_truncated_proto_values, tensor);
	} else {
	gtl::InlinedVector<T, 64> tmp(num_tensor_values);
	TypeHelper::CopyValues(tmp.begin(), *tensor);
	TypeHelper::Truncate(0, tensor);
	port::CopyFromArray(tensor->mutable_tensor_content(),
	reinterpret_cast<const char*>(tmp.data()),
	num_bytes_as_tensor_content);
	}
	return true;
	}

	template <typename T>
	bool CompressTensorProtoInPlaceImpl(int64 min_num_elements,
	float min_compression_ratio,
	TensorProto* tensor) {
	const TensorShape shape(tensor->tensor_shape());
	const int64 num_tensor_values = shape.num_elements();
	if (num_tensor_values < min_num_elements) {
	return false;
	}
	if (tensor->tensor_content().empty()) {
	return CompressRepeatedField<T>(min_compression_ratio, shape, tensor);
	} else {
	return CompressTensorContent<T>(min_compression_ratio, shape, tensor);
	}
	return true;
	}

	} // namespace internal

	#define HANDLE_COMPRESS_CASE(TF_TYPE) \
	case TF_TYPE: \
	return internal::CompressTensorProtoInPlaceImpl< \
	EnumToDataType<TF_TYPE>::Type>(min_num_elements, \
	min_compression_ratio, tensor); \
	break

	bool CompressTensorProtoInPlace(int64 min_num_elements,
	float min_compression_ratio,
	TensorProto* tensor) {
	switch (tensor->dtype()) {
	HANDLE_COMPRESS_CASE(DT_FLOAT);
	HANDLE_COMPRESS_CASE(DT_DOUBLE);
	HANDLE_COMPRESS_CASE(DT_COMPLEX64);
	HANDLE_COMPRESS_CASE(DT_COMPLEX128);
	HANDLE_COMPRESS_CASE(DT_UINT8);
	HANDLE_COMPRESS_CASE(DT_INT8);
	HANDLE_COMPRESS_CASE(DT_UINT16);
	HANDLE_COMPRESS_CASE(DT_INT16);
	HANDLE_COMPRESS_CASE(DT_UINT32);
	HANDLE_COMPRESS_CASE(DT_INT32);
	HANDLE_COMPRESS_CASE(DT_UINT64);
	HANDLE_COMPRESS_CASE(DT_INT64);
	HANDLE_COMPRESS_CASE(DT_BOOL);
	HANDLE_COMPRESS_CASE(DT_QUINT8);
	HANDLE_COMPRESS_CASE(DT_QINT8);
	HANDLE_COMPRESS_CASE(DT_QUINT16);
	HANDLE_COMPRESS_CASE(DT_QINT16);
	HANDLE_COMPRESS_CASE(DT_QINT32);
	HANDLE_COMPRESS_CASE(DT_HALF);
	HANDLE_COMPRESS_CASE(DT_BFLOAT16);
	default:
	return false;
	}
	}

	#undef HANDLE_COMPRESS_CASE

	} // namespace tensor
	} // namespace tensorflow