aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorGravatar Yifei Feng <1192265+yifeif@users.noreply.github.com>2018-03-08 10:32:41 -0800
committerGravatar GitHub <noreply@github.com>2018-03-08 10:32:41 -0800
commitb315950540e80d4c67121ecabe4ed69c5f17fef8 (patch)
tree3b1e13ab549ec3bf7e2737970b645d4612652f9e
parent5fa816d17640509b19567c6d72f85fb00a8fefc0 (diff)
Also reverting ccedcb
-rw-r--r--tensorflow/core/distributed_runtime/tensor_coding.cc4
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);