diff options
author | 2018-03-08 10:32:41 -0800 | |
---|---|---|
committer | 2018-03-08 10:32:41 -0800 | |
commit | b315950540e80d4c67121ecabe4ed69c5f17fef8 (patch) | |
tree | 3b1e13ab549ec3bf7e2737970b645d4612652f9e | |
parent | 5fa816d17640509b19567c6d72f85fb00a8fefc0 (diff) |
Also reverting ccedcb
-rw-r--r-- | tensorflow/core/distributed_runtime/tensor_coding.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tensorflow/core/distributed_runtime/tensor_coding.cc b/tensorflow/core/distributed_runtime/tensor_coding.cc index 34a4013547..fe2d1a1293 100644 --- a/tensorflow/core/distributed_runtime/tensor_coding.cc +++ b/tensorflow/core/distributed_runtime/tensor_coding.cc @@ -81,7 +81,7 @@ void TensorResponse::InitPartial(const RecvTensorResponse& response) { Status TensorResponse::ParseFrom(Source* source) { if (!on_host_) { protobuf::io::CodedInputStream input(source->contents()); - input.SetTotalBytesLimit(INT_MAX); // Unlimited + input.SetTotalBytesLimit(INT_MAX, INT_MAX); // Unlimited // Pre-parse into local storage, then delegate to device. if (!meta_.ParseFromCodedStream(&input) || !input.ConsumedEntireMessage()) { @@ -217,7 +217,7 @@ bool TensorResponse::ParseTensorSubmessage( bool TensorResponse::ParseFast(Source* source) { protobuf::io::CodedInputStream input(source->contents()); - input.SetTotalBytesLimit(INT_MAX); // Unlimited + input.SetTotalBytesLimit(INT_MAX, INT_MAX); // Unlimited while (true) { auto p = input.ReadTagWithCutoff(127); int tag = GetTagFieldNumber(p.first); |